ome.smuggler.providers.q

Class CountedScheduleTask<T>

java.lang.Object

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

All Implemented Interfaces:

ChannelSource<ChannelMessage<CountedSchedule,T>>, MessageSource<CountedSchedule,T>

public class CountedScheduleTask<T>
extends java.lang.Object
implements MessageSource<CountedSchedule,T>

Enqueues a message that will only be delivered to consumers at a specified time in the future and makes a sender-specified delivery count available in the metadata.

See Also:

CountedScheduleSink

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	send(ChannelMessage<CountedSchedule,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

CountedScheduleTask

public CountedScheduleTask(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<CountedSchedule,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<CountedSchedule,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.