public class RabbitMQProducer extends Object implements MessageProducer
Constructor and Description |
---|
RabbitMQProducer(RabbitMQStore store) |
Modifier and Type | Method and Description |
---|---|
boolean |
cleanup()
Used to close the channel opened in this object instance.
|
String |
getId()
Returns the ID of this message consumer.
|
boolean |
isInitialized() |
void |
setConnection(com.rabbitmq.client.Connection connection) |
void |
setExchangeName(String exchangeName) |
void |
setId(int id)
Sets the ID of this message consumer.
|
void |
setQueueName(String queueName) |
boolean |
storeMessage(MessageContext synCtx)
Stores the given message to the store associated with this message consumer.
|
public RabbitMQProducer(RabbitMQStore store)
public void setQueueName(String queueName)
public void setExchangeName(String exchangeName)
public void setConnection(com.rabbitmq.client.Connection connection)
public void setId(int id)
MessageProducer
setId
in interface MessageProducer
id
- IDpublic boolean storeMessage(MessageContext synCtx)
MessageProducer
storeMessage
in interface MessageProducer
synCtx
- Message to be saved.true
if storing of the message is successful, false
otherwise.public boolean cleanup()
cleanup
in interface MessageProducer
true
if clean up is successful, false
otherwise.public boolean isInitialized()
public String getId()
MessageProducer
getId
in interface MessageProducer
Copyright © 2005–2024 Apache Software Foundation. All rights reserved.