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) |
ReceivedDataMultiPushTask(SessionServerConfig sessionServerConfig,
ClientNodeService clientNodeService,
ExecutorManager executorManager,
Exchange boltExchange,
ReceivedDataMultiPushTaskStrategy receivedDataMultiPushTaskStrategy,
AsyncHashedWheelTimer asyncHashedWheelTimer,
Interests sessionInterests) |