org.apache.activemq.transport.stomp
Class JmsFrameTranslator
java.lang.Object
org.apache.activemq.transport.stomp.LegacyFrameTranslator
org.apache.activemq.transport.stomp.JmsFrameTranslator
- All Implemented Interfaces:
- BrokerContextAware, FrameTranslator
public class JmsFrameTranslator
- extends LegacyFrameTranslator
- implements BrokerContextAware
Frame translator implementation that uses XStream to convert messages to and
from XML and JSON
- Author:
- Dejan Bosanac
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JmsFrameTranslator
public JmsFrameTranslator()
convertFrame
public ActiveMQMessage convertFrame(ProtocolConverter converter,
StompFrame command)
throws javax.jms.JMSException,
ProtocolException
- Specified by:
convertFrame
in interface FrameTranslator
- Overrides:
convertFrame
in class LegacyFrameTranslator
- Throws:
javax.jms.JMSException
ProtocolException
convertMessage
public StompFrame convertMessage(ProtocolConverter converter,
ActiveMQMessage message)
throws java.io.IOException,
javax.jms.JMSException
- Specified by:
convertMessage
in interface FrameTranslator
- Overrides:
convertMessage
in class LegacyFrameTranslator
- Throws:
java.io.IOException
javax.jms.JMSException
marshall
protected java.lang.String marshall(java.io.Serializable object,
java.lang.String transformation)
throws javax.jms.JMSException
- Marshalls the Object to a string using XML or JSON encoding
- Throws:
javax.jms.JMSException
createObjectMessage
protected ActiveMQObjectMessage createObjectMessage(com.thoughtworks.xstream.io.HierarchicalStreamReader in)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
createMapMessage
protected ActiveMQMapMessage createMapMessage(com.thoughtworks.xstream.io.HierarchicalStreamReader in)
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
marshallAdvisory
protected java.lang.String marshallAdvisory(DataStructure ds,
java.lang.String transformation)
getXStream
public XStream getXStream()
setXStream
public void setXStream(XStream xStream)
createXStream
protected XStream createXStream()
setBrokerContext
public void setBrokerContext(BrokerContext brokerContext)
- Specified by:
setBrokerContext
in interface BrokerContextAware
Copyright © 2005-2016. All Rights Reserved.