public class AmqpProtocolDiscriminator extends Object implements AmqpProtocolConverter
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_PREFETCH |
Constructor and Description |
---|
AmqpProtocolDiscriminator(AmqpTransport transport,
BrokerService brokerService) |
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 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.
|
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 static final int DEFAULT_PREFETCH
public AmqpProtocolDiscriminator(AmqpTransport transport, BrokerService brokerService)
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.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.public void updateTracer()
AmqpProtocolConverter
updateTracer
in interface AmqpProtocolConverter
public long keepAlive()
AmqpProtocolConverter
keepAlive
in interface AmqpProtocolConverter
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.