com.alipay.sofa.registry.server.session.push

类 PushProcessor

java.lang.Object

com.alipay.sofa.registry.server.session.push.PushProcessor

public class PushProcessor
extends Object

嵌套类概要

嵌套类

限定符和类型	类和说明
protected static class	PushProcessor.RetryReason

字段概要

字段

限定符和类型	字段和说明
protected CircuitBreakerService	circuitBreakerService
protected ClientNodeService	clientNodeService
protected PushDataGenerator	pushDataGenerator
protected PushSwitchService	pushSwitchService
protected SessionServerConfig	sessionServerConfig

构造器概要

构造器

构造器和说明
PushProcessor()

方法概要

限定符和类型	方法和说明
protected List<PushTask>	createPushTask(PushCause pushCause, InetSocketAddress addr, Map<String,Subscriber> subscriberMap, MultiSubDatum datum)
void	init()
protected boolean	interruptOnPushEmpty(MultiSubDatum datum, PushData pushData, PushCause pushCause, Subscriber sub, InetSocketAddress addr)
protected boolean	needRetry(PushTask task, PushProcessor.RetryReason reason)
void	setPushTaskDelayTime(PushEfficiencyImproveConfig pushEfficiencyImproveConfig)

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

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

字段详细资料

sessionServerConfig

@Autowired
protected SessionServerConfig sessionServerConfig

pushSwitchService

@Autowired
protected PushSwitchService pushSwitchService

pushDataGenerator

@Autowired
protected PushDataGenerator pushDataGenerator

clientNodeService

@Autowired
protected ClientNodeService clientNodeService

circuitBreakerService

@Autowired
protected CircuitBreakerService circuitBreakerService

构造器详细资料

PushProcessor

public PushProcessor()

方法详细资料

init

@PostConstruct
public void init()

setPushTaskDelayTime

public void setPushTaskDelayTime(PushEfficiencyImproveConfig pushEfficiencyImproveConfig)

createPushTask

protected List<PushTask> createPushTask(PushCause pushCause,
                                        InetSocketAddress addr,
                                        Map<String,Subscriber> subscriberMap,
                                        MultiSubDatum datum)

needRetry

protected boolean needRetry(PushTask task,
                            PushProcessor.RetryReason reason)

interruptOnPushEmpty

protected boolean interruptOnPushEmpty(MultiSubDatum datum,
                                       PushData pushData,
                                       PushCause pushCause,
                                       Subscriber sub,
                                       InetSocketAddress addr)