Skip to content

Commit 03706c2

Browse files
committed
Remove deprecated client.sendToQueue() [API]
1 parent eb5e0ff commit 03706c2

File tree

2 files changed

+2
-6
lines changed

2 files changed

+2
-6
lines changed

src/direct.coffee

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ class MessageBroker extends interfaces.MessageBroker
102102

103103
## Sending/Receiving messages
104104
sendTo: (type, queueName, message, callback) ->
105-
# console.log 'broker sendToQueue', queueName, Object.keys(@queues), @queues[queueName]
105+
debug 'broker sendTo', queueName
106106
@queues[queueName].send message
107107
return callback null
108108

src/interfaces.coffee

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,14 +20,10 @@ class MessagingSystem
2020
throw new Error 'Not Implemented'
2121

2222
## Sending/Receiving messages
23+
# queueName must be created beforehand, and be of correct type
2324
sendTo: (type, name, message, callback) ->
2425
throw new Error 'Not Implemented'
2526

26-
# queueName must be created beforehand, and be of correct type
27-
sendToQueue: (queueName, message, callback) ->
28-
console.log 'WARN: sendToQueue is deprecated. Use sendTo() instead'
29-
@sendTo 'outqueue', queueName, message, callback
30-
3127
# handler must call ackMessage() on succesful processing of a message
3228
subscribeToQueue: (queueName, handler, callback) ->
3329
throw new Error 'Not Implemented'

0 commit comments

Comments
 (0)