More examples in demo for multiple hosts connections

php-amqplib · Apr 20, 2018 · f6243b8 · f6243b8
1 parent 4e55d9f
commit f6243b8
Show file tree

Hide file tree

Showing 2 changed files with 36 additions and 0 deletions.
diff --git a/demo/amqp_connect_multiple_hosts.php b/demo/amqp_connect_multiple_hosts.php
@@ -2,6 +2,7 @@
 
 include(__DIR__ . '/config.php');
 use PhpAmqpLib\Connection\AMQPStreamConnection;
+use PhpAmqpLib\Connection\AMQPSocketConnection;
 use PhpAmqpLib\Connection\AMQPSSLConnection;
 
 define('CERTS_PATH', '/git/rabbitmqinaction/av_scratchwork/openssl');
@@ -36,6 +37,40 @@
     'heartbeat' => 0
 ]);
 
+
+// Use empty options array for defaults
+$connection = AMQPStreamConnection::create_connection([
+    ['host' => HOST, 'port' => PORT, 'user' => USER, 'password' => PASS, 'vhost' => VHOST],
+    ['host' => HOST, 'port' => 5673, 'user' => USER, 'password' => PASS, 'vhost' => VHOST],
+    ['host' => HOST, 'port' => 5674, 'user' => USER, 'password' => PASS, 'vhost' => VHOST]
+],
+[]);
+
+// Options keys are different for different connection types
+$connection = AMQPSocketConnection::create_connection([
+    ['host' => HOST, 'port' => PORT, 'user' => USER, 'password' => PASS, 'vhost' => VHOST],
+    ['host' => HOST, 'port' => 5673, 'user' => USER, 'password' => PASS, 'vhost' => VHOST],
+    ['host' => HOST, 'port' => 5674, 'user' => USER, 'password' => PASS, 'vhost' => VHOST]
+],
+[
+    'insist' => false,
+    'login_method' => 'AMQPLAIN',
+    'login_response' => null,
+    'locale' => 'en_US',
+    'read_timeout' => 3,
+    'keepalive' => false,
+    'write_timeout' => 3,
+    'heartbeat' => 0
+]);
+
+// Use empty options array for defaults
+$connection = AMQPSocketConnection::create_connection([
+    ['host' => HOST, 'port' => PORT, 'user' => USER, 'password' => PASS, 'vhost' => VHOST],
+    ['host' => HOST, 'port' => 5673, 'user' => USER, 'password' => PASS, 'vhost' => VHOST],
+    ['host' => HOST, 'port' => 5674, 'user' => USER, 'password' => PASS, 'vhost' => VHOST]
+], []);
+
+
 /*
     For SSL connections you should set 'ssl_options' in the options array
 */

diff --git a/demo/connection_recovery_consume.php b/demo/connection_recovery_consume.php
@@ -17,6 +17,7 @@
 */
 
 function connect() {
+    // If you want a better load-balancing, you cann reshuffle the list.
     return AMQPStreamConnection::create_connection([
         ['host' => HOST, 'port' => PORT1, 'user' => USER, 'password' => PASS, 'vhost' => VHOST],
         ['host' => HOST, 'port' => PORT2, 'user' => USER, 'password' => PASS, 'vhost' => VHOST],