Methods
-
<static> poll(topic [, options], callback)
-
poll
Parameters:
Name Type Argument Description topic
string channel topic options
object <optional>
optinal options Properties
Name Type Argument Default Description repollTime
int <optional>
2000 millaseconds for when to poll for messages after none have been recieved VisibilityTimeout
int <optional>
60 - WaitTimeSeconds
int <optional>
60 - MaxNumberOfMessages
int <optional>
1 capped at 10 callback
pollCallback callback on message being recieved Returns:
call this function to stop polling- Type
- function
-
<static> publish(topic, body)
-
publish
Parameters:
Name Type Description topic
string channel topic body
Object message body -
<static> subscribe(topic [, queue], callback)
-
subscribe
Parameters:
Name Type Argument Description topic
string channel topic queue
string <optional>
options queue name. If none is passes in it will use the topic name callback
subscribeCallback