类 PulseSignalRequestUserProcessor
java.lang.Object
com.alipay.remoting.AbstractLifeCycle
com.alipay.remoting.rpc.protocol.AbstractUserProcessor<PulseSignalRequest>
com.alipay.remoting.rpc.protocol.AsyncUserProcessor<PulseSignalRequest>
com.iohao.game.bolt.broker.core.common.AbstractAsyncUserProcessor<PulseSignalRequest>
com.iohao.game.bolt.broker.core.common.processor.pulse.PulseSignalRequestUserProcessor
- 所有已实现的接口:
com.alipay.remoting.LifeCycle
,com.alipay.remoting.rpc.protocol.UserProcessor<PulseSignalRequest>
,PulseConsumerAware
,UserProcessorExecutorAware
,UserProcessorInNettyThreadAware
public class PulseSignalRequestUserProcessor
extends AbstractAsyncUserProcessor<PulseSignalRequest>
implements PulseConsumerAware
脉冲信号请求接收
- 作者:
- 渔民小镇
- 日期:
- 2023-04-20
-
嵌套类概要
从接口继承的嵌套类/接口 com.alipay.remoting.rpc.protocol.UserProcessor
com.alipay.remoting.rpc.protocol.UserProcessor.ExecutorSelector
-
字段概要
从类继承的字段 com.alipay.remoting.rpc.protocol.AbstractUserProcessor
executorSelector
-
构造器概要
-
方法概要
修饰符和类型方法说明void
handleRequest
(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, PulseSignalRequest request) interest()
void
setPulseConsumers
(PulseConsumers pulseConsumers) set PulseConsumers从类继承的方法 com.iohao.game.bolt.broker.core.common.AbstractAsyncUserProcessor
getExecutor, getUserProcessorExecutor, inNettyThreadExecute, processInIOThread, setInNettyThread, setUserProcessorExecutor
从类继承的方法 com.alipay.remoting.rpc.protocol.AsyncUserProcessor
handleRequest
从类继承的方法 com.alipay.remoting.rpc.protocol.AbstractUserProcessor
getBizClassLoader, getExecutorSelector, preHandleRequest, 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
-
构造器详细资料
-
PulseSignalRequestUserProcessor
public PulseSignalRequestUserProcessor()
-
-
方法详细资料
-
setPulseConsumers
从接口复制的说明:PulseConsumerAware
set PulseConsumers- 指定者:
setPulseConsumers
在接口中PulseConsumerAware
- 参数:
pulseConsumers
- 脉冲消费器
-
handleRequest
public void handleRequest(com.alipay.remoting.BizContext bizCtx, com.alipay.remoting.AsyncContext asyncCtx, PulseSignalRequest request) - 指定者:
handleRequest
在接口中com.alipay.remoting.rpc.protocol.UserProcessor<PulseSignalRequest>
- 指定者:
handleRequest
在类中com.alipay.remoting.rpc.protocol.AsyncUserProcessor<PulseSignalRequest>
-
interest
- 指定者:
interest
在接口中com.alipay.remoting.rpc.protocol.UserProcessor<PulseSignalRequest>
- 指定者:
interest
在类中com.alipay.remoting.rpc.protocol.AsyncUserProcessor<PulseSignalRequest>
-