Skip to content

Commit d9e70c9

Browse files
committed
transports: Remove used of deprecated sendToQueue()
1 parent 54876ae commit d9e70c9

2 files changed

Lines changed: 2 additions & 2 deletions

File tree

src/amqp.coffee

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ class Client extends interfaces.MessagingClient
146146
payload: part
147147
@channel.assertQueue 'fbp'
148148
data = new Buffer JSON.stringify msg
149-
@channel.sendToQueue 'fbp', data
149+
@channel.sendTo 'inqueue', 'fbp', data
150150
return callback null
151151

152152
class MessageBroker extends Client

src/mqtt.coffee

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ class Client extends interfaces.MessagingClient
106106
protocol: 'discovery'
107107
command: 'participant'
108108
payload: part
109-
@sendToQueue 'fbp', msg, callback
109+
@sendTo 'inqueue', 'fbp', msg, callback
110110

111111
class MessageBroker extends Client
112112
constructor: (address, options) ->

0 commit comments

Comments
 (0)