RequestResponseWorkItem Class

  • java.lang.Object
    • com.microsoft.azure.servicebus.primitives.WorkItem<Message>
      • com.microsoft.azure.servicebus.primitives.RequestResponseWorkItem

public class RequestResponseWorkItem

Constructor Summary

Constructor Description
RequestResponseWorkItem(Message request, TransactionContext transaction, CompletableFuture<Message> completableFuture, Duration timeout)
RequestResponseWorkItem(Message request, TransactionContext transaction, CompletableFuture<Message> completableFuture, TimeoutTracker tracker)

Method Summary

Modifier and Type Method and Description
Message getRequest()
TransactionContext getTransaction()

Inherited Members

com.microsoft.azure.servicebus.primitives.WorkItem.cancelTimeoutTask(boolean) com.microsoft.azure.servicebus.primitives.WorkItem.getLastKnownException() com.microsoft.azure.servicebus.primitives.WorkItem.getTimeoutTask() com.microsoft.azure.servicebus.primitives.WorkItem.getTimeoutTracker() com.microsoft.azure.servicebus.primitives.WorkItem.getWork() com.microsoft.azure.servicebus.primitives.WorkItem.setLastKnownException(Exception) com.microsoft.azure.servicebus.primitives.WorkItem.setTimeoutTask(final ScheduledFuture<?>) com.microsoft.azure.servicebus.primitives.WorkItem.WorkItem(final CompletableFuture<T>,final Duration) com.microsoft.azure.servicebus.primitives.WorkItem.WorkItem(final CompletableFuture<T>,final TimeoutTracker)

Constructor Details

RequestResponseWorkItem

public RequestResponseWorkItem(Message request, TransactionContext transaction, CompletableFuture completableFuture, Duration timeout)

Parameters:

request
transaction
completableFuture
timeout

RequestResponseWorkItem

public RequestResponseWorkItem(Message request, TransactionContext transaction, CompletableFuture completableFuture, TimeoutTracker tracker)

Parameters:

request
transaction
completableFuture
tracker

Method Details

getRequest

public Message getRequest()

getTransaction

public TransactionContext getTransaction()

Applies to