ome.smuggler.providers.q

Class CountedScheduleSink<T>

java.lang.Object

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

All Implemented Interfaces:

ChannelSink<ChannelMessage<org.apache.activemq.artemis.api.core.client.ClientMessage,T>>, MessageSink<org.apache.activemq.artemis.api.core.client.ClientMessage,T>

public class CountedScheduleSink<T>
extends java.lang.Object
implements MessageSink<org.apache.activemq.artemis.api.core.client.ClientMessage,T>

DequeueTask consumer to convert raw Artemis metadata into a CountedSchedule and forward it, along with the received data T to a target message sink.

See Also:

CountedScheduleTask

Constructor Summary

Constructors

Constructor and Description
CountedScheduleSink(MessageSink<CountedSchedule,T> consumer) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	consume(ChannelMessage<org.apache.activemq.artemis.api.core.client.ClientMessage,T> queued) Consumes a message.

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.MessageSink

asDataSink, forwardDataTo

Constructor Detail

CountedScheduleSink

public CountedScheduleSink(MessageSink<CountedSchedule,T> consumer)

Creates a new instance.

Parameters:

consumer - the target sink to consume the metadata and data extracted from queued messages.

Throws:

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

Method Detail

consume

public void consume(ChannelMessage<org.apache.activemq.artemis.api.core.client.ClientMessage,T> queued)

Description copied from interface: ChannelSink

Consumes a message.

Specified by:

consume in interface ChannelSink<ChannelMessage<org.apache.activemq.artemis.api.core.client.ClientMessage,T>>

Parameters:

queued - the message data output from the channel.