CancelDataTask(Interests sessionInterests,
DataStore sessionDataStore,
Watchers sessionWatchers,
DataNodeService dataNodeService,
SessionServerConfig sessionServerConfig) |
DataChangeFetchCloudTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
Interests sessionInterests,
ExecutorManager executorManager,
CacheService sessionCacheService) |
DataChangeFetchTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
ExecutorManager executorManager,
Interests sessionInterests,
CacheService sessionCacheService) |
DataPushTask(Interests sessionInterests,
SessionServerConfig sessionServerConfig,
ExecutorManager executorManager,
TaskListenerManager taskListenerManager) |
ProvideDataChangeFetchTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
MetaNodeService metaNodeService,
Watchers sessionWatchers,
Exchange boltExchange,
Interests sessionInterests,
Registry sessionRegistry,
BlacklistManager blacklistManager) |
PushTaskClosure(AsyncHashedWheelTimer pushTaskCheckAsyncHashedWheelTimer,
SessionServerConfig sessionServerConfig,
String dataInfoId) |
ReceivedConfigDataPushTask(SessionServerConfig sessionServerConfig,
ClientNodeService clientNodeService,
ReceivedConfigDataPushTaskStrategy receivedConfigDataPushTaskStrategy) |
ReceivedDataMultiPushTask(SessionServerConfig sessionServerConfig,
ClientNodeService clientNodeService,
ExecutorManager executorManager,
Exchange boltExchange,
ReceivedDataMultiPushTaskStrategy receivedDataMultiPushTaskStrategy,
AsyncHashedWheelTimer asyncHashedWheelTimer,
Interests sessionInterests) |
RenewDatumTask(SessionServerConfig sessionServerConfig,
DataNodeService dataNodeService,
SessionRegistry sessionRegistry) |
SessionRegisterDataTask(Exchange boltExchange,
DataNodeService dataNodeService,
SessionServerConfig sessionServerConfig) |
SubscriberMultiFetchTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
CacheService sessionCacheService,
SubscriberMultiFetchTaskStrategy subscriberMultiFetchTaskStrategy) |
SubscriberPushEmptyTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager) |
SubscriberRegisterFetchTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
DataNodeService dataNodeService,
CacheService sessionCacheService,
SubscriberRegisterFetchTaskStrategy subscriberRegisterFetchTaskStrategy) |
WatcherRegisterFetchTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
MetaNodeService metaNodeService) |