File tree Expand file tree Collapse file tree 2 files changed +2
-8
lines changed
Expand file tree Collapse file tree 2 files changed +2
-8
lines changed Original file line number Diff line number Diff line change @@ -37,7 +37,7 @@ class MessagingSystem
3737class MessagingClient extends MessagingSystem
3838
3939 # Participant registration
40- registerParticipant : (part ) ->
40+ registerParticipant : (part , callback ) ->
4141 throw new Error ' Not Implemented'
4242
4343exports .MessagingClient = MessagingClient
Original file line number Diff line number Diff line change 11
22common = require ' ./common'
33transport = require ' ./transport'
4+ newrelic = require ' ./newrelic'
45
5- path = require ' path'
6- fs = require ' fs'
76debug = require (' debug' )(' msgflo:participant' )
8- chance = require ' chance'
97async = require ' async'
108EventEmitter = require (' events' ).EventEmitter
119uuid = require ' uuid'
12- fbp = require ' fbp'
13-
14- random = new chance.Chance 10202
1510
1611findPort = (def , type , portName ) ->
1712 ports = if type == ' inport' then def .inports else def .outports
@@ -60,7 +55,6 @@ class Participant extends EventEmitter
6055 role = ' unknown' if not role
6156 @definition = instantiateDefinition def, role
6257 @running = false
63- newrelic = require ' ./newrelic'
6458 @_transactions = new newrelic.Transactions @definition
6559 @options = options
6660 @options .discoveryPeriod = defaultDiscoveryPeriod if not @options .discoveryPeriod # seconds
You can’t perform that action at this time.
0 commit comments