Merge pull request gocelery#48 from haritsfahreza/master

Add AMQP Celery backend and broker initialize using conn and channel

amqp_backend.go

@@ -16,18 +16,23 @@ type AMQPCeleryBackend struct {
 	host       string
 }
 
-// NewAMQPCeleryBackend creates new AMQPCeleryBackend
-func NewAMQPCeleryBackend(host string) *AMQPCeleryBackend {
-	conn, channel := NewAMQPConnection(host)
+// NewAMQPCeleryBackendByConnAndChannel creates new AMQPCeleryBackend by AMQP conn and channel
+func NewAMQPCeleryBackendByConnAndChannel(conn *amqp.Connection, channel *amqp.Channel) *AMQPCeleryBackend {
 	// ensure exchange is initialized
 	backend := &AMQPCeleryBackend{
 		Channel:    channel,
 		connection: conn,
-		host:       host,
 	}
 	return backend
 }
 
+// NewAMQPCeleryBackend creates new AMQPCeleryBackend
+func NewAMQPCeleryBackend(host string) *AMQPCeleryBackend {
+	backend := NewAMQPCeleryBackendByConnAndChannel(NewAMQPConnection(host))
+	backend.host = host
+	return backend
+}
+
 // Reconnect reconnects to AMQP server
 func (b *AMQPCeleryBackend) Reconnect() {
 	b.connection.Close()

amqp_broker.go

@@ -57,7 +57,7 @@ func NewAMQPConnection(host string) (*amqp.Connection, *amqp.Channel) {
 	if err != nil {
 		panic(err)
 	}
-	//defer connection.Close()
+
 	channel, err := connection.Channel()
 	if err != nil {
 		panic(err)
@@ -67,7 +67,11 @@ func NewAMQPConnection(host string) (*amqp.Connection, *amqp.Channel) {
 
 // NewAMQPCeleryBroker creates new AMQPCeleryBroker
 func NewAMQPCeleryBroker(host string) *AMQPCeleryBroker {
-	conn, channel := NewAMQPConnection(host)
+	return NewAMQPCeleryBrokerByConnAndChannel(NewAMQPConnection(host))
+}
+
+// NewAMQPCeleryBrokerByConnAndChannel creates new AMQPCeleryBroker using AMQP conn and channel
+func NewAMQPCeleryBrokerByConnAndChannel(conn *amqp.Connection, channel *amqp.Channel) *AMQPCeleryBroker {
 	// ensure exchange is initialized
 	broker := &AMQPCeleryBroker{
 		Channel:    channel,