public abstract class AbstractConnectionContext extends ProtonInitializable implements AMQPConnectionContext
Modifier and Type | Field and Description |
---|---|
static String |
AMQP_CONTAINER_ID |
static org.apache.qpid.proton.amqp.Symbol |
CONNECTION_OPEN_FAILED |
protected AMQPConnectionCallback |
connectionCallback |
protected ProtonHandler |
handler |
protected org.proton.plug.context.AbstractConnectionContext.LocalListener |
listener |
Constructor and Description |
---|
AbstractConnectionContext(AMQPConnectionCallback connectionCallback,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
AbstractConnectionContext(AMQPConnectionCallback connectionCallback,
String containerId,
int idleTimeout,
int maxFrameSize,
int channelMax,
Executor dispatchExecutor,
ScheduledExecutorService scheduledPool) |
Modifier and Type | Method and Description |
---|---|
int |
capacity() |
boolean |
checkDataReceived() |
void |
close() |
void |
destroy() |
void |
flush() |
protected void |
flushBytes() |
long |
getCreationTime() |
Object |
getLock() |
String |
getPubSubPrefix() |
String |
getRemoteContainer() |
SASLResult |
getSASLResult() |
protected AbstractProtonSessionContext |
getSessionExtension(org.apache.qpid.proton.engine.Session realSession) |
void |
inputBuffer(io.netty.buffer.ByteBuf buffer)
This is for the Remoting layer to push bytes on the AMQP Connection
The buffer readerIndex should be at the latest read byte after this method is called
|
boolean |
isSyncOnFlush()
See comment at
AMQPConnectionContext.isSyncOnFlush() |
protected abstract AbstractProtonSessionContext |
newSessionExtension(org.apache.qpid.proton.engine.Session realSession) |
void |
outputDone(int bytes)
To be called when the bytes were sent down the stream (flushed on the socket for example)
|
protected abstract void |
remoteLinkOpened(org.apache.qpid.proton.engine.Link link) |
afterInit, initialise, isInitialized, waitWithTimeout
public static final org.apache.qpid.proton.amqp.Symbol CONNECTION_OPEN_FAILED
public static final String AMQP_CONTAINER_ID
protected final ProtonHandler handler
protected AMQPConnectionCallback connectionCallback
protected org.proton.plug.context.AbstractConnectionContext.LocalListener listener
public AbstractConnectionContext(AMQPConnectionCallback connectionCallback, Executor dispatchExecutor, ScheduledExecutorService scheduledPool)
public AbstractConnectionContext(AMQPConnectionCallback connectionCallback, String containerId, int idleTimeout, int maxFrameSize, int channelMax, Executor dispatchExecutor, ScheduledExecutorService scheduledPool)
public SASLResult getSASLResult()
getSASLResult
in interface AMQPConnectionContext
public void inputBuffer(io.netty.buffer.ByteBuf buffer)
AMQPConnectionContext
inputBuffer
in interface AMQPConnectionContext
public void destroy()
public boolean isSyncOnFlush()
AMQPConnectionContext.isSyncOnFlush()
isSyncOnFlush
in interface AMQPConnectionContext
public Object getLock()
getLock
in interface AMQPConnectionContext
public int capacity()
capacity
in interface AMQPConnectionContext
public void outputDone(int bytes)
AMQPConnectionContext
outputDone
in interface AMQPConnectionContext
public void flush()
flush
in interface AMQPConnectionContext
public void close()
close
in interface AMQPConnectionContext
protected AbstractProtonSessionContext getSessionExtension(org.apache.qpid.proton.engine.Session realSession) throws ActiveMQAMQPException
ActiveMQAMQPException
protected abstract void remoteLinkOpened(org.apache.qpid.proton.engine.Link link) throws Exception
Exception
protected abstract AbstractProtonSessionContext newSessionExtension(org.apache.qpid.proton.engine.Session realSession) throws ActiveMQAMQPException
ActiveMQAMQPException
public boolean checkDataReceived()
checkDataReceived
in interface AMQPConnectionContext
public long getCreationTime()
getCreationTime
in interface AMQPConnectionContext
protected void flushBytes()
public String getRemoteContainer()
public String getPubSubPrefix()
Copyright © 2016 The Apache Software Foundation. All rights reserved.