Package com.microsoft.azure.servicebus.primitives

Class RequestResponseWorkItem

java.lang.Object

com.microsoft.azure.servicebus.primitives.RequestResponseWorkItem

public class RequestResponseWorkItem
extends Object

Constructor Summary

Constructors

Constructor	Description
RequestResponseWorkItem(org.apache.qpid.proton.message.Message request, TransactionContext transaction, CompletableFuture<org.apache.qpid.proton.message.Message> completableFuture, TimeoutTracker tracker)
RequestResponseWorkItem(org.apache.qpid.proton.message.Message request, TransactionContext transaction, CompletableFuture<org.apache.qpid.proton.message.Message> completableFuture, Duration timeout)

Method Summary

Modifier and Type	Method	Description
boolean	cancelTimeoutTask(boolean mayInterruptIfRunning)
Exception	getLastKnownException()
org.apache.qpid.proton.message.Message	getRequest()
ScheduledFuture<?>	getTimeoutTask()
TimeoutTracker	getTimeoutTracker()
TransactionContext	getTransaction()
CompletableFuture<T>	getWork()
void	setLastKnownException(Exception exception)
void	setTimeoutTask(ScheduledFuture<?> timeoutTask)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RequestResponseWorkItem

public RequestResponseWorkItem(org.apache.qpid.proton.message.Message request,
                               TransactionContext transaction,
                               CompletableFuture<org.apache.qpid.proton.message.Message> completableFuture,
                               TimeoutTracker tracker)

RequestResponseWorkItem

public RequestResponseWorkItem(org.apache.qpid.proton.message.Message request,
                               TransactionContext transaction,
                               CompletableFuture<org.apache.qpid.proton.message.Message> completableFuture,
                               Duration timeout)

Method Detail

getRequest

public org.apache.qpid.proton.message.Message getRequest()

getTransaction

public TransactionContext getTransaction()

getTimeoutTracker

public TimeoutTracker getTimeoutTracker()

getWork

public CompletableFuture<T> getWork()

getTimeoutTask

public ScheduledFuture<?> getTimeoutTask()

setTimeoutTask

public void setTimeoutTask(ScheduledFuture<?> timeoutTask)

cancelTimeoutTask

public boolean cancelTimeoutTask(boolean mayInterruptIfRunning)

getLastKnownException

public Exception getLastKnownException()

setLastKnownException

public void setLastKnownException(Exception exception)