Package com.microsoft.azure.eventhubs.impl

Class RequestResponseChannel

java.lang.Object

com.microsoft.azure.eventhubs.impl.RequestResponseChannel

All Implemented Interfaces:

IOObject

public class RequestResponseChannel
extends Object
implements IOObject

Nested Class Summary

Nested classes/interfaces inherited from interface com.microsoft.azure.eventhubs.impl.IOObject

IOObject.IOObjectState

Constructor Summary

Constructors

Constructor	Description
RequestResponseChannel(String linkName, String path, org.apache.qpid.proton.engine.Session session, ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method	Description
void	close(OperationResult<Void,Exception> onGraceFullClose)
String	getId()
org.apache.qpid.proton.engine.Receiver	getReceiveLink()
org.apache.qpid.proton.engine.Sender	getSendLink()
IOObject.IOObjectState	getState()
void	open(OperationResult<Void,Exception> onOpen, OperationResult<Void,Exception> onClose)
void	request(org.apache.qpid.proton.message.Message message, OperationResult<org.apache.qpid.proton.message.Message,Exception> onResponse)

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestResponseChannel

public RequestResponseChannel(String linkName,
                              String path,
                              org.apache.qpid.proton.engine.Session session,
                              ScheduledExecutorService executor)

Method Detail

open

public void open(OperationResult<Void,Exception> onOpen,
                 OperationResult<Void,Exception> onClose)

close

public void close(OperationResult<Void,Exception> onGraceFullClose)

getSendLink

public org.apache.qpid.proton.engine.Sender getSendLink()

getReceiveLink

public org.apache.qpid.proton.engine.Receiver getReceiveLink()

request

public void request(org.apache.qpid.proton.message.Message message,
                    OperationResult<org.apache.qpid.proton.message.Message,Exception> onResponse)

getState

public IOObject.IOObjectState getState()

Specified by:

getState in interface IOObject

getId

public String getId()

Specified by:

getId in interface IOObject