Removes at most the given number of available transaction reports from this queue and returns them as a list.
Removes at most the given number of available transaction reports from this queue and returns them as a list.
This operation may be more efficient than repeatedly polling this queue.
the maximum number of reports to transfer.
a list of all available tranaction reports.
Removes all available transaction reports from this queue and returns them as a list.
Removes all available transaction reports from this queue and returns them as a list.
This operation may be more efficient than repeatedly polling this queue.
a list of all available tranaction reports.
Returns true
if this queue contains no transaction reports.
Returns true
if this queue contains no transaction reports.
true
if this queue contains no transaction reports.
Returns an iterator over the transaction reports in this queue.
Returns an iterator over the transaction reports in this queue.
an Iterator
over the transaction reports
in this queue.
Retrieves, but does not remove, the head of this queue,
or None
if this queue is empty.
Retrieves, but does not remove, the head of this queue,
or None
if this queue is empty.
the head of this queue, or None
if this
queue is empty.
Retrieves and removes the head of this queue,
or returns None
if this queue is empty.
Retrieves and removes the head of this queue,
or returns None
if this queue is empty.
the head of this queue, or None
if this queue is empty.
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
Throws InterruptedException if interrupted while waiting.
the duration of time to wait before giving up.
the head of this queue, or None
if the specified
waiting time elapses before an element is available.
the underlying transaction report queue.
Returns the number of transaction reports in the queue.
Returns the number of transaction reports in the queue.
the number of transaction reports in the queue.
Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
Throws InterruptedException if interrupted while waiting.
the head of this queue.
The data queue associated with a connection.
At any point in time either zero or one queue is associated with a connection.
This queue may be safely consumed from more than one thread. Note that the queue does not block producers, and will consume memory until you consume the elements from it.
Reports will be added to the queue at some point after the database has been updated. If the associated connection originated the transaction, the transaction future will be notified first, before a report is placed on this queue.
datomic.Connection.txReportQueue()