Asymmetrik/mean2-starter

'use strict';

let path = require('path'),
    deps = require(path.resolve('./src/server/dependencies.js')),
    kafkaProducer = deps.kafkaProducer;

exports.publish = function(destination, message, retry, key) {
    if (key) {
        return kafkaProducer.sendMessageForTopicWithKey(destination, JSON.stringify(message), key, false);
    }

    return kafkaProducer.sendMessageForTopic(destination, JSON.stringify(message), retry);
};