org.apache.activemq.transport.stomp
Class ProtocolConverter
java.lang.Object
org.apache.activemq.transport.stomp.ProtocolConverter
public class ProtocolConverter
- extends Object
- Author:
- chirino
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ProtocolConverter
public ProtocolConverter(StompTransportFilter stompTransportFilter,
FrameTranslator translator,
org.springframework.context.ApplicationContext applicationContext)
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)
onStompCommand
public void onStompCommand(StompFrame command)
throws IOException,
JMSException
- Convert a stomp command
- Parameters:
command
-
- Throws:
IOException
JMSException
handleException
protected void handleException(Throwable exception,
StompFrame command)
throws IOException
- Throws:
IOException
onStompSend
protected void onStompSend(StompFrame command)
throws IOException,
JMSException
- Throws:
IOException
JMSException
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,
JMSException
- Dispatch a ActiveMQ command
- Parameters:
command
-
- Throws:
IOException
JMSException
convertMessage
public ActiveMQMessage convertMessage(StompFrame command)
throws IOException,
JMSException
- Throws:
IOException
JMSException
convertMessage
public StompFrame convertMessage(ActiveMQMessage message,
boolean ignoreTransformation)
throws IOException,
JMSException
- Throws:
IOException
JMSException
getTransportFilter
public StompTransportFilter getTransportFilter()
createTempQueue
public ActiveMQDestination createTempQueue(String name)
createTempTopic
public ActiveMQDestination createTempTopic(String name)
getCreatedTempDestinationName
public String getCreatedTempDestinationName(ActiveMQDestination destination)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.