org.trellisldp.amqp

Class AmqpPublisher

java.lang.Object

org.trellisldp.amqp.AmqpPublisher

All Implemented Interfaces:

EventService

public class AmqpPublisher
extends Object
implements EventService

An AMQP message producer capable of publishing messages to an AMQP broker such as RabbitMQ or Qpid.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_AMQP_EXCHANGE_NAME The configuration key controlling the AMQP exchange name.
static String	CONFIG_AMQP_IMMEDIATE The configuration key controlling whether publishing is immediate.
static String	CONFIG_AMQP_MANDATORY The configuration key controlling whether publishing is mandatory.
static String	CONFIG_AMQP_ROUTING_KEY The configuration key controlling the AMQP routing key.
static String	CONFIG_AMQP_URI The configuration key controlling the AMQP connection URI.

Constructor Summary

Constructors

Constructor and Description
AmqpPublisher() Create an AMQP publisher.
AmqpPublisher(com.rabbitmq.client.Channel channel) Create an AMQP publisher.
AmqpPublisher(com.rabbitmq.client.Channel channel, String exchangeName, String routingKey) Create an AMQP publisher.
AmqpPublisher(com.rabbitmq.client.Channel channel, String exchangeName, String routingKey, boolean mandatory, boolean immediate) Create an AMQP publisher.

Method Summary

Modifier and Type	Method and Description
void	emit(Event event) Emit an event to the event service.

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_AMQP_EXCHANGE_NAME

public static final String CONFIG_AMQP_EXCHANGE_NAME

The configuration key controlling the AMQP exchange name.

See Also:

Constant Field Values

CONFIG_AMQP_ROUTING_KEY

public static final String CONFIG_AMQP_ROUTING_KEY

The configuration key controlling the AMQP routing key.

See Also:

Constant Field Values

CONFIG_AMQP_MANDATORY

public static final String CONFIG_AMQP_MANDATORY

The configuration key controlling whether publishing is mandatory.

See Also:

Constant Field Values

CONFIG_AMQP_IMMEDIATE

public static final String CONFIG_AMQP_IMMEDIATE

The configuration key controlling whether publishing is immediate.

See Also:

Constant Field Values

CONFIG_AMQP_URI

public static final String CONFIG_AMQP_URI

The configuration key controlling the AMQP connection URI.

See Also:

Constant Field Values

Constructor Detail

AmqpPublisher

@Inject
public AmqpPublisher()
                      throws IOException,
                             GeneralSecurityException,
                             URISyntaxException,
                             TimeoutException

Create an AMQP publisher.

Throws:

IOException - in the event that an I/O related error occurs when connecting

GeneralSecurityException - in the event that a security error occurs when connecting

URISyntaxException - in the event that the connection URI is syntactically incorrect

TimeoutException - in the event that the connection times out

AmqpPublisher

public AmqpPublisher(com.rabbitmq.client.Channel channel)

Create an AMQP publisher.

Parameters:

channel - the channel

AmqpPublisher

public AmqpPublisher(com.rabbitmq.client.Channel channel,
                     String exchangeName,
                     String routingKey)

Create an AMQP publisher.

Parameters:

channel - the channel

exchangeName - the exchange name

routingKey - the routing key

AmqpPublisher

public AmqpPublisher(com.rabbitmq.client.Channel channel,
                     String exchangeName,
                     String routingKey,
                     boolean mandatory,
                     boolean immediate)

Create an AMQP publisher.

Parameters:

channel - the channel

exchangeName - the exchange name

routingKey - the routing key

mandatory - the mandatory setting

immediate - the immediate setting

Method Detail

emit

public void emit(Event event)

Description copied from interface: EventService

Emit an event to the event service.

Specified by:

emit in interface EventService

Parameters:

event - the event