ConnectionUp will tell if this is a first connect or a reconnect

coolamqp/events.py

@@ -14,6 +14,9 @@ class ConnectionDown(ClusterEvent):
 class ConnectionUp(ClusterEvent):
     """Connection to broker has been (re)established"""
 
+    def __init__(self, initial=False):
+        self.initial = initial  #: public, is this first connection up in this cluster ever?
+
 
 class MessageReceived(ClusterEvent):
     """A message has been received from the broker"""

coolamqp/handler.py

@@ -33,6 +33,7 @@ class ClusterHandlerThread(threading.Thread):
         self.queues_by_consumer_tags = {}   # listened queues, by their consumer tags
 
         self.backend = None
+        self.first_connect = True
 
     def _reconnect(self):
         exponential_backoff_delay = 1
@@ -80,7 +81,8 @@ class ClusterHandlerThread(threading.Thread):
                     exponential_backoff_delay = 60
             else:
                 self.cluster.connected = True
-                self.event_queue.put(ConnectionUp())
+                self.event_queue.put(ConnectionUp(initial=self.first_connect))
+                self.first_connect = False
                 break   # we connected :)
 
 

examples/send_to_myself.py

@@ -6,7 +6,7 @@ QUEUE_NAME = 'f'
 
 logging.basicConfig()
 
-cluster = Cluster([ClusterNode('xx', 'xx', 'xx', 'xx', heartbeat=10)]).start()
+cluster = Cluster([ClusterNode('192.168.224.31:5672', 'smok', 'smok', 'smok', heartbeat=10)]).start()
 
 a_queue = Queue(QUEUE_NAME, auto_delete=True)
 cluster.consume(a_queue)