Skip to content

Commit 445497a

Browse files
committed
participant: Remove deprecated connectGraphEdges/File
Should use msgflo.setup instead
1 parent b940582 commit 445497a

1 file changed

Lines changed: 0 additions & 33 deletions

File tree

src/participant.coffee

Lines changed: 0 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -140,39 +140,6 @@ class Participant extends EventEmitter
140140
debug 'registered', err
141141
return callback err
142142

143-
# Sets up queues to match those defined in graph
144-
connectGraphEdges: (graph) ->
145-
console.log 'WARN: msgflo.Participant::connectGraphEdges() is deprecated. Use msgflo.setup.setupBindings() instead'
146-
processName = @definition.role
147-
148-
# If there are outbound connections
149-
# Set the output queue to equal to the input queue of the target
150-
for conn in graph.connections
151-
if conn.src?.process == processName
152-
# WARN: assumes the queue naming convention,
153-
# as we don't have access to the definition of target participant
154-
# altenative would be to instantiate whole network,
155-
# and in worker case only run one participant?
156-
# using exchanges for the outports and binding to inports might also solve it
157-
tgtQueue = "#{conn.tgt.process}.#{conn.tgt.port.toUpperCase()}"
158-
ports = @definition.outports.filter (p) -> return p.id == conn.src.port
159-
ports[0].queue = tgtQueue
160-
161-
connectGraphEdgesFile: (filepath, callback) ->
162-
console.log 'WARN: msgflo.Participant::connectGraphEdgesFile() is deprecated. Use msgflo.setup.setupBindings() instead'
163-
ext = path.extname filepath
164-
fs.readFile filepath, { encoding: 'utf-8' }, (err, contents) =>
165-
return callback err if err
166-
try
167-
if ext == '.fbp'
168-
graph = fbp.parse contents
169-
else
170-
graph = JSON.parse contents
171-
@connectGraphEdges graph
172-
catch e
173-
return callback e
174-
return callback null
175-
176143
# TODO: consider making component api a bit more like NoFlo.WirePattern
177144
#
178145
# inputs = { portA: { data: dataA1, groups: ['A', '1'] }, portB: { data: B1 } }

0 commit comments

Comments
 (0)