ome.smuggler.providers.q

Class QChannelFactory<T>

java.lang.Object

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

public class QChannelFactory<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
QChannelFactory(ServerConnector connector, org.apache.activemq.artemis.core.config.CoreQueueConfiguration qConfig)

Method Summary

Modifier and Type	Method and Description
DequeueTask<T>	buildCountedScheduleSink(MessageSink<CountedSchedule,T> consumer, SourceReader<java.io.InputStream,T> deserializer)
DequeueTask<T>	buildCountedScheduleSink(MessageSink<CountedSchedule,T> consumer, SourceReader<java.io.InputStream,T> deserializer, boolean redeliverOnCrash)
MessageSource<CountedSchedule,T>	buildCountedScheduleSource(SinkWriter<T,java.io.OutputStream> serializer)
DequeueTask<T>	buildReschedulableSink(Reschedulable<T> consumer, SinkWriter<T,java.io.OutputStream> serializer, SourceReader<java.io.InputStream,T> deserializer)
DequeueTask<T>	buildReschedulableSink(Reschedulable<T> consumer, SinkWriter<T,java.io.OutputStream> serializer, SourceReader<java.io.InputStream,T> deserializer, boolean redeliverOnCrash)
SchedulingSource<T>	buildSchedulingSource(SinkWriter<T,java.io.OutputStream> serializer)
DequeueTask<T>	buildSink(ChannelSink<T> consumer, SourceReader<java.io.InputStream,T> deserializer)
DequeueTask<T>	buildSink(ChannelSink<T> consumer, SourceReader<java.io.InputStream,T> deserializer, boolean redeliverOnCrash)
ChannelSource<T>	buildSource(SinkWriter<T,java.io.OutputStream> serializer)
static <T> QChannelFactory<T>	with(ServerConnector connector, org.apache.activemq.artemis.core.config.CoreQueueConfiguration qConfig)

Methods inherited from class java.lang.Object

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

Constructor Detail

QChannelFactory

public QChannelFactory(ServerConnector connector,
                       org.apache.activemq.artemis.core.config.CoreQueueConfiguration qConfig)

Method Detail

with

public static <T> QChannelFactory<T> with(ServerConnector connector,
                                          org.apache.activemq.artemis.core.config.CoreQueueConfiguration qConfig)

buildSource

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

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

buildSchedulingSource

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

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

buildCountedScheduleSource

public MessageSource<CountedSchedule,T> buildCountedScheduleSource(SinkWriter<T,java.io.OutputStream> serializer)
                                                            throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

buildSink

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

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

buildSink

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

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

buildCountedScheduleSink

public DequeueTask<T> buildCountedScheduleSink(MessageSink<CountedSchedule,T> consumer,
                                               SourceReader<java.io.InputStream,T> deserializer)
                                        throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

buildCountedScheduleSink

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

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

buildReschedulableSink

public DequeueTask<T> buildReschedulableSink(Reschedulable<T> consumer,
                                             SinkWriter<T,java.io.OutputStream> serializer,
                                             SourceReader<java.io.InputStream,T> deserializer)
                                      throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException

buildReschedulableSink

public DequeueTask<T> buildReschedulableSink(Reschedulable<T> consumer,
                                             SinkWriter<T,java.io.OutputStream> serializer,
                                             SourceReader<java.io.InputStream,T> deserializer,
                                             boolean redeliverOnCrash)
                                      throws org.apache.activemq.artemis.api.core.ActiveMQException

Throws:

org.apache.activemq.artemis.api.core.ActiveMQException