File tree Expand file tree Collapse file tree 1 file changed +24
-0
lines changed Expand file tree Collapse file tree 1 file changed +24
-0
lines changed Original file line number Diff line number Diff line change @@ -119,6 +119,30 @@ transportTests = (type) ->
119
119
clientA .connect (err) ->
120
120
done err
121
121
122
+ describe ' sending participant registration message' , ->
123
+ client = null
124
+ beforeEach (done ) ->
125
+ client = transport .getClient address
126
+ return client .connect done
127
+ afterEach (done ) ->
128
+ return client .disconnect done
129
+
130
+ it ' should be received by subscribed broker' , (done ) ->
131
+ definition =
132
+ id : ' 123'
133
+ role : ' role'
134
+ component : ' lib/Component'
135
+ inports : []
136
+ outports : []
137
+ onDiscover = (message ) ->
138
+ got = message .data .payload
139
+ chai .expect (got).to .eql definition
140
+ return done ()
141
+ broker .subscribeParticipantChange onDiscover, (err ) ->
142
+ return done err if err
143
+ client .registerParticipant definition, (err ) ->
144
+ return done err if err
145
+
122
146
describe ' outqueue without subscribers' , ->
123
147
it ' sending should not error' , (done ) ->
124
148
payload = { foo : ' bar91' }
You can’t perform that action at this time.
0 commit comments