程序包 com.iohao.game.external.core.broker.client.processor

类 BroadcastOrderMessageExternalProcessor

java.lang.Object
com.alipay.remoting.AbstractLifeCycle
com.alipay.remoting.rpc.protocol.AbstractUserProcessor<BroadcastOrderMessage>
com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BroadcastOrderMessage>
com.iohao.game.external.core.broker.client.processor.BroadcastOrderMessageExternalProcessor
所有已实现的接口:
com.alipay.remoting.LifeCycle, com.alipay.remoting.rpc.protocol.UserProcessor<BroadcastOrderMessage>, UserSessionsAware
public final class BroadcastOrderMessageExternalProcessor extends com.alipay.remoting.rpc.protocol.AsyncUserProcessor<BroadcastOrderMessage> implements UserSessionsAware
接收并处理 来自网关的广播消息 - 顺序的
作者:
渔民小镇
日期:
2023-02-21

  • 嵌套类概要

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

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

  • 字段概要

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

    executorSelector

  • 构造器概要

    构造器
    构造器
    说明
    BroadcastOrderMessageExternalProcessor()
     

  • 方法概要

    修饰符和类型
    方法
    说明
    Executor
    getExecutor()
     
    void
    handleRequest(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, BroadcastOrderMessage message)
     
    String
    interest()
     
    void
    setUserSessions(UserSessions<?,?> userSessions)
    框架会调用此方法，将 UserSessions 对象传入

    从类继承的方法 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.alipay.remoting.LifeCycle

    isStarted, shutdown, startup

  • 构造器详细资料

    • BroadcastOrderMessageExternalProcessor

      public BroadcastOrderMessageExternalProcessor()

  • 方法详细资料

    • setUserSessions

      public void setUserSessions(UserSessions<?,?> userSessions)
      从接口复制的说明: UserSessionsAware
      框架会调用此方法，将 UserSessions 对象传入
      指定者:
      setUserSessions 在接口中 UserSessionsAware
      参数:
      userSessions - userSessions

    • handleRequest

      public void handleRequest(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, BroadcastOrderMessage message)
      指定者:
      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>