public interface AmqpProtocolConverter
Modifier and Type | Method and Description |
---|---|
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 data)
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.
|
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.
|
void onAMQPData(Object data) throws Exception
data
- the next incoming data object from the remote peer.Exception
- if an error occurs processing the incoming data packet.void onAMQPException(IOException error)
error
- the error that triggered this call.void onActiveMQCommand(org.apache.activemq.command.Command command) throws Exception
command
- the next incoming command from the broker.Exception
- if an error occurs processing the command.void updateTracer()
long keepAlive() throws IOException
IOException
- if an error occurs on writing heatbeats to the wire.Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.