public class ProtonServerConnectionContext extends AbstractConnectionContext implements AMQPServerConnectionContext
AMQP_CONTAINER_ID, CONNECTION_OPEN_FAILED, connectionCallback, handler, listener
Constructor and Description |
---|
ProtonServerConnectionContext(AMQPConnectionCallback connectionSP,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
ProtonServerConnectionContext(AMQPConnectionCallback connectionSP,
String containerId,
int idleTimeout,
int maxFrameSize,
int channelMax,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
Modifier and Type | Method and Description |
---|---|
protected AbstractProtonSessionContext |
newSessionExtension(org.apache.qpid.proton.engine.Session realSession) |
protected void |
remoteLinkOpened(org.apache.qpid.proton.engine.Link link) |
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 ProtonServerConnectionContext(AMQPConnectionCallback connectionSP, Executor dispatchExecutor, ScheduledExecutorService scheduledPool)
public ProtonServerConnectionContext(AMQPConnectionCallback connectionSP, String containerId, int idleTimeout, int maxFrameSize, int channelMax, Executor dispatchExecutor, ScheduledExecutorService scheduledPool)
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.