Methods
-
<static> poll(topic [, options], callback)
-
poll
Parameters:
Name Type Argument Description topicstring channel topic optionsobject <optional>
optinal options Properties
Name Type Argument Default Description repollTimeint <optional>
2000 millaseconds for when to poll for messages after none have been recieved VisibilityTimeoutint <optional>
60 - WaitTimeSecondsint <optional>
60 - MaxNumberOfMessagesint <optional>
1 capped at 10 callbackpollCallback callback on message being recieved Returns:
call this function to stop polling- Type
- function
-
<static> publish(topic, body)
-
publish
Parameters:
Name Type Description topicstring channel topic bodyObject message body -
<static> subscribe(topic [, queue], callback)
-
subscribe
Parameters:
Name Type Argument Description topicstring channel topic queuestring <optional>
options queue name. If none is passes in it will use the topic name callbacksubscribeCallback