ome.smuggler.providers.q

Class ScheduleTask<T>

java.lang.Object

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

All Implemented Interfaces:

ChannelSource<ChannelMessage<FutureTimepoint,T>>, MessageSource<FutureTimepoint,T>, SchedulingSource<T>

public class ScheduleTask<T>
extends java.lang.Object
implements SchedulingSource<T>

Enqueues a message that will only be delivered to consumers at a specified time in the future.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	send(ChannelMessage<FutureTimepoint,T> msg) Sends the message so that the channel will only deliver it to consumers at the specified time in the future.

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

ScheduleTask

public ScheduleTask(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<FutureTimepoint,T> msg)
          throws java.lang.Exception

Sends the message so that the channel will only deliver it to consumers at the specified time in the future.

Specified by:

send in interface ChannelSource<ChannelMessage<FutureTimepoint,T>>

Parameters:

msg - amount of time from now to specify when in the future the message should be delivered.

Throws:

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

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