tests: Also check subscribing for srcQueue==tgtQueue case

Common in exising, pre-MsgFlo, MQTT networks (hardcoded receiver)

Author: jonnor

spec/01transport.coffee

@@ -411,6 +411,53 @@ transportTests = (type) ->
             clients.sender.sendTo 'outqueue', sendQueue, payloads.two, (err) ->
               return done err if err
 
+  describeIfSubscribeSupport 'subscribing to binding with srcQueue==tgtQueue', ->
+    sendQueue = 'sub-shared-37'
+    receiveQueue = sendQueue
+    binding = { type:'pubsub', src:sendQueue, tgt:receiveQueue }
+    connectionData = []
+    clients = null
+
+    # Should be a before, but the 'beforeEach' of higher scope are ran afterwards...
+    setup = (done) ->
+      createConnectClients address, ['sender', 'receiver'], (err, c) ->
+        clients = c
+        createQueues [
+          [ clients.receiver, 'inqueue', receiveQueue ]
+          [ clients.sender, 'outqueue', sendQueue ]
+        ], (err) ->
+          chai.expect(err).to.not.exist
+          broker.addBinding binding, (err) ->
+            chai.expect(err).to.be.a 'null'
+            return done null
+
+    it 'should provide data sent on connection', (done) ->
+      payloads =
+        one: { foo: 'sub-106' }
+        two: { bar: 'sub-107' }
+
+      onData = (bind, data) ->
+        chai.expect(bind.src).to.equal binding.src
+        chai.expect(bind.tgt).to.equal binding.tgt
+        connectionData.push data
+        # wait until we've gotten two packets
+        if connectionData.length == 2
+          [one, two] = connectionData
+          chai.expect(one).to.eql payloads.one
+          chai.expect(two).to.eql payloads.two
+          return done null
+        else if connectionData.length > 2
+          return done new Error "Got more data than expected"
+
+      setup (err) ->
+        return done err if err
+        broker.subscribeData binding, onData, (err) ->
+          return done err if err
+          clients.sender.sendTo 'outqueue', sendQueue, payloads.one, (err) ->
+            return done err if err
+            clients.sender.sendTo 'outqueue', sendQueue, payloads.two, (err) ->
+              return done err if err
+
 describe 'Transport', ->
   Object.keys(transports).forEach (type) =>
     describe "#{type}", () ->