ome.smuggler.providers.q

Class DequeueTask<T>

java.lang.Object

ome.smuggler.providers.q.DequeueTask<T>

All Implemented Interfaces:

org.apache.activemq.artemis.api.core.client.MessageHandler

public class DequeueTask<T>
extends java.lang.Object
implements org.apache.activemq.artemis.api.core.client.MessageHandler

Receives messages asynchronously from a queue and dispatches them to a consumer.

Constructor Summary

Constructors

Constructor and Description
DequeueTask(QueueConnector queue, ChannelSink<T> consumer, SourceReader<java.io.InputStream,T> deserializer, boolean redeliverOnCrash) Creates a new instance.
DequeueTask(QueueConnector queue, MessageSink<org.apache.activemq.artemis.api.core.client.ClientMessage,T> consumer, SourceReader<java.io.InputStream,T> deserializer, boolean redeliverOnCrash) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage msg)

Methods inherited from class java.lang.Object

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

Constructor Detail

DequeueTask

public DequeueTask(QueueConnector queue,
                   ChannelSink<T> consumer,
                   SourceReader<java.io.InputStream,T> deserializer,
                   boolean redeliverOnCrash)
            throws org.apache.activemq.artemis.api.core.ActiveMQException

Creates a new instance.

Parameters:

queue - provides access to the queue from which to fetch messages.

consumer - consumes message data fetched from the queue.

deserializer - de-serialises the message data, a T-value.

redeliverOnCrash - if true and the process terminates abnormally (e.g. segfault, power failure) while the consumer is busy processing a message, the message will be delivered again once the process is rebooted. If false, a message will only ever be delivered once to the consumer.

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException - if an error occurs while setting up Artemis to receive messages on the specified queue.

java.lang.NullPointerException - if any argument is null.

DequeueTask

public DequeueTask(QueueConnector queue,
                   MessageSink<org.apache.activemq.artemis.api.core.client.ClientMessage,T> consumer,
                   SourceReader<java.io.InputStream,T> deserializer,
                   boolean redeliverOnCrash)
            throws org.apache.activemq.artemis.api.core.ActiveMQException

Creates a new instance.

Parameters:

queue - provides access to the queue from which to fetch messages.

consumer - consumes message data and metadata fetched from the queue.

redeliverOnCrash - if true and the process terminates abnormally (e.g. segfault, power failure) while the consumer is busy processing a message, the message will be delivered again once the process is rebooted. If false, a message will only ever be delivered once to the consumer.

deserializer - de-serialises the message data, a T-value.

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException - if an error occurs while setting up Artemis to receive messages on the specified queue.

java.lang.NullPointerException - if any argument is null.

Method Detail

onMessage

public void onMessage(org.apache.activemq.artemis.api.core.client.ClientMessage msg)

Specified by:

onMessage in interface org.apache.activemq.artemis.api.core.client.MessageHandler