Skip to content

Commit 6618f43

Browse files
committed
tests: Prepare support for MQTT, uncomment to enable
1 parent 9b19923 commit 6618f43

1 file changed

Lines changed: 14 additions & 5 deletions

File tree

spec/participant.coffee

Lines changed: 14 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6,11 +6,12 @@ heterogenous = require '../node_modules/msgflo/spec/heterogenous.coffee'
66
participants =
77
'C++Repeat': [path.join __dirname, '..', 'build', './repeat-cpp']
88

9-
describe 'Participants', ->
10-
address = 'amqp://localhost'
11-
g =
12-
broker: null
13-
commands: participants
9+
# Note: most require running an external broker service
10+
transports =
11+
#'MQTT': 'mqtt://localhost'
12+
'AMQP': 'amqp://localhost'
13+
14+
transportTests = (g, address) ->
1415

1516
beforeEach (done) ->
1617
g.broker = msgflo.transport.getBroker address
@@ -23,4 +24,12 @@ describe 'Participants', ->
2324
heterogenous.testParticipant g, name
2425

2526

27+
describe 'Participants', ->
28+
g =
29+
broker: null
30+
commands: participants
2631

32+
Object.keys(transports).forEach (type) =>
33+
describe "#{type}", () ->
34+
address = transports[type]
35+
transportTests g, address

0 commit comments

Comments
 (0)