org.apache.activemq.transport.stomp
Class ProtocolConverter
java.lang.Object
org.apache.activemq.transport.stomp.ProtocolConverter
public class ProtocolConverter
- extends java.lang.Object
- Author:
- chirino
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ProtocolConverter
public ProtocolConverter(StompTransport stompTransport,
FrameTranslator translator,
BrokerContext brokerContext)
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 java.io.IOException
- Throws:
java.io.IOException
findTranslator
protected FrameTranslator findTranslator(java.lang.String header)
onStompCommand
public void onStompCommand(StompFrame command)
throws java.io.IOException,
javax.jms.JMSException
- Convert a stomp command
- Parameters:
command
-
- Throws:
java.io.IOException
javax.jms.JMSException
handleException
protected void handleException(java.lang.Throwable exception,
StompFrame command)
throws java.io.IOException
- Throws:
java.io.IOException
onStompSend
protected void onStompSend(StompFrame command)
throws java.io.IOException,
javax.jms.JMSException
- Throws:
java.io.IOException
javax.jms.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 java.io.IOException,
javax.jms.JMSException
- Dispatch a ActiveMQ command
- Parameters:
command
-
- Throws:
java.io.IOException
javax.jms.JMSException
convertMessage
public ActiveMQMessage convertMessage(StompFrame command)
throws java.io.IOException,
javax.jms.JMSException
- Throws:
java.io.IOException
javax.jms.JMSException
convertMessage
public StompFrame convertMessage(ActiveMQMessage message,
boolean ignoreTransformation)
throws java.io.IOException,
javax.jms.JMSException
- Throws:
java.io.IOException
javax.jms.JMSException
getStompTransport
public StompTransport getStompTransport()
createTempQueue
public ActiveMQDestination createTempQueue(java.lang.String name)
createTempTopic
public ActiveMQDestination createTempTopic(java.lang.String name)
getCreatedTempDestinationName
public java.lang.String getCreatedTempDestinationName(ActiveMQDestination destination)
Copyright © 2005-2011. All Rights Reserved.