Skip to content

Commit 58f9fa7

Browse files
committed
AMQP: Fix exception in registerParticipant()
Regression introduced in d9e70c9
1 parent 6b54a9e commit 58f9fa7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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.sendTo 'inqueue', 'fbp', data
149+
@channel.sendToQueue 'fbp', data
150150
return callback null
151151

152152
class MessageBroker extends Client

0 commit comments

Comments
 (0)