Method group

packages/message/message_queue.ts:20–20

(name: string, middleware?: MiddlewareFunction)

export interface IMessageQueue {
  // 创建子分组
  group(name: string, middleware?: MiddlewareFunction): IMessageQueueExtended;

  // 订阅消息
  subscribe<T>(topic: string, handler: MessageHandler<T>): () => void;