org.gytheio.messaging.amqp

Class AmqpDirectEndpoint

java.lang.Object

org.gytheio.messaging.amqp.AmqpDirectEndpoint

All Implemented Interfaces:

org.gytheio.messaging.MessageProducer

public class AmqpDirectEndpoint
extends Object
implements org.gytheio.messaging.MessageProducer

A MessageProducer and message listener which interacts with AMQP queues directly using Apache Qpid.

Author:

Ray Gauss II

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AmqpDirectEndpoint.AmqpListener

Constructor Summary

Constructors

Constructor and Description
AmqpDirectEndpoint()

Method Summary

Methods

Modifier and Type	Method and Description
AmqpDirectEndpoint.AmqpListener	getListener()
boolean	isInitialized()
void	send(Object message)
void	send(Object message, Map<String,Object> headers)
void	send(Object message, String queueName)
void	send(Object message, String queueName, Map<String,Object> headers)
void	setHost(String host)
void	setMessageConsumer(org.gytheio.messaging.MessageConsumer messageConsumer)
void	setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
void	setPassword(String password)
void	setPort(int port)
void	setReceiveQueueName(String receiveQueueName)
void	setSendQueueName(String sendQueueName)
void	setUsername(String username)
void	startListener()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpDirectEndpoint

public AmqpDirectEndpoint()

Method Detail

setHost

public void setHost(String host)

setPort

public void setPort(int port)

setUsername

public void setUsername(String username)

setPassword

public void setPassword(String password)

setReceiveQueueName

public void setReceiveQueueName(String receiveQueueName)

setSendQueueName

public void setSendQueueName(String sendQueueName)

setMessageConsumer

public void setMessageConsumer(org.gytheio.messaging.MessageConsumer messageConsumer)

setObjectMapper

public void setObjectMapper(com.fasterxml.jackson.databind.ObjectMapper objectMapper)

send

public void send(Object message)

Specified by:

send in interface org.gytheio.messaging.MessageProducer

send

public void send(Object message,
        Map<String,Object> headers)
          throws org.gytheio.messaging.MessagingException

Specified by:

send in interface org.gytheio.messaging.MessageProducer

Throws:

org.gytheio.messaging.MessagingException

send

public void send(Object message,
        String queueName,
        Map<String,Object> headers)
          throws org.gytheio.messaging.MessagingException

Specified by:

send in interface org.gytheio.messaging.MessageProducer

Throws:

org.gytheio.messaging.MessagingException

send

public void send(Object message,
        String queueName)

Specified by:

send in interface org.gytheio.messaging.MessageProducer

startListener

public void startListener()

getListener

public AmqpDirectEndpoint.AmqpListener getListener()

isInitialized

public boolean isInitialized()

toString

public String toString()

Overrides:

toString in class Object