ome.smuggler.providers.q

Class EnqueueTask<T>

java.lang.Object

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

All Implemented Interfaces:

ChannelSource<ChannelMessage<java.util.function.Function<QueueConnector,org.apache.activemq.artemis.api.core.client.ClientMessage>,T>>, MessageSource<java.util.function.Function<QueueConnector,org.apache.activemq.artemis.api.core.client.ClientMessage>,T>

public class EnqueueTask<T>
extends java.lang.Object
implements MessageSource<java.util.function.Function<QueueConnector,org.apache.activemq.artemis.api.core.client.ClientMessage>,T>

Puts messages on a queue, asynchronously. Messages are durable by default but any other kind of message can be constructed by providing a message builder function as message metadata.

Constructor Summary

Constructors

Constructor and Description
EnqueueTask(QueueConnector queue, SinkWriter<T,java.io.OutputStream> serializer) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	send(ChannelMessage<java.util.function.Function<QueueConnector,org.apache.activemq.artemis.api.core.client.ClientMessage>,T> msg) Inputs data into the channel and returns immediately.

Methods inherited from class java.lang.Object

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

Methods inherited from interface ome.smuggler.core.msg.MessageSource

asDataSource

Methods inherited from interface ome.smuggler.core.msg.ChannelSource

uncheckedSend

Constructor Detail

EnqueueTask

public EnqueueTask(QueueConnector queue,
                   SinkWriter<T,java.io.OutputStream> serializer)
            throws org.apache.activemq.artemis.api.core.ActiveMQException

Creates a new instance.

Parameters:

queue - provides access to the queue on which to put messages.

serializer - serialises the message data, a T-value.

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException - if a queue producer could not be created.

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

Method Detail

send

public void send(ChannelMessage<java.util.function.Function<QueueConnector,org.apache.activemq.artemis.api.core.client.ClientMessage>,T> msg)
          throws java.lang.Exception

Description copied from interface: ChannelSource

Inputs data into the channel and returns immediately. This is an asynchronous operation, so that the sender never waits for the receiver to get the data.

Specified by:

send in interface ChannelSource<ChannelMessage<java.util.function.Function<QueueConnector,org.apache.activemq.artemis.api.core.client.ClientMessage>,T>>

Parameters:

msg - the message to send.

Throws:

java.lang.NullPointerException - if the input is null.

java.lang.Exception - if the data could not be input into the channel.