public interface Consumer extends ServiceLifecycle, Client
PushConsumer
receives messages from multiple queues, these messages are pushed from MOM server to Consumer
client.Modifier and Type | Method and Description |
---|---|
void |
ack(MessageReceipt receipt)
Acknowledges the specified and consumed message with the unique message receipt handle, in the scenario of using
manual commit.
|
void |
addInterceptor(ConsumerInterceptor interceptor)
Adds a
ConsumerInterceptor instance to this consumer. |
Set<String> |
getBindQueues()
This method is used to find out the collection of queues bind to
Consumer . |
void |
removeInterceptor(ConsumerInterceptor interceptor)
Removes an interceptor from this consumer.
|
currentState, start, stop
getQueueMetaData
getExtension
Set<String> getBindQueues()
Consumer
.void addInterceptor(ConsumerInterceptor interceptor)
ConsumerInterceptor
instance to this consumer.interceptor
- an interceptor instance.void removeInterceptor(ConsumerInterceptor interceptor)
interceptor
- an interceptor to be removed.void ack(MessageReceipt receipt)
Messages that have been received but not acknowledged may be redelivered.
receipt
- the receipt handle associated with the consumed message.Copyright © 2017–2020 OpenMessaging. All rights reserved.