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 |
org.apache.activemq.command.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(org.apache.activemq.command.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 porcessing.
|
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 heatbeats to the wire.public int getConfiguredReceiverCredit()
public String getConfiguredTransformer()
public org.apache.activemq.command.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(org.apache.activemq.command.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–2017 FuseSource, Corp.. All rights reserved.