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)
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
onStompCommad
public void onStompCommad(StompFrame command)
throws IOException,
javax.jms.JMSException
- Convert a stomp command
- Parameters:
command
-
- Throws:
IOException
javax.jms.JMSException
onStompSend
protected void onStompSend(StompFrame command)
throws IOException,
javax.jms.JMSException
- Throws:
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
onActiveMQCommad
public void onActiveMQCommad(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)
throws IOException,
javax.jms.JMSException
- Throws:
IOException
javax.jms.JMSException
getTransportFilter
public StompTransportFilter getTransportFilter()
Copyright © 2011 Apache Software Foundation. All Rights Reserved.