noc.core.nsq.pub

Module Contents

noc.core.nsq.pub.nsqd_http_service_param
noc.core.nsq.pub.logger
noc.core.nsq.pub.nsq_pub(topic, message)
Publish message to NSQ topic
Parameters:
  • topic – NSQ topic name
  • message – Raw message (Converted to JSON if is not a string)
Returns:

noc.core.nsq.pub.mpub(topic, messages, dcs=None, io_loop=None, retries=None)
Asynchronously publish message to NSQ topic
Parameters:
  • topic – NSQ topic
  • messages – List of strings containing messages
  • dcs – DSC instance
  • io_loop – IOLoop instance
  • retries – Error retries. config.nsqd.pub_retries by default
Returns:

None

Raises:

NSQPubError – On publish error