public class ProtonClientConnectionContext extends AbstractConnectionContext implements AMQPClientConnectionContext
AMQP_CONTAINER_ID, CONNECTION_OPEN_FAILED, connectionCallback, handler, listener
Constructor and Description |
---|
ProtonClientConnectionContext(AMQPConnectionCallback connectionCallback,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
ProtonClientConnectionContext(AMQPConnectionCallback connectionCallback,
String containerId,
int idleTimeout,
int maxFrameSize,
int channelMax,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
Modifier and Type | Method and Description |
---|---|
void |
clientOpen(ClientSASL sasl)
This will send an open and block for its return on AMQP protocol.
|
AMQPClientSessionContext |
createClientSession() |
protected AbstractProtonSessionContext |
newSessionExtension(org.apache.qpid.proton.engine.Session realSession) |
protected void |
remoteLinkOpened(org.apache.qpid.proton.engine.Link link) |
void |
setContainer(String containerID) |
capacity, checkDataReceived, close, destroy, flush, flushBytes, getCreationTime, getLock, getPubSubPrefix, getRemoteContainer, getSASLResult, getSessionExtension, inputBuffer, isSyncOnFlush, outputDone
afterInit, initialise, isInitialized, waitWithTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
capacity, checkDataReceived, close, flush, getCreationTime, getLock, getSASLResult, inputBuffer, isSyncOnFlush, outputDone
public ProtonClientConnectionContext(AMQPConnectionCallback connectionCallback, Executor dispatchExecutor, ScheduledExecutorService scheduledPool)
public ProtonClientConnectionContext(AMQPConnectionCallback connectionCallback, String containerId, int idleTimeout, int maxFrameSize, int channelMax, Executor dispatchExecutor, ScheduledExecutorService scheduledPool)
public void clientOpen(ClientSASL sasl) throws Exception
AMQPClientConnectionContext
clientOpen
in interface AMQPClientConnectionContext
Exception
public AMQPClientSessionContext createClientSession() throws ActiveMQAMQPException
createClientSession
in interface AMQPClientConnectionContext
ActiveMQAMQPException
public void setContainer(String containerID)
setContainer
in interface AMQPClientConnectionContext
protected AbstractProtonSessionContext newSessionExtension(org.apache.qpid.proton.engine.Session realSession) throws ActiveMQAMQPException
newSessionExtension
in class AbstractConnectionContext
ActiveMQAMQPException
protected void remoteLinkOpened(org.apache.qpid.proton.engine.Link link) throws Exception
remoteLinkOpened
in class AbstractConnectionContext
Exception
Copyright © 2016 The Apache Software Foundation. All rights reserved.