| 限定符和类型 | 方法和说明 |
|---|---|
DataNodeService |
SessionServerConfiguration.SessionNodeConfiguration.dataNodeService() |
| 限定符和类型 | 类和说明 |
|---|---|
class |
DataNodeServiceImpl |
| 构造器和说明 |
|---|
CancelDataTask(Interests sessionInterests,
DataStore sessionDataStore,
Watchers sessionWatchers,
DataNodeService dataNodeService,
SessionServerConfig sessionServerConfig) |
DatumSnapshotTask(DataNodeService dataNodeService) |
PublishDataTask(DataNodeService dataNodeService) |
RenewDatumTask(SessionServerConfig sessionServerConfig,
DataNodeService dataNodeService,
SessionRegistry sessionRegistry) |
SessionRegisterDataTask(Exchange boltExchange,
DataNodeService dataNodeService,
SessionServerConfig sessionServerConfig) |
SubscriberRegisterFetchTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
DataNodeService dataNodeService,
CacheService sessionCacheService,
SubscriberRegisterFetchTaskStrategy subscriberRegisterFetchTaskStrategy) |
UnPublishDataTask(DataNodeService dataNodeService) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
SubscriberRegisterFetchTaskStrategy.doSubscriberRegisterFetchTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
DataNodeService dataNodeService,
CacheService sessionCacheService,
Subscriber subscriber) |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
DefaultSubscriberRegisterFetchTaskStrategy.doSubscriberRegisterFetchTask(SessionServerConfig sessionServerConfig,
TaskListenerManager taskListenerManager,
DataNodeService dataNodeService,
CacheService sessionCacheService,
Subscriber subscriber) |
Copyright © 2019 The Ant Financial. All rights reserved.