dispatcher.js

self.dispatchInternal = function (queue, message) {
        return self.connection.getQueue(queue)
            .then(function (queue) {
                return self.connection.sendMessageAsync({
                    MessageBody: JSON.stringify(message),
                    QueueUrl: queue.QueueUrl
                });
            })
            .then(function (message) {
                self.logger.debug(util.format("dispatched new event: %s, message Id: %s", queue, message.MessageId));
            })
            .catch(function (e) {
                self.logger.error("Dispatch failure: %s", e.toString());
            });
    };

    self.dispatch = function (queue, message) {
        return Promise.each(_.isString(queue) ? [queue] : queue, function (queueItem) {
            return self.dispatchInternal(queueItem, message);
        });

    };