Skip to content

Commit ac62211

Browse files
committed
tests: Enable data subscription tests for AMQP
1 parent cf557e0 commit ac62211

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

spec/01transport.coffee

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,6 @@ transportTests = (type) ->
9999
broker = null
100100

101101
describeIfRoundRobinSupport = if type == 'AMQP' then describe else describe.skip
102-
describeIfSubscribeSupport = if type != 'AMQP' then describe else describe.skip
103102

104103
beforeEach (done) ->
105104
broker = transport.getBroker address
@@ -364,7 +363,7 @@ transportTests = (type) ->
364363
it 'only NACKed message is sent to deadletter', ->
365364
chai.expect(received.deadletter).to.eql [ { foo: 'nack'} ]
366365

367-
describeIfSubscribeSupport 'subscribing to bound topics', ->
366+
describe 'subscribing to bound topics', ->
368367
sendQueue = 'sub-send-36'
369368
receiveQueue = 'sub-receive-36'
370369
binding = { type:'pubsub', src:sendQueue, tgt:receiveQueue }
@@ -411,7 +410,7 @@ transportTests = (type) ->
411410
clients.sender.sendTo 'outqueue', sendQueue, payloads.two, (err) ->
412411
return done err if err
413412

414-
describeIfSubscribeSupport 'subscribing to binding with srcQueue==tgtQueue', ->
413+
describe 'subscribing to binding with srcQueue==tgtQueue', ->
415414
sendQueue = 'sub-shared-37'
416415
receiveQueue = sendQueue
417416
binding = { type:'pubsub', src:sendQueue, tgt:receiveQueue }

0 commit comments

Comments
 (0)