com.mulesoft.mule.runtime.module.cluster.internal.serialization

Class SerializationSaavyTransactionalQueue<T>

java.lang.Object

com.mulesoft.mule.runtime.module.cluster.internal.serialization.SerializationSaavyQueueSupport

com.mulesoft.mule.runtime.module.cluster.internal.serialization.SerializationSaavyTransactionalQueue<T>

All Implemented Interfaces:

com.hazelcast.core.BaseQueue<T>, com.hazelcast.core.DistributedObject, com.hazelcast.core.TransactionalQueue<T>, com.hazelcast.transaction.TransactionalObject

public final class SerializationSaavyTransactionalQueue<T>
extends SerializationSaavyQueueSupport
implements com.hazelcast.core.TransactionalQueue<T>

Wraps a TransactionalQueue and it uses a ClusterDistributedObject to serialize its values

Since:

3.7.0

Constructor Summary

Constructors

Constructor and Description
SerializationSaavyTransactionalQueue(com.hazelcast.core.TransactionalQueue delegate, org.mule.runtime.api.serialization.ObjectSerializer objectSerializer)

Method Summary

Modifier and Type	Method and Description
void	destroy()
String	getName()
String	getPartitionKey()
String	getServiceName()
boolean	offer(T object)
boolean	offer(T t, long timeout, TimeUnit unit)
T	peek()
T	peek(long timeout, TimeUnit unit)
T	poll()
T	poll(long timeout, TimeUnit unit)
int	size()
T	take()

Methods inherited from class com.mulesoft.mule.runtime.module.cluster.internal.serialization.SerializationSaavyQueueSupport

deserialize, serialize

Methods inherited from class java.lang.Object

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

Constructor Detail

SerializationSaavyTransactionalQueue

public SerializationSaavyTransactionalQueue(com.hazelcast.core.TransactionalQueue delegate,
                                            org.mule.runtime.api.serialization.ObjectSerializer objectSerializer)

Method Detail

offer

public boolean offer(T object)

Specified by:

offer in interface com.hazelcast.core.BaseQueue<T>

Specified by:

offer in interface com.hazelcast.core.TransactionalQueue<T>

offer

public boolean offer(T t,
                     long timeout,
                     TimeUnit unit)
              throws InterruptedException

Specified by:

offer in interface com.hazelcast.core.BaseQueue<T>

Specified by:

offer in interface com.hazelcast.core.TransactionalQueue<T>

Throws:

InterruptedException

take

public T take()
       throws InterruptedException

Specified by:

take in interface com.hazelcast.core.BaseQueue<T>

Specified by:

take in interface com.hazelcast.core.TransactionalQueue<T>

Throws:

InterruptedException

poll

public T poll()

Specified by:

poll in interface com.hazelcast.core.BaseQueue<T>

Specified by:

poll in interface com.hazelcast.core.TransactionalQueue<T>

poll

public T poll(long timeout,
              TimeUnit unit)
       throws InterruptedException

Specified by:

poll in interface com.hazelcast.core.BaseQueue<T>

Specified by:

poll in interface com.hazelcast.core.TransactionalQueue<T>

Throws:

InterruptedException

peek

public T peek()

Specified by:

peek in interface com.hazelcast.core.TransactionalQueue<T>

peek

public T peek(long timeout,
              TimeUnit unit)
       throws InterruptedException

Specified by:

peek in interface com.hazelcast.core.TransactionalQueue<T>

Throws:

InterruptedException

size

public int size()

Specified by:

size in interface com.hazelcast.core.BaseQueue<T>

Specified by:

size in interface com.hazelcast.core.TransactionalQueue<T>

getPartitionKey

public String getPartitionKey()

Specified by:

getPartitionKey in interface com.hazelcast.core.DistributedObject

getName

public String getName()

Specified by:

getName in interface com.hazelcast.core.DistributedObject

getServiceName

public String getServiceName()

Specified by:

getServiceName in interface com.hazelcast.core.DistributedObject

destroy

public void destroy()

Specified by:

destroy in interface com.hazelcast.core.DistributedObject