Merge pull request #44 from jimhorng/feature/auto_create_exchange

Auto create/bind exchange, queue as celery's behavior

tcelery/producer.py

@@ -86,6 +86,11 @@ def publish(self, body, routing_key=None, delivery_mode=None,
          self.encoder) = serialization.registry._encoders[self.serializer]
 
         conn = self.conn_pool.connection()
+
+        for entity in declare:
+            entity.maybe_bind(self.channel)
+            entity.declare()
+
         publish = conn.publish
         result = publish(body, priority=priority, content_type=content_type,
                          content_encoding=content_encoding, headers=headers,