nsq/writer.py
def dpub(self, topic, delay_ms, msg, callback=None):
        """
        publish multiple messages in one command (efficiently)

        :param topic: nsq topic
        :param delay_ms: tell nsqd to delay delivery for this long (integer milliseconds)
        :param msg: message body (bytes)
        :param callback: function which takes (conn, data) (data may be nsq.Error)
        """
        self._pub('dpub', topic, msg, delay_ms, callback=callback)
def dpub(self, topic, delay_ms, msg, callback=None):
        """
        publish multiple messages in one command (efficiently)

        :param topic: nsq topic
        :param delay_ms: tell nsqd to delay delivery for this long (integer milliseconds)
        :param msg: message body (bytes)
        :param callback: function which takes (conn, data) (data may be nsq.Error)
        """
        self._pub('dpub', topic, msg, delay_ms, callback=callback)
publish multiple messages in one command (efficiently)

        :param topic: nsq topic
        :param delay_ms: tell nsqd to delay delivery for this long (integer milliseconds)
        :param msg: message body (bytes)
        :param callback: function which takes (conn, data) (data may be nsq.Error)