public class ClientTxnQueueProxy<E> extends Object implements TransactionalQueue<E>
Constructor and Description |
---|
ClientTxnQueueProxy(String name,
ClientTransactionContext transactionContext) |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Destroys this object cluster-wide.
|
String |
getName()
Returns the unique name for this DistributedObject.
|
String |
getPartitionKey()
Returns the key of the partition that this DistributedObject is assigned to.
|
String |
getServiceName()
Returns the service name for this object.
|
boolean |
offer(E e)
Inserts the specified element into this queue if it is possible to do
so immediately without violating capacity restrictions.
|
boolean |
offer(E e,
long timeout,
TimeUnit unit)
Inserts the specified element into this queue, waiting up to the
specified wait time if necessary for space to become available.
|
E |
peek() |
E |
peek(long timeout,
TimeUnit unit) |
E |
poll()
Retrieves and removes the head of this queue,
or returns null if this queue is empty.
|
E |
poll(long timeout,
TimeUnit unit)
Retrieves and removes the head of this queue, waiting up to the
specified wait time if necessary for an element to become available.
|
int |
size()
Returns the number of elements in this collection.
|
E |
take()
Retrieves and removes the head of this queue, waiting if necessary
until an element becomes available.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
destroy, getName, getPartitionKey
public ClientTxnQueueProxy(String name, ClientTransactionContext transactionContext)
public boolean offer(E e)
TransactionalQueue
public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueue
offer
in interface BaseQueue<E>
offer
in interface TransactionalQueue<E>
e
- the element to addtimeout
- how long to wait before giving up, in units of
unitunit
- a TimeUnit determines how to interpret the
timeout parameterInterruptedException
- if interrupted while waitingpublic E take() throws InterruptedException
TransactionalQueue
take
in interface BaseQueue<E>
take
in interface TransactionalQueue<E>
InterruptedException
- if interrupted while waitingpublic E poll()
TransactionalQueue
public E poll(long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueue
poll
in interface BaseQueue<E>
poll
in interface TransactionalQueue<E>
timeout
- how long to wait before giving up, in units of
unitunit
- a TimeUnit determining how to interpret the
timeout parameterInterruptedException
- if interrupted while waitingpublic E peek()
TransactionalQueue
peek
in interface TransactionalQueue<E>
public E peek(long timeout, TimeUnit unit) throws InterruptedException
TransactionalQueue
peek
in interface TransactionalQueue<E>
InterruptedException
public int size()
TransactionalQueue
public String getServiceName()
DistributedObject
getServiceName
in interface DistributedObject
public final void destroy()
DistributedObject
destroy
in interface DistributedObject
public String getName()
DistributedObject
getName
in interface DistributedObject
public String getPartitionKey()
DistributedObject
IAtomicLong
. For a partitioned data structure like an IMap
,
the returned value will not be null, but otherwise undefined.getPartitionKey
in interface DistributedObject
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.