org.apache.activemq.transport.stomp

Class ProtocolConverter

java.lang.Object

org.apache.activemq.transport.stomp.ProtocolConverter

public class ProtocolConverter
extends Object

Author:

chirino

Constructor Summary

Constructors

Constructor and Description
ProtocolConverter(StompTransport stompTransport, BrokerContext brokerContext)

Method Summary

Modifier and Type	Method and Description
protected void	afterClientAck(StompSubscription subscription, ArrayList<String> msgIdsToRemove) Remove all pending acknowledgement markers that are batched into the single client acknowledge operation.
protected void	checkConnected()
protected void	configureInactivityMonitor(String heartBeatConfig)
StompFrame	convertMessage(ActiveMQMessage message, boolean ignoreTransformation)
ActiveMQMessage	convertMessage(StompFrame command)
protected org.apache.activemq.transport.stomp.ResponseHandler	createResponseHandler(StompFrame command)
ActiveMQDestination	createTempDestination(String name, boolean topic)
protected FrameTranslator	findTranslator(String header)
protected FrameTranslator	findTranslator(String header, ActiveMQDestination destination, boolean advisory)
protected int	generateCommandId()
String	getCreatedTempDestinationName(ActiveMQDestination destination)
String	getDefaultHeartBeat()
float	getHbGracePeriodMultiplier()
StompTransport	getStompTransport()
protected void	handleException(Throwable exception, StompFrame command)
void	onActiveMQCommand(Command command) Dispatch a ActiveMQ command
protected void	onStompAbort(StompFrame command)
protected void	onStompAck(StompFrame command)
protected void	onStompBegin(StompFrame command)
void	onStompCommand(StompFrame command) Convert a STOMP command
protected void	onStompCommit(StompFrame command)
protected void	onStompConnect(StompFrame command)
protected void	onStompDisconnect(StompFrame command)
protected void	onStompNack(StompFrame command)
protected void	onStompSend(StompFrame command)
protected void	onStompSubscribe(StompFrame command)
protected void	onStompUnsubscribe(StompFrame command)
protected Object	safeGetAction(StompFrame command) Retrieve the STOMP action value from a frame if the value is valid, otherwise return an unknown string to allow for safe log output.
protected void	sendReceipt(StompFrame command)
protected void	sendToActiveMQ(Command command, org.apache.activemq.transport.stomp.ResponseHandler handler)
protected void	sendToStomp(StompFrame command)
void	setDefaultHeartBeat(String defaultHeartBeat)
void	setHbGracePeriodMultiplier(float hbGracePeriodMultiplier)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProtocolConverter

public ProtocolConverter(StompTransport stompTransport,
                         BrokerContext brokerContext)

Method Detail

generateCommandId

protected int generateCommandId()

createResponseHandler

protected org.apache.activemq.transport.stomp.ResponseHandler createResponseHandler(StompFrame command)

sendToActiveMQ

protected void sendToActiveMQ(Command command,
                              org.apache.activemq.transport.stomp.ResponseHandler handler)

sendToStomp

protected void sendToStomp(StompFrame command)
                    throws IOException

Throws:

IOException

findTranslator

protected FrameTranslator findTranslator(String header)

findTranslator

protected FrameTranslator findTranslator(String header,
                                         ActiveMQDestination destination,
                                         boolean advisory)

onStompCommand

public void onStompCommand(StompFrame command)
                    throws IOException,
                           javax.jms.JMSException

Convert a STOMP command

Parameters:

command -

Throws:

IOException

javax.jms.JMSException

handleException

protected void handleException(Throwable exception,
                               StompFrame command)
                        throws IOException

Throws:

IOException

onStompSend

protected void onStompSend(StompFrame command)
                    throws IOException,
                           javax.jms.JMSException

Throws:

IOException

javax.jms.JMSException

onStompNack

protected void onStompNack(StompFrame command)
                    throws ProtocolException

Throws:

ProtocolException

onStompAck

protected void onStompAck(StompFrame command)
                   throws ProtocolException

Throws:

ProtocolException

onStompBegin

protected void onStompBegin(StompFrame command)
                     throws ProtocolException

Throws:

ProtocolException

onStompCommit

protected void onStompCommit(StompFrame command)
                      throws ProtocolException

Throws:

ProtocolException

onStompAbort

protected void onStompAbort(StompFrame command)
                     throws ProtocolException

Throws:

ProtocolException

onStompSubscribe

protected void onStompSubscribe(StompFrame command)
                         throws ProtocolException

Throws:

ProtocolException

onStompUnsubscribe

protected void onStompUnsubscribe(StompFrame command)
                           throws ProtocolException

Throws:

ProtocolException

onStompConnect

protected void onStompConnect(StompFrame command)
                       throws ProtocolException

Throws:

ProtocolException

onStompDisconnect

protected void onStompDisconnect(StompFrame command)
                          throws ProtocolException

Throws:

ProtocolException

checkConnected

protected void checkConnected()
                       throws ProtocolException

Throws:

ProtocolException

onActiveMQCommand

public void onActiveMQCommand(Command command)
                       throws IOException,
                              javax.jms.JMSException

Dispatch a ActiveMQ command

Parameters:

command -

Throws:

IOException

javax.jms.JMSException

convertMessage

public ActiveMQMessage convertMessage(StompFrame command)
                               throws IOException,
                                      javax.jms.JMSException

Throws:

IOException

javax.jms.JMSException

convertMessage

public StompFrame convertMessage(ActiveMQMessage message,
                                 boolean ignoreTransformation)
                          throws IOException,
                                 javax.jms.JMSException

Throws:

IOException

javax.jms.JMSException

getStompTransport

public StompTransport getStompTransport()

createTempDestination

public ActiveMQDestination createTempDestination(String name,
                                                 boolean topic)

getCreatedTempDestinationName

public String getCreatedTempDestinationName(ActiveMQDestination destination)

getDefaultHeartBeat

public String getDefaultHeartBeat()

setDefaultHeartBeat

public void setDefaultHeartBeat(String defaultHeartBeat)

getHbGracePeriodMultiplier

public float getHbGracePeriodMultiplier()

Returns:

the hbGracePeriodMultiplier

setHbGracePeriodMultiplier

public void setHbGracePeriodMultiplier(float hbGracePeriodMultiplier)

Parameters:

hbGracePeriodMultiplier - the hbGracePeriodMultiplier to set

configureInactivityMonitor

protected void configureInactivityMonitor(String heartBeatConfig)
                                   throws ProtocolException

Throws:

ProtocolException

sendReceipt

protected void sendReceipt(StompFrame command)

safeGetAction

protected Object safeGetAction(StompFrame command)

Retrieve the STOMP action value from a frame if the value is valid, otherwise return an unknown string to allow for safe log output.

Parameters:

command - The STOMP command to fetch an action from.

Returns:

the command action or a safe string to use in logging.

afterClientAck

protected void afterClientAck(StompSubscription subscription,
                              ArrayList<String> msgIdsToRemove)

Remove all pending acknowledgement markers that are batched into the single client acknowledge operation.

Parameters:

subscription - The STOMP Subscription that has performed a client acknowledge.

msgIdsToRemove - List of message IDs that are bound to the subscription that has ack'd