Fix for publisher and add a method to access consumer::connection()

Author: microThread

src/Consumer.php

@@ -130,6 +130,14 @@ public function queue()
         return $this->queue;
     }
 
+    /**
+     * @return Connection
+     */
+    public function connection()
+    {
+        return $this->queue->connection();
+    }
+
     /**
      * @return $this
      *

src/Publisher.php

@@ -126,7 +126,7 @@ public function publish(Amqp\AmqpMessage $message, $retry = 0, $onRetry = null,
                     \call_user_func_array($onRetry, [$this, $error]);
                 }
 
-                \usleep(1e6 * $delay);
+                \usleep((int) (1e6 * $delay));
             }
         } while (--$retry > 0);