Package com.microsoft.azure.eventhubs.impl

Class RequestResponseOpener

java.lang.Object

com.microsoft.azure.eventhubs.impl.RequestResponseOpener

All Implemented Interfaces:

Operation<RequestResponseChannel>

public class RequestResponseOpener
extends Object
implements Operation<RequestResponseChannel>

Constructor Summary

Constructors

Constructor	Description
RequestResponseOpener(SessionProvider sessionProvider, String clientId, String sessionName, String linkName, String endpointAddress, AmqpConnection eventDispatcher, ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method	Description
void	run(OperationResult<RequestResponseChannel,Exception> operationCallback)

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestResponseOpener

public RequestResponseOpener(SessionProvider sessionProvider,
                             String clientId,
                             String sessionName,
                             String linkName,
                             String endpointAddress,
                             AmqpConnection eventDispatcher,
                             ScheduledExecutorService executor)

Method Detail

run

public void run(OperationResult<RequestResponseChannel,Exception> operationCallback)

Specified by:

run in interface Operation<RequestResponseChannel>