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,
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
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 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()
createTempDestination
public ActiveMQDestination createTempDestination(java.lang.String name,
boolean topic)
getCreatedTempDestinationName
public java.lang.String getCreatedTempDestinationName(ActiveMQDestination destination)
getDefaultHeartBeat
public java.lang.String getDefaultHeartBeat()
setDefaultHeartBeat
public void setDefaultHeartBeat(java.lang.String defaultHeartBeat)
configureInactivityMonitor
protected void configureInactivityMonitor(java.lang.String heartBeatConfig)
throws ProtocolException
- Throws:
ProtocolException
sendReceipt
protected void sendReceipt(StompFrame command)
Copyright © 2005-2012. All Rights Reserved.