Modifier and Type | Method and Description |
---|---|
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 List<MessageConsumer> |
AbstractMessageProcessor.messageConsumers |
Modifier and Type | Method and Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
MessageConsumer |
RabbitMQStore.getConsumer() |
Copyright © 2005–2020 Apache Software Foundation. All rights reserved.