T
- the operation typepublic class BlockingQueueOperationListener<T extends TransactionalProtocolClient.Operation> extends Object implements TransactionalProtocolClient.TransactionalOperationListener<T>
Modifier and Type | Class and Description |
---|---|
static class |
BlockingQueueOperationListener.FailedOperation<T extends TransactionalProtocolClient.Operation> |
Constructor and Description |
---|
BlockingQueueOperationListener() |
BlockingQueueOperationListener(BlockingQueue<TransactionalProtocolClient.PreparedOperation<T>> queue) |
BlockingQueueOperationListener(int capacity) |
Modifier and Type | Method and Description |
---|---|
protected void |
drainTo(Collection<TransactionalProtocolClient.PreparedOperation<T>> collection) |
void |
operationComplete(T operation,
OperationResponse result)
Notification that an operation completed.
|
void |
operationFailed(T operation,
org.jboss.dmr.ModelNode result)
Notification that an operation failed.
|
void |
operationPrepared(TransactionalProtocolClient.PreparedOperation<T> prepared)
Notification that an operation was prepared.
|
TransactionalProtocolClient.PreparedOperation<T> |
retrievePreparedOperation()
Retrieves and removes the head of the underlying queue, waiting if necessary until an element becomes available.
|
TransactionalProtocolClient.PreparedOperation<T> |
retrievePreparedOperation(long timeout,
TimeUnit timeUnit)
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
|
public BlockingQueueOperationListener()
public BlockingQueueOperationListener(int capacity)
public BlockingQueueOperationListener(BlockingQueue<TransactionalProtocolClient.PreparedOperation<T>> queue)
public void operationPrepared(TransactionalProtocolClient.PreparedOperation<T> prepared)
TransactionalProtocolClient.TransactionalOperationListener
operationPrepared
in interface TransactionalProtocolClient.TransactionalOperationListener<T extends TransactionalProtocolClient.Operation>
prepared
- the prepared operationpublic void operationFailed(T operation, org.jboss.dmr.ModelNode result)
TransactionalProtocolClient.TransactionalOperationListener
operationFailed
in interface TransactionalProtocolClient.TransactionalOperationListener<T extends TransactionalProtocolClient.Operation>
operation
- the operationresult
- the operation resultpublic void operationComplete(T operation, OperationResponse result)
TransactionalProtocolClient.TransactionalOperationListener
operationComplete
in interface TransactionalProtocolClient.TransactionalOperationListener<T extends TransactionalProtocolClient.Operation>
operation
- the operationresult
- the final resultpublic TransactionalProtocolClient.PreparedOperation<T> retrievePreparedOperation() throws InterruptedException
InterruptedException
protected void drainTo(Collection<TransactionalProtocolClient.PreparedOperation<T>> collection)
public TransactionalProtocolClient.PreparedOperation<T> retrievePreparedOperation(long timeout, TimeUnit timeUnit) throws InterruptedException
timeout
- the timeouttimeUnit
- the time unitInterruptedException
Copyright © 2023 JBoss by Red Hat. All rights reserved.