/**
 * @author songxiwen
 * @date 2020/12/03 15:01
 */

import { MessageQueueClient } from './message.queue.client';

export enum MessageQueueSubject {
  Upload = 'FileService:upload'
}

export class MessageQueueHandler {
  private static client = MessageQueueClient.getInstance();

  static publish(subject: string, message: string) {
    MessageQueueHandler.client.publish(subject, message);
  }
}