|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.io.AbstractWireFormat
org.activemq.transport.jabber.JabberWireFormat
A wire format which uses XMPP format of messages
Field Summary |
Fields inherited from class org.activemq.io.AbstractWireFormat |
cachingEnabled, transportDataIn, transportDataOut |
Fields inherited from interface org.activemq.io.WireFormat |
DEFAULT_MAXIMUM_MESSAGE_SIZE |
Constructor Summary | |
JabberWireFormat()
|
Method Summary | |
boolean |
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version |
WireFormat |
copy()
Creates a new copy of this wire format so it can be used in another thread/context |
protected Packet |
createConnectionInfo()
|
protected Packet |
createConsumerPacket()
|
protected ActiveMQDestination |
createDestination(java.lang.String typeName,
java.lang.String text)
|
protected java.lang.String |
encodeBinary(byte[] data,
int offset,
int length)
|
int |
getCurrentWireFormatVersion()
|
java.io.PrintWriter |
getWriter()
|
protected java.lang.String |
getXmppType(ActiveMQMessage message)
|
protected void |
initialize()
|
protected boolean |
readElement(javax.xml.stream.XMLStreamReader reader,
ActiveMQTextMessage message)
|
protected Packet |
readMessage(javax.xml.stream.XMLStreamReader reader)
|
Packet |
readPacket(int firstByte,
java.io.DataInput in)
A helper method for working with sockets where the first byte is read first, then the rest of the message is read. |
void |
readPacket(javax.xml.stream.XMLStreamReader reader,
java.util.List returnPackets)
Reads a packet from the XML stream |
protected java.lang.String |
readXMLAsText(javax.xml.stream.XMLStreamReader reader)
|
void |
setWriter(java.io.PrintWriter writer)
|
protected java.lang.String |
toString(javax.jms.Destination destination)
|
protected void |
writeBytesMessage(ActiveMQBytesMessage message,
java.io.DataOutput out)
|
protected void |
writeEndElement(javax.xml.stream.XMLStreamReader reader)
|
protected void |
writeMessage(ActiveMQMessage message,
java.lang.String body,
java.io.DataOutput out)
|
protected void |
writeObjectMessage(ActiveMQObjectMessage message,
java.io.DataOutput out)
|
Packet |
writePacket(Packet packet,
java.io.DataOutput out)
Writes the packet to the given output stream |
protected void |
writeQName(javax.xml.namespace.QName name)
|
protected void |
writeStartElement(javax.xml.stream.XMLStreamReader reader)
|
protected void |
writeTextMessage(ActiveMQTextMessage message,
java.io.DataOutput out)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public JabberWireFormat()
Method Detail |
public WireFormat copy()
WireFormat
public Packet readPacket(int firstByte, java.io.DataInput in) throws java.io.IOException
WireFormat
firstByte
- the first byte of the packetin
- the rest of the packet
java.io.IOException
public void readPacket(javax.xml.stream.XMLStreamReader reader, java.util.List returnPackets) throws javax.xml.stream.XMLStreamException, javax.jms.JMSException
reader
- returnPackets
-
javax.xml.stream.XMLStreamException
javax.jms.JMSException
public Packet writePacket(Packet packet, java.io.DataOutput out) throws java.io.IOException, javax.jms.JMSException
WireFormat
packet
- out
-
javax.jms.JMSException
java.io.IOException
public boolean canProcessWireFormatVersion(int version)
version
- the version number to test
public int getCurrentWireFormatVersion()
public java.io.PrintWriter getWriter()
public void setWriter(java.io.PrintWriter writer)
protected Packet createConnectionInfo()
protected Packet createConsumerPacket()
protected void initialize() throws java.io.IOException
java.io.IOException
protected Packet readMessage(javax.xml.stream.XMLStreamReader reader) throws javax.xml.stream.XMLStreamException, javax.jms.JMSException
javax.xml.stream.XMLStreamException
javax.jms.JMSException
protected boolean readElement(javax.xml.stream.XMLStreamReader reader, ActiveMQTextMessage message) throws javax.jms.JMSException, javax.xml.stream.XMLStreamException
javax.jms.JMSException
javax.xml.stream.XMLStreamException
protected java.lang.String readXMLAsText(javax.xml.stream.XMLStreamReader reader) throws javax.xml.stream.XMLStreamException
javax.xml.stream.XMLStreamException
protected void writeStartElement(javax.xml.stream.XMLStreamReader reader)
protected void writeEndElement(javax.xml.stream.XMLStreamReader reader)
protected void writeQName(javax.xml.namespace.QName name)
protected ActiveMQDestination createDestination(java.lang.String typeName, java.lang.String text)
protected java.lang.String toString(javax.jms.Destination destination)
protected void writeObjectMessage(ActiveMQObjectMessage message, java.io.DataOutput out) throws javax.jms.JMSException, java.io.IOException
javax.jms.JMSException
java.io.IOException
protected void writeTextMessage(ActiveMQTextMessage message, java.io.DataOutput out) throws javax.jms.JMSException, java.io.IOException
javax.jms.JMSException
java.io.IOException
protected void writeBytesMessage(ActiveMQBytesMessage message, java.io.DataOutput out) throws java.io.IOException
java.io.IOException
protected void writeMessage(ActiveMQMessage message, java.lang.String body, java.io.DataOutput out) throws java.io.IOException
java.io.IOException
protected java.lang.String encodeBinary(byte[] data, int offset, int length)
protected java.lang.String getXmppType(ActiveMQMessage message)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |