public class ProtocolConverter extends java.lang.Object
Constructor and Description |
---|
ProtocolConverter(StompTransport stompTransport,
BrokerContext brokerContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkConnected() |
protected void |
configureInactivityMonitor(java.lang.String heartBeatConfig) |
StompFrame |
convertMessage(ActiveMQMessage message,
boolean ignoreTransformation) |
ActiveMQMessage |
convertMessage(StompFrame command) |
protected org.apache.activemq.transport.stomp.ResponseHandler |
createResponseHandler(StompFrame command) |
ActiveMQDestination |
createTempDestination(java.lang.String name,
boolean topic) |
protected FrameTranslator |
findTranslator(java.lang.String header) |
protected int |
generateCommandId() |
java.lang.String |
getCreatedTempDestinationName(ActiveMQDestination destination) |
java.lang.String |
getDefaultHeartBeat() |
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 |
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(java.lang.String defaultHeartBeat) |
public ProtocolConverter(StompTransport stompTransport, 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 onStompNack(StompFrame command) throws ProtocolException
ProtocolException
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 createTempDestination(java.lang.String name, boolean topic)
public java.lang.String getCreatedTempDestinationName(ActiveMQDestination destination)
public java.lang.String getDefaultHeartBeat()
public void setDefaultHeartBeat(java.lang.String defaultHeartBeat)
protected void configureInactivityMonitor(java.lang.String heartBeatConfig) throws ProtocolException
ProtocolException
protected void sendReceipt(StompFrame command)
Copyright © 2005-2017. All Rights Reserved.