| Package | Description |
|---|---|
| org.springframework.cloud.stream.binder.rocketmq | |
| org.springframework.cloud.stream.binder.rocketmq.consuming |
| Modifier and Type | Method and Description |
|---|---|
Acknowledgement |
RocketMQMessageHeaderAccessor.getAcknowledgement(org.springframework.messaging.Message message) |
| Modifier and Type | Method and Description |
|---|---|
RocketMQMessageHeaderAccessor |
RocketMQMessageHeaderAccessor.withAcknowledgment(Acknowledgement acknowledgment) |
| Modifier and Type | Method and Description |
|---|---|
static Acknowledgement |
Acknowledgement.buildConcurrentlyInstance() |
static Acknowledgement |
Acknowledgement.buildOrderlyInstance() |
Acknowledgement |
Acknowledgement.setConsumeConcurrentlyStatus(org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus consumeConcurrentlyStatus) |
Acknowledgement |
Acknowledgement.setConsumeOrderlyStatus(org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus consumeOrderlyStatus) |
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.