Method emit

packages/message/message_queue.ts:86–88

(topic: string, message: NonNullable<T>)

  // 只发布给当前环境
  emit<T>(topic: string, message: NonNullable<T>) {
    this.EE.emit(topic, message);
  }

  // 创建分组
  group(name: string, middleware?: MiddlewareFunction) {