org.apache.synapse.transport.amqp.sendertask

Class AMQPSender

java.lang.Object

org.apache.synapse.transport.amqp.sendertask.AMQPSender

public class AMQPSender
extends Object

Performs the actual sending of the AMQP message, this class is designed to be cached ,so it accepts the message context from out side rather than from the constructor.

Constructor Summary

Constructors

Constructor and Description
AMQPSender()

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.Channel	getChannel()
void	sendAMQPMessage(org.apache.axis2.context.MessageContext mc, String correlationId, String replyTo)
void	setChannel(com.rabbitmq.client.Channel channel)
void	setExchangeName(String exchangeName)
void	setQueueName(String queueName)
void	setRoutingKey(String routingKey)

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPSender

public AMQPSender()

Method Detail

setChannel

public void setChannel(com.rabbitmq.client.Channel channel)

setExchangeName

public void setExchangeName(String exchangeName)

setRoutingKey

public void setRoutingKey(String routingKey)

setQueueName

public void setQueueName(String queueName)

getChannel

public com.rabbitmq.client.Channel getChannel()

sendAMQPMessage

public void sendAMQPMessage(org.apache.axis2.context.MessageContext mc,
                            String correlationId,
                            String replyTo)
                     throws AMQPTransportException,
                            IOException

Throws:

AMQPTransportException

IOException