| Package | Description |
|---|---|
| co.cask.cdap.messaging | |
| co.cask.cdap.messaging.client | |
| co.cask.cdap.messaging.distributed | |
| co.cask.cdap.messaging.service |
| Modifier and Type | Method and Description |
|---|---|
RollbackDetail |
MessagingService.publish(StoreRequest request)
Publishes a list of messages to the messaging system.
|
void |
MessagingService.storePayload(StoreRequest request)
Stores a list of messages to the messaging system.
|
| Modifier and Type | Method and Description |
|---|---|
StoreRequest |
StoreRequestBuilder.build()
Creates a
StoreRequest based on the settings in this builder. |
| Modifier and Type | Method and Description |
|---|---|
RollbackDetail |
ClientMessagingService.publish(StoreRequest request) |
void |
ClientMessagingService.storePayload(StoreRequest request) |
| Modifier and Type | Method and Description |
|---|---|
RollbackDetail |
LeaderElectionMessagingService.publish(StoreRequest request) |
void |
LeaderElectionMessagingService.storePayload(StoreRequest request) |
| Modifier and Type | Method and Description |
|---|---|
RollbackDetail |
CoreMessagingService.publish(StoreRequest request) |
void |
CoreMessagingService.storePayload(StoreRequest request) |
Copyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.