org.apache.activemq.transport.stomp
Class ProtocolConverter

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

public class ProtocolConverter
extends Object

Author:
chirino

Constructor Summary
ProtocolConverter(StompTransport stompTransport, BrokerContext brokerContext)
           
 
Method Summary
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  int generateCommandId()
           
 String getCreatedTempDestinationName(ActiveMQDestination destination)
           
 String getDefaultHeartBeat()
           
 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  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)
           
 
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)

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

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,
                              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

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)

configureInactivityMonitor

protected void configureInactivityMonitor(String heartBeatConfig)
                                   throws ProtocolException
Throws:
ProtocolException

sendReceipt

protected void sendReceipt(StompFrame command)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.