程序包 com.iohao.game.bolt.broker.server.processor

类 BroadcastOrderMessageBrokerProcessor

java.lang.Object
com.alipay.remoting.AbstractLifeCycle
com.alipay.remoting.rpc.protocol.AbstractUserProcessor<BroadcastOrderMessage>
com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BroadcastOrderMessage>
com.iohao.game.bolt.broker.server.processor.BroadcastOrderMessageBrokerProcessor
所有已实现的接口:
com.alipay.remoting.LifeCycle, com.alipay.remoting.rpc.protocol.UserProcessor<BroadcastOrderMessage>, BrokerServerAware
public final class BroadcastOrderMessageBrokerProcessor extends com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BroadcastOrderMessage> implements BrokerServerAware
把逻辑服的广播 顺序的 转发到对外服 
     只使用了一个线程
作者:
渔民小镇
日期:
2022-07-14

  • 嵌套类概要

    从接口继承的嵌套类/接口 com.alipay.remoting.rpc.protocol.UserProcessor

    com.alipay.remoting.rpc.protocol.UserProcessor.ExecutorSelector

  • 字段概要

    从类继承的字段 com.alipay.remoting.rpc.protocol.AbstractUserProcessor

    executorSelector

  • 构造器概要

    构造器
    构造器
    说明
    BroadcastOrderMessageBrokerProcessor()
     

  • 方法概要

    修饰符和类型
    方法
    说明
    Executor
    getExecutor()
     
    void
    handleRequest(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, BroadcastOrderMessage broadcastOrderMessage)
     
    String
    interest()
     

    从类继承的方法 com.alipay.remoting.rpc.protocol.AsyncUserProcessor

    handleRequest

    从类继承的方法 com.alipay.remoting.rpc.protocol.AbstractUserProcessor

    getBizClassLoader, getExecutorSelector, preHandleRequest, processInIOThread, setExecutorSelector, timeoutDiscard

    从类继承的方法 com.alipay.remoting.AbstractLifeCycle

    ensureStarted, isStarted, shutdown, startup

    从类继承的方法 java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    从接口继承的方法 com.iohao.game.bolt.broker.server.aware.BrokerServerAware

    setBrokerServer

    从接口继承的方法 com.alipay.remoting.LifeCycle

    isStarted, shutdown, startup

  • 构造器详细资料

    • BroadcastOrderMessageBrokerProcessor

      public BroadcastOrderMessageBrokerProcessor()

  • 方法详细资料

    • handleRequest

      public void handleRequest(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, BroadcastOrderMessage broadcastOrderMessage)
      指定者:
      handleRequest 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<BroadcastOrderMessage>
      指定者:
      handleRequest 在类中 com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BroadcastOrderMessage>

    • getExecutor

      public Executor getExecutor()
      指定者:
      getExecutor 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<BroadcastOrderMessage>
      覆盖:
      getExecutor 在类中 com.alipay.remoting.rpc.protocol.AbstractUserProcessor<BroadcastOrderMessage>

    • interest

      public String interest()
      指定者:
      interest 在接口中 com.alipay.remoting.rpc.protocol.UserProcessor<BroadcastOrderMessage>
      指定者:
      interest 在类中 com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BroadcastOrderMessage>