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: hazelcast.future.Future[any]

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: hazelcast.future.Future[any]

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: hazelcast.future.Future[any]

size()[source]¶

Transactional implementation of Queue.size()

Returns: Size of the queue.
Return type: hazelcast.future.Future[int]