public class ProtocolConverter extends java.lang.Object
Constructor and Description |
---|
ProtocolConverter(StompTransport stompTransport,
FrameTranslator translator,
BrokerContext brokerContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkConnected() |
StompFrame |
convertMessage(ActiveMQMessage message,
boolean ignoreTransformation) |
ActiveMQMessage |
convertMessage(StompFrame command) |
protected org.apache.activemq.transport.stomp.ResponseHandler |
createResponseHandler(StompFrame command) |
ActiveMQDestination |
createTempQueue(java.lang.String name) |
ActiveMQDestination |
createTempTopic(java.lang.String name) |
protected FrameTranslator |
findTranslator(java.lang.String header) |
protected int |
generateCommandId() |
java.lang.String |
getCreatedTempDestinationName(ActiveMQDestination destination) |
StompTransport |
getStompTransport() |
protected void |
handleException(java.lang.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 |
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) |
public ProtocolConverter(StompTransport stompTransport, FrameTranslator translator, BrokerContext brokerContext)
protected int generateCommandId()
protected org.apache.activemq.transport.stomp.ResponseHandler createResponseHandler(StompFrame command)
protected void sendToActiveMQ(Command command, org.apache.activemq.transport.stomp.ResponseHandler handler)
protected void sendToStomp(StompFrame command) throws java.io.IOException
java.io.IOException
protected FrameTranslator findTranslator(java.lang.String header)
public void onStompCommand(StompFrame command) throws java.io.IOException, javax.jms.JMSException
command
- java.io.IOException
javax.jms.JMSException
protected void handleException(java.lang.Throwable exception, StompFrame command) throws java.io.IOException
java.io.IOException
protected void onStompSend(StompFrame command) throws java.io.IOException, javax.jms.JMSException
java.io.IOException
javax.jms.JMSException
protected void onStompAck(StompFrame command) throws ProtocolException
ProtocolException
protected void onStompBegin(StompFrame command) throws ProtocolException
ProtocolException
protected void onStompCommit(StompFrame command) throws ProtocolException
ProtocolException
protected void onStompAbort(StompFrame command) throws ProtocolException
ProtocolException
protected void onStompSubscribe(StompFrame command) throws ProtocolException
ProtocolException
protected void onStompUnsubscribe(StompFrame command) throws ProtocolException
ProtocolException
protected void onStompConnect(StompFrame command) throws ProtocolException
ProtocolException
protected void onStompDisconnect(StompFrame command) throws ProtocolException
ProtocolException
protected void checkConnected() throws ProtocolException
ProtocolException
public void onActiveMQCommand(Command command) throws java.io.IOException, javax.jms.JMSException
command
- java.io.IOException
javax.jms.JMSException
public ActiveMQMessage convertMessage(StompFrame command) throws java.io.IOException, javax.jms.JMSException
java.io.IOException
javax.jms.JMSException
public StompFrame convertMessage(ActiveMQMessage message, boolean ignoreTransformation) throws java.io.IOException, javax.jms.JMSException
java.io.IOException
javax.jms.JMSException
public StompTransport getStompTransport()
public ActiveMQDestination createTempQueue(java.lang.String name)
public ActiveMQDestination createTempTopic(java.lang.String name)
public java.lang.String getCreatedTempDestinationName(ActiveMQDestination destination)
Copyright © 2005-2012. All Rights Reserved.