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

Class HazelcastQueueTransactionContext

java.lang.Object

com.mulesoft.mule.runtime.module.cluster.internal.vm.HazelcastQueueTransactionContext

All Implemented Interfaces:

org.mule.runtime.core.internal.util.queue.QueueTransactionContext

public class HazelcastQueueTransactionContext
extends Object
implements org.mule.runtime.core.internal.util.queue.QueueTransactionContext

Field Summary

Fields

Modifier and Type	Field and Description
static int	LONG_TIMEOUT
static int	SHORT_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
HazelcastQueueTransactionContext(com.hazelcast.transaction.TransactionContext transactionContext, ClusterQueueNameResolver clusterQueueNameResolver, org.mule.runtime.api.serialization.ObjectSerializer objectSerializer)

Method Summary

Modifier and Type	Method and Description
void	clear(org.mule.runtime.core.internal.util.queue.QueueStore queue)
boolean	offer(org.mule.runtime.core.internal.util.queue.QueueStore queue, Serializable item, long offerTimeout)
Serializable	peek(org.mule.runtime.core.internal.util.queue.QueueStore queue)
Serializable	poll(org.mule.runtime.core.internal.util.queue.QueueStore queue, long pollTimeout)
int	size(org.mule.runtime.core.internal.util.queue.QueueStore queue)
void	untake(org.mule.runtime.core.internal.util.queue.QueueStore queue, Serializable item)

Methods inherited from class java.lang.Object

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

Field Detail

LONG_TIMEOUT

public static final int LONG_TIMEOUT

See Also:

Constant Field Values

SHORT_TIMEOUT

public static final int SHORT_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

HazelcastQueueTransactionContext

public HazelcastQueueTransactionContext(com.hazelcast.transaction.TransactionContext transactionContext,
                                        ClusterQueueNameResolver clusterQueueNameResolver,
                                        org.mule.runtime.api.serialization.ObjectSerializer objectSerializer)

Method Detail

offer

public boolean offer(org.mule.runtime.core.internal.util.queue.QueueStore queue,
                     Serializable item,
                     long offerTimeout)
              throws InterruptedException

Specified by:

offer in interface org.mule.runtime.core.internal.util.queue.QueueTransactionContext

Throws:

InterruptedException

untake

public void untake(org.mule.runtime.core.internal.util.queue.QueueStore queue,
                   Serializable item)
            throws InterruptedException

Specified by:

untake in interface org.mule.runtime.core.internal.util.queue.QueueTransactionContext

Throws:

InterruptedException

clear

public void clear(org.mule.runtime.core.internal.util.queue.QueueStore queue)
           throws InterruptedException

Specified by:

clear in interface org.mule.runtime.core.internal.util.queue.QueueTransactionContext

Throws:

InterruptedException

poll

public Serializable poll(org.mule.runtime.core.internal.util.queue.QueueStore queue,
                         long pollTimeout)
                  throws InterruptedException

Specified by:

poll in interface org.mule.runtime.core.internal.util.queue.QueueTransactionContext

Throws:

InterruptedException

peek

public Serializable peek(org.mule.runtime.core.internal.util.queue.QueueStore queue)

Specified by:

peek in interface org.mule.runtime.core.internal.util.queue.QueueTransactionContext

size

public int size(org.mule.runtime.core.internal.util.queue.QueueStore queue)

Specified by:

size in interface org.mule.runtime.core.internal.util.queue.QueueTransactionContext