added queue binding

client.go

@@ -62,7 +62,6 @@ type QueueSettings struct {
 	Arguments            amqp.Table
 	QueuePublishSettings QueuePublishSettings
 	QueueConsumeSettings QueueConsumeSettings
-	QueueBindSettings    QueueBindSettings
 }
 
 type QueuePublishSettings struct {
@@ -239,22 +238,6 @@ func (client *Client) init(conn *amqp.Connection) error {
 
 		client.AssignedQueueName = q.Name
 
-		log.Println("AssignedQueueName", q.Name)
-
-		if client.queueSettings.QueueBindSettings.QueueName != "" {
-			err = ch.QueueBind(
-				client.queueSettings.QueueBindSettings.QueueName,
-				client.queueSettings.QueueBindSettings.RoutingKey,
-				client.queueSettings.QueueBindSettings.Exchange,
-				client.queueSettings.QueueBindSettings.NoWait,
-				client.queueSettings.QueueBindSettings.Arguments,
-			)
-
-			if err != nil {
-				return err
-			}
-		}
-
 		client.changeChannel(ch)
 	}
 
@@ -264,6 +247,16 @@ func (client *Client) init(conn *amqp.Connection) error {
 	return nil
 }
 
+func (client *Client) QueueBind(queueBindSettings QueueBindSettings) error {
+	return client.Channel.QueueBind(
+		queueBindSettings.QueueName,
+		queueBindSettings.RoutingKey,
+		queueBindSettings.Exchange,
+		queueBindSettings.NoWait,
+		queueBindSettings.Arguments,
+	)
+}
+
 // changeConnection takes a new connection to the queue,
 // and updates the close listener to reflect this.
 func (client *Client) changeConnection(connection *amqp.Connection) {