Modifier and Type | Method and Description |
---|---|
java.util.List<MessageConsumer> |
MessageProcessor.getMessageConsumer()
This method retrieves the message consumer of message processor.
|
Modifier and Type | Method and Description |
---|---|
MessageContext |
Service.fetch(MessageConsumer msgConsumer)
This method has the responsibility of fetching message from the message store.
|
boolean |
MessageProcessor.setMessageConsumer(MessageConsumer messageConsumer)
This method is used to set the message consumer of message processor.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.List<MessageConsumer> |
AbstractMessageProcessor.messageConsumers |
Modifier and Type | Method and Description |
---|---|
java.util.List<MessageConsumer> |
AbstractMessageProcessor.getMessageConsumer() |
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractMessageProcessor.setMessageConsumer(MessageConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
MessageContext |
FailoverForwardingService.fetch(MessageConsumer msgConsumer)
Receives the next message from the message store.
|
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
MessageStore.getConsumer()
Returns a Message Consumer for this message store.
|
Modifier and Type | Class and Description |
---|---|
class |
JDBCConsumer
JDBC Store Consumer
|
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
JDBCMessageStore.getConsumer() |
Modifier and Type | Class and Description |
---|---|
class |
JmsConsumer |
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
JmsStore.getConsumer() |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryConsumer |
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
InMemoryStore.getConsumer() |
Modifier and Type | Class and Description |
---|---|
class |
RabbitMQConsumer
The message consumer responsible for read a message from the queue and set it into the message context
|
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
RabbitMQStore.getConsumer()
Create a new
RabbitMQConsumer object |
Copyright © 2005-2022 Apache Software Foundation. All Rights Reserved.