public class AmqpConnection extends Object implements AmqpProtocolConverter
Constructor and Description |
---|
AmqpConnection(AmqpTransport transport,
BrokerService brokerService) |
Modifier and Type | Method and Description |
---|---|
String |
getClientId() |
int |
getConfiguredReceiverCredit() |
String |
getConfiguredTransformer() |
protected org.apache.qpid.proton.amqp.Symbol[] |
getConnectionCapabilitiesOffered()
Load and return a
[]Symbol that contains the connection capabilities
offered to new connections |
ConnectionId |
getConnectionId() |
protected Map<org.apache.qpid.proton.amqp.Symbol,Object> |
getConnetionProperties()
Load and return a
Map that contains the properties
that this connection supplies to incoming connections. |
protected Map<org.apache.qpid.proton.amqp.Symbol,Object> |
getFailedConnetionProperties()
Load and return a
Map that contains the properties
that this connection supplies to incoming connections when the open has failed
and the remote should expect a close to follow. |
long |
getMaxFrameSize() |
long |
keepAlive()
Perform any keep alive processing for the connection such as sending
empty frames or closing connections due to remote end being inactive
for to long.
|
void |
onActiveMQCommand(Command command)
Incoming Command object from ActiveMQ.
|
void |
onAMQPData(Object command)
A new incoming data packet from the remote peer is handed off to the
protocol converter for processing.
|
void |
onAMQPException(IOException error)
Called when the transport detects an exception that the converter
needs to respond to.
|
protected void |
processConnectionClose(org.apache.qpid.proton.engine.Connection connection) |
protected void |
processConnectionOpen(org.apache.qpid.proton.engine.Connection connection) |
protected void |
processDelivery(org.apache.qpid.proton.engine.Delivery delivery) |
protected void |
processLinkClose(org.apache.qpid.proton.engine.Link link) |
protected void |
processLinkDetach(org.apache.qpid.proton.engine.Link link) |
protected void |
processLinkFlow(org.apache.qpid.proton.engine.Link link) |
protected void |
processLinkOpen(org.apache.qpid.proton.engine.Link link) |
protected void |
processSessionClose(org.apache.qpid.proton.engine.Session protonSession) |
protected void |
processSessionOpen(org.apache.qpid.proton.engine.Session protonSession) |
void |
updateTracer()
On changes to the transport tracing options the Protocol Converter
should update its internal state so that the proper AMQP data is
logged.
|
public AmqpConnection(AmqpTransport transport, BrokerService brokerService)
protected org.apache.qpid.proton.amqp.Symbol[] getConnectionCapabilitiesOffered()
[]Symbol
that contains the connection capabilities
offered to new connectionsprotected Map<org.apache.qpid.proton.amqp.Symbol,Object> getConnetionProperties()
Map
that contains the properties
that this connection supplies to incoming connections.protected Map<org.apache.qpid.proton.amqp.Symbol,Object> getFailedConnetionProperties()
Map
that contains the properties
that this connection supplies to incoming connections when the open has failed
and the remote should expect a close to follow.public void updateTracer()
AmqpProtocolConverter
updateTracer
in interface AmqpProtocolConverter
public long keepAlive() throws IOException
AmqpProtocolConverter
keepAlive
in interface AmqpProtocolConverter
IOException
- if an error occurs on writing heart-beats to the wire.public int getConfiguredReceiverCredit()
public String getConfiguredTransformer()
public ConnectionId getConnectionId()
public String getClientId()
public long getMaxFrameSize()
public void onAMQPData(Object command) throws Exception
AmqpProtocolConverter
onAMQPData
in interface AmqpProtocolConverter
command
- the next incoming data object from the remote peer.Exception
- if an error occurs processing the incoming data packet.protected void processConnectionOpen(org.apache.qpid.proton.engine.Connection connection) throws Exception
Exception
protected void processConnectionClose(org.apache.qpid.proton.engine.Connection connection) throws Exception
Exception
protected void processSessionOpen(org.apache.qpid.proton.engine.Session protonSession) throws Exception
Exception
protected void processSessionClose(org.apache.qpid.proton.engine.Session protonSession) throws Exception
Exception
protected void processLinkOpen(org.apache.qpid.proton.engine.Link link) throws Exception
Exception
protected void processLinkDetach(org.apache.qpid.proton.engine.Link link) throws Exception
Exception
protected void processLinkClose(org.apache.qpid.proton.engine.Link link) throws Exception
Exception
protected void processLinkFlow(org.apache.qpid.proton.engine.Link link) throws Exception
Exception
protected void processDelivery(org.apache.qpid.proton.engine.Delivery delivery) throws Exception
Exception
public void onAMQPException(IOException error)
AmqpProtocolConverter
onAMQPException
in interface AmqpProtocolConverter
error
- the error that triggered this call.public void onActiveMQCommand(Command command) throws Exception
AmqpProtocolConverter
onActiveMQCommand
in interface AmqpProtocolConverter
command
- the next incoming command from the broker.Exception
- if an error occurs processing the command.Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.