com.mulesoft.mule.runtime.module.batch.internal.streaming

Class SerializationAwareQueueProducer<T>

java.lang.Object

com.mulesoft.mule.runtime.module.batch.internal.streaming.SerializationAwareQueueProducer<T>

All Implemented Interfaces:

Closeable, AutoCloseable, org.mule.runtime.api.streaming.HasSize, org.mule.runtime.core.api.streaming.iterator.Producer<T>

public class SerializationAwareQueueProducer<T>
extends Object
implements org.mule.runtime.core.api.streaming.iterator.Producer<T>

Implementation of Producer that reads arrays of byte from a Queue and then uses a ObjectSerializer to deserialized those bytes into an object. A polling timeout value might be specified, otherwise the default value of 5000 milliseconds will be assumed

Since:

3.5.0

Constructor Summary

Constructors

Constructor and Description
SerializationAwareQueueProducer(org.mule.runtime.core.api.util.queue.Queue queue, org.mule.runtime.api.serialization.ObjectSerializer serializer) Creates an instance with 5000 milliseconds as the default polling value
SerializationAwareQueueProducer(org.mule.runtime.core.api.util.queue.Queue queue, org.mule.runtime.api.serialization.ObjectSerializer serializer, long timeout)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getSize()
T	produce() This implementation will poll from the queue once and will return the obtained item.

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializationAwareQueueProducer

public SerializationAwareQueueProducer(org.mule.runtime.core.api.util.queue.Queue queue,
                                       org.mule.runtime.api.serialization.ObjectSerializer serializer)

Creates an instance with 5000 milliseconds as the default polling value

Parameters:

queue - the queue to stream from

serializer - the ObjectSerializer to be used when accessing the Queue

SerializationAwareQueueProducer

public SerializationAwareQueueProducer(org.mule.runtime.core.api.util.queue.Queue queue,
                                       org.mule.runtime.api.serialization.ObjectSerializer serializer,
                                       long timeout)

Method Detail

produce

public T produce()

This implementation will poll from the queue once and will return the obtained item. If the producer is closed or if the queue times out while polling, then null is returned. If the poll method throws InterruptedException then null is returned as well

Specified by:

produce in interface org.mule.runtime.core.api.streaming.iterator.Producer<T>

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getSize

public int getSize()

Specified by:

getSize in interface org.mule.runtime.api.streaming.HasSize