diff --git a/reference/amqp/examples.xml b/reference/amqp/examples.xml
index f9ede033b1..066258598a 100644
--- a/reference/amqp/examples.xml
+++ b/reference/amqp/examples.xml
@@ -11,6 +11,7 @@
 
 // Create a connection
 $cnn = new AMQPConnection();
+$cnn->connect();
 
 // Declare a new exchange
 $ex = new AMQPExchange($cnn);