com.alipay.sofa.registry.server.session.listener

类 ReceivedDataMultiPushTaskListener

java.lang.Object

com.alipay.sofa.registry.server.session.listener.ReceivedDataMultiPushTaskListener

所有已实现的接口:

PushTaskSender, TaskListener

public class ReceivedDataMultiPushTaskListener
extends Object
implements TaskListener, PushTaskSender

版本:

$Id: SubscriberRegisterPushTaskListener.java, v 0.1 2017-12-11 20:44 shangyu.wh Exp $

作者:

shangyu.wh

嵌套类概要

从接口继承的嵌套类/接口 com.alipay.sofa.registry.server.session.listener.PushTaskSender

PushTaskSender.PushDataType

构造器概要

构造器

构造器和说明
ReceivedDataMultiPushTaskListener(TaskProcessor clientNodeSingleTaskProcessor, TaskMergeProcessorStrategy receiveDataTaskMergeProcessorStrategy, SessionServerConfig sessionServerConfig)

方法概要

限定符和类型	方法和说明
void	executePushAsync(TaskEvent event)
PushTaskSender.PushDataType	getPushDataType()
TaskMergeProcessorStrategy	getTaskMergeProcessorStrategy() Getter method for property taskMergeProcessorStrategy.
void	handleEvent(TaskEvent event)
boolean	support(TaskEvent event)

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

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

构造器详细资料

ReceivedDataMultiPushTaskListener

public ReceivedDataMultiPushTaskListener(TaskProcessor clientNodeSingleTaskProcessor,
                                         TaskMergeProcessorStrategy receiveDataTaskMergeProcessorStrategy,
                                         SessionServerConfig sessionServerConfig)

方法详细资料

support

public boolean support(TaskEvent event)

指定者:

support 在接口中 TaskListener

handleEvent

public void handleEvent(TaskEvent event)

指定者:

handleEvent 在接口中 TaskListener

executePushAsync

public void executePushAsync(TaskEvent event)

指定者:

executePushAsync 在接口中 PushTaskSender

getPushDataType

public PushTaskSender.PushDataType getPushDataType()

指定者:

getPushDataType 在接口中 PushTaskSender

getTaskMergeProcessorStrategy

public TaskMergeProcessorStrategy getTaskMergeProcessorStrategy()

Getter method for property taskMergeProcessorStrategy.

返回:

property value of taskMergeProcessorStrategy