|
||||||||||
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
public class 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(String typeName,
String text)
|
protected String |
encodeBinary(byte[] data,
int offset,
int length)
|
int |
getCurrentWireFormatVersion()
|
PrintWriter |
getWriter()
|
protected 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,
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,
List returnPackets)
Reads a packet from the XML stream |
protected String |
readXMLAsText(javax.xml.stream.XMLStreamReader reader)
|
void |
setWriter(PrintWriter writer)
|
protected String |
toString(Destination destination)
|
protected void |
writeBytesMessage(ActiveMQBytesMessage message,
DataOutput out)
|
protected void |
writeEndElement(javax.xml.stream.XMLStreamReader reader)
|
protected void |
writeMessage(ActiveMQMessage message,
String body,
DataOutput out)
|
protected void |
writeObjectMessage(ActiveMQObjectMessage message,
DataOutput out)
|
Packet |
writePacket(Packet packet,
DataOutput out)
Writes the packet to the given output stream |
protected void |
writeQName(QName name)
|
protected void |
writeStartElement(javax.xml.stream.XMLStreamReader reader)
|
protected void |
writeTextMessage(ActiveMQTextMessage message,
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, DataInput in) throws IOException
WireFormat
firstByte
- the first byte of the packetin
- the rest of the packet
IOException
public void readPacket(javax.xml.stream.XMLStreamReader reader, List returnPackets) throws javax.xml.stream.XMLStreamException, JMSException
reader
- returnPackets
-
javax.xml.stream.XMLStreamException
JMSException
public Packet writePacket(Packet packet, DataOutput out) throws IOException, JMSException
WireFormat
IOException
JMSException
public boolean canProcessWireFormatVersion(int version)
version
- the version number to test
public int getCurrentWireFormatVersion()
public PrintWriter getWriter()
public void setWriter(PrintWriter writer)
protected Packet createConnectionInfo()
protected Packet createConsumerPacket()
protected void initialize() throws IOException
IOException
protected Packet readMessage(javax.xml.stream.XMLStreamReader reader) throws javax.xml.stream.XMLStreamException, JMSException
javax.xml.stream.XMLStreamException
JMSException
protected boolean readElement(javax.xml.stream.XMLStreamReader reader, ActiveMQTextMessage message) throws JMSException, javax.xml.stream.XMLStreamException
JMSException
javax.xml.stream.XMLStreamException
protected 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(QName name)
protected ActiveMQDestination createDestination(String typeName, String text)
protected String toString(Destination destination)
protected void writeObjectMessage(ActiveMQObjectMessage message, DataOutput out) throws JMSException, IOException
JMSException
IOException
protected void writeTextMessage(ActiveMQTextMessage message, DataOutput out) throws JMSException, IOException
JMSException
IOException
protected void writeBytesMessage(ActiveMQBytesMessage message, DataOutput out) throws IOException
IOException
protected void writeMessage(ActiveMQMessage message, String body, DataOutput out) throws IOException
IOException
protected String encodeBinary(byte[] data, int offset, int length)
protected String getXmppType(ActiveMQMessage message)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |