org.apache.activemq.transport.stomp
Class ProtocolConverter

java.lang.Object
  extended by org.apache.activemq.transport.stomp.ProtocolConverter

public class ProtocolConverter
extends java.lang.Object

Author:
chirino

Constructor Summary
ProtocolConverter(StompTransportFilter stompTransportFilter, FrameTranslator translator)
           
 
Method Summary
protected  void checkConnected()
           
 StompFrame convertMessage(ActiveMQMessage message)
           
 ActiveMQMessage convertMessage(StompFrame command)
           
protected  org.apache.activemq.transport.stomp.ResponseHandler createResponseHandler(StompFrame command)
           
protected  int generateCommandId()
           
 StompTransportFilter getTransportFilter()
           
 void onActiveMQCommad(Command command)
          Dispatch a ActiveMQ command
protected  void onStompAbort(StompFrame command)
           
protected  void onStompAck(StompFrame command)
           
protected  void onStompBegin(StompFrame command)
           
 void onStompCommad(StompFrame command)
          Convert a stomp command
protected  void onStompCommit(StompFrame command)
           
protected  void onStompConnect(StompFrame command)
           
protected  void onStompDisconnect(StompFrame command)
           
protected  void onStompSend(StompFrame command)
           
protected  void onStompSubscribe(StompFrame command)
           
protected  void onStompUnsubscribe(StompFrame command)
           
protected  void sendToActiveMQ(Command command, org.apache.activemq.transport.stomp.ResponseHandler handler)
           
protected  void sendToStomp(StompFrame command)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ProtocolConverter

public ProtocolConverter(StompTransportFilter stompTransportFilter,
                         FrameTranslator translator)
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 java.io.IOException
Throws:
java.io.IOException

onStompCommad

public void onStompCommad(StompFrame command)
                   throws java.io.IOException,
                          javax.jms.JMSException
Convert a stomp command

Parameters:
command -
Throws:
java.io.IOException
javax.jms.JMSException

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

onActiveMQCommad

public void onActiveMQCommad(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)
                          throws java.io.IOException,
                                 javax.jms.JMSException
Throws:
java.io.IOException
javax.jms.JMSException

getTransportFilter

public StompTransportFilter getTransportFilter()


Copyright © 2011 Apache Software Foundation. All Rights Reserved.