         chai.expect(msg).to.include.keys 'data'
         chai.expect(msg.data).to.eql payload
         done()
-      createConnectClients ['sender', 'receiver'], (clients, err) ->
-        clients.receiver.createQueue 'inqueue', sharedQueue, (err) ->
-          chai.expect(err).to.be.a 'null'
-          clients.sender.createQueue 'outqueue', sharedQueue, (err) ->
-            chai.expect(err).to.be.a 'null'
+      createConnectClients address, ['sender', 'receiver'], (err, clients) ->
+        createQueues [
+          [ clients.receiver, 'inqueue', sharedQueue ]
+          [ clients.sender, 'outqueue', sharedQueue ]
+        ], (err) ->
+          chai.expect(err).to.not.exist
 
           broker.addBinding {type:'pubsub', src:sharedQueue, tgt:sharedQueue}, (err) ->
             chai.expect(err).to.be.a 'null'

        chai.expect(msg).to.include.keys 'data'
        chai.expect(msg.data).to.eql payload
        done()
      createConnectClients ['sender', 'receiver'], (clients, err) ->
        clients.receiver.createQueue 'inqueue', sharedQueue, (err) ->
          chai.expect(err).to.be.a 'null'
          clients.sender.createQueue 'outqueue', sharedQueue, (err) ->
            chai.expect(err).to.be.a 'null'

          clients.receiver.subscribeToQueue sharedQueue, onReceive, (err) ->
            chai.expect(err).to.be.a 'null'


        inQueue = 'inqueue27'

        createQueues [ [ clients.receive, 'inqueue', inQueue] ], (err) ->
          chai.expect(err).to.not.exist
          clients.receive.subscribeToQueue inQueue, onReceive, (err) ->
            chai.expect(err).to.not.exist
