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
}