| Package | Description |
|---|---|
| co.cask.cdap.messaging | |
| co.cask.cdap.messaging.client | |
| co.cask.cdap.messaging.distributed | |
| co.cask.cdap.messaging.service | |
| co.cask.cdap.messaging.store |
| Modifier and Type | Method and Description |
|---|---|
RollbackDetail |
MessagingService.publish(StoreRequest request)
Publishes a list of messages to the messaging system.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MessagingService.rollback(co.cask.cdap.proto.id.TopicId topicId,
RollbackDetail rollbackDetail)
Rollbacks messages published to the given topic with the given transaction.
|
| Modifier and Type | Method and Description |
|---|---|
RollbackDetail |
ClientMessagingService.publish(StoreRequest request) |
| Modifier and Type | Method and Description |
|---|---|
void |
ClientMessagingService.rollback(co.cask.cdap.proto.id.TopicId topicId,
RollbackDetail rollbackDetail) |
| Modifier and Type | Method and Description |
|---|---|
RollbackDetail |
LeaderElectionMessagingService.publish(StoreRequest request) |
| Modifier and Type | Method and Description |
|---|---|
void |
LeaderElectionMessagingService.rollback(co.cask.cdap.proto.id.TopicId topicId,
RollbackDetail rollbackDetail) |
| Modifier and Type | Method and Description |
|---|---|
RollbackDetail |
CoreMessagingService.publish(StoreRequest request) |
| Modifier and Type | Method and Description |
|---|---|
void |
CoreMessagingService.rollback(co.cask.cdap.proto.id.TopicId topicId,
RollbackDetail rollbackDetail) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractMessageTable.rollback(TopicMetadata metadata,
RollbackDetail rollbackDetail) |
void |
MessageTable.rollback(TopicMetadata metadata,
RollbackDetail rollbackDetail)
Rollback entries stored earlier, as deleted, under the given topic based on the given information.
|
Copyright © 2017 Cask Data, Inc. Licensed under the Apache License, Version 2.0.