TransactionalQueue¶
- class TransactionalQueue(name, transaction, context)[source]¶
Bases:
hazelcast.proxy.base.TransactionalProxy
Transactional implementation of
Queue
.- offer(item, timeout=0)[source]¶
Transactional implementation of
Queue.offer(item, timeout)
- Parameters
item – The item to be added.
timeout (int) – Maximum time in seconds to wait for addition.
- Returns
True
if the element was added to this queue,False
otherwise.- Return type
hazelcast.future.Future[bool]
- take()[source]¶
Transactional implementation of
Queue.take()
- Returns
The head of this queue.
- Return type
- poll(timeout=0)[source]¶
Transactional implementation of
Queue.poll(timeout)
- Parameters
timeout (int) – Maximum time in seconds to wait for addition.
- Returns
The head of this queue, or
None
if this queue is empty or specified timeout elapses before an item is added to the queue.- Return type
- peek(timeout=0)[source]¶
Transactional implementation of
Queue.peek(timeout)
- Parameters
timeout (int) – Maximum time in seconds to wait for addition.
- Returns
The head of this queue, or
None
if this queue is empty or specified timeout elapses before an item is added to the queue.- Return type
- size()[source]¶
Transactional implementation of
Queue.size()
- Returns
Size of the queue.
- Return type