kami-parse-server/src/ParseMessageQueue.js

import { loadAdapter } from './Adapters/AdapterLoader';
import { EventEmitterMQ } from './Adapters/MessageQueue/EventEmitterMQ';

const ParseMessageQueue = {};

ParseMessageQueue.createPublisher = function (config: any): any {
  const adapter = loadAdapter(config.messageQueueAdapter, EventEmitterMQ, config);
  if (typeof adapter.createPublisher !== 'function') {
    throw 'pubSubAdapter should have createPublisher()';
  }
  return adapter.createPublisher(config);
};

ParseMessageQueue.createSubscriber = function (config: any): void {
  const adapter = loadAdapter(config.messageQueueAdapter, EventEmitterMQ, config);
  if (typeof adapter.createSubscriber !== 'function') {
    throw 'messageQueueAdapter should have createSubscriber()';
  }
  return adapter.createSubscriber(config);
};

export { ParseMessageQueue };