Package interlok.rabbitmq

Class StandardMessageProducer

java.lang.Object

com.adaptris.core.AdaptrisMessageWorkerImp

com.adaptris.core.AdaptrisMessageProducerImp

com.adaptris.core.ProduceOnlyProducerImp

interlok.rabbitmq.StandardMessageProducer

All Implemented Interfaces:

AdaptrisComponent, AdaptrisMessageProducer, AdaptrisMessageSender, AdaptrisMessageWorker, ComponentLifecycle, ComponentLifecycleExtension, MessageEventGenerator

@ComponentProfile(summary="Publishes a message to RabbitMQ",
                  tag="amqp, rabbitmq",
                  recommended=RabbitMqConnection.class,
                  since="4.3.0")
public class StandardMessageProducer
extends ProduceOnlyProducerImp

Publishes a message to RabbitMQ.

RabbitMQ requires you to programatically declare both the exchange and queue before use. If you are not targetting the default exchange or have specific requirements about the queue declaration then please remember to configure a Declaration.ExchangeDeclaration and Declaration.QueueDeclaration respectively. By default we simply use the default exchange and the queue is declared to be durable, non-exclusive, with no auto-delete and no additional arguments.

Use a property-builder to configure how the BasicProperties object is created. Unless explicitly configured there will be no additional properties in the call to Channel#basicPublish.

Field Summary

Fields inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

log

Constructor Summary

Constructors

Constructor	Description
StandardMessageProducer()

Method Summary

Modifier and Type	Method	Description
protected void	doProduce(AdaptrisMessage msg, String endpoint)
String	endpoint(AdaptrisMessage msg)
Declaration.ExchangeDeclaration	getExchangeDeclaration()	How the Exchange will be declared prior to use.
Translator.BasicPropertiesBuilder	getPropertyBuilder()	How to build the required BasicProperties if required.
String	getQueue()	The queue to publish to.
Declaration.QueueDeclaration	getQueueDeclaration()	How the Queue will be declared prior to use.
void	prepare()
void	setExchangeDeclaration(Declaration.ExchangeDeclaration exchangeDeclaration)	How the Exchange will be declared prior to use.
void	setPropertyBuilder(Translator.BasicPropertiesBuilder propertyBuilder)	How to build the required BasicProperties if required.
void	setQueue(String queue)	The queue to publish to.
void	setQueueDeclaration(Declaration.QueueDeclaration queueDeclaration)	How the Queue will be declared prior to use.
void	start()
void	stop()
StandardMessageProducer	withPropertyBuilder(Translator.BasicPropertiesBuilder b)
StandardMessageProducer	withQueue(String s)

Methods inherited from class com.adaptris.core.ProduceOnlyProducerImp

produce, request, request

Methods inherited from class com.adaptris.core.AdaptrisMessageProducerImp

createName

Methods inherited from class com.adaptris.core.AdaptrisMessageWorkerImp

createQualifier, decode, encode, getEncoder, getIsTrackingEndpoint, getMessageFactory, getUniqueId, handleConnectionException, isTrackingEndpoint, registerConnection, registerEncoderMessageFactory, retrieveConnection, setEncoder, setIsTrackingEndpoint, setMessageFactory, setUniqueId, withMessageFactory, withUniqueID

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.adaptris.core.AdaptrisComponent

getUniqueId

Methods inherited from interface com.adaptris.core.AdaptrisMessageWorker

decode, encode, getEncoder, getMessageFactory, handleConnectionException, registerConnection, retrieveConnection, setEncoder, setMessageFactory

Methods inherited from interface com.adaptris.core.ComponentLifecycle

close, init

Methods inherited from interface com.adaptris.core.MessageEventGenerator

createQualifier, isTrackingEndpoint

Constructor Details

StandardMessageProducer

public StandardMessageProducer()

Method Details

prepare

public void prepare()
             throws CoreException

Throws:

CoreException

start

public void start()
           throws CoreException

Throws:

CoreException

stop

public void stop()

doProduce

protected void doProduce(AdaptrisMessage msg,
 String endpoint)
                  throws ProduceException

Specified by:

doProduce in class ProduceOnlyProducerImp

Throws:

ProduceException

withPropertyBuilder

public StandardMessageProducer withPropertyBuilder(Translator.BasicPropertiesBuilder b)

endpoint

public String endpoint(AdaptrisMessage msg)
                throws ProduceException

Specified by:

endpoint in class AdaptrisMessageProducerImp

Throws:

ProduceException

withQueue

public StandardMessageProducer withQueue(String s)

getQueue

public String getQueue()

The queue to publish to.

setQueue

public void setQueue(String queue)

The queue to publish to.

getPropertyBuilder

public Translator.BasicPropertiesBuilder getPropertyBuilder()

How to build the required BasicProperties if required.

The default if not explicitly specified is to return a null object which uses the default behaviour of RabbitMQ

setPropertyBuilder

public void setPropertyBuilder(Translator.BasicPropertiesBuilder propertyBuilder)

How to build the required BasicProperties if required.

The default if not explicitly specified is to return a null object which uses the default behaviour of RabbitMQ

getExchangeDeclaration

public Declaration.ExchangeDeclaration getExchangeDeclaration()

How the Exchange will be declared prior to use.

setExchangeDeclaration

public void setExchangeDeclaration(Declaration.ExchangeDeclaration exchangeDeclaration)

How the Exchange will be declared prior to use.

getQueueDeclaration

public Declaration.QueueDeclaration getQueueDeclaration()

How the Queue will be declared prior to use.

setQueueDeclaration

public void setQueueDeclaration(Declaration.QueueDeclaration queueDeclaration)

How the Queue will be declared prior to use.