|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.message.WireFormat
org.codehaus.activemq.transport.jabber.JabberWireFormat
A wire format which uses XMPP format of messages
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 String |
encodeBinary(byte[] data)
|
int |
getCurrentWireFormatVersion()
|
protected String |
getXmppType(ActiveMQMessage message)
|
Packet |
readPacket(DataInput in)
Reads a packet from the given input stream |
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. |
protected void |
writeBytesMessage(ActiveMQBytesMessage message,
DataOutput out)
|
protected void |
writeMessage(ActiveMQMessage message,
String body,
DataOutput out)
|
protected void |
writeObjectMessage(ActiveMQObjectMessage message,
DataOutput out)
|
void |
writePacket(Packet packet,
DataOutput out)
Writes the packet to the given output stream |
protected void |
writeTextMessage(ActiveMQTextMessage message,
DataOutput out)
|
Methods inherited from class org.codehaus.activemq.message.WireFormat |
fromBytes, fromBytes, readPacket, toBytes, writePacket |
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
copy
in class WireFormat
public Packet readPacket(DataInput in) throws IOException
WireFormat
readPacket
in class WireFormat
in
-
IOException
public Packet readPacket(int firstByte, DataInput in) throws IOException
WireFormat
readPacket
in class WireFormat
firstByte
- the first byte of the packetin
- the rest of the packet
IOException
public void writePacket(Packet packet, DataOutput out) throws IOException, JMSException
WireFormat
writePacket
in class WireFormat
packet
- out
-
IOException
JMSException
public boolean canProcessWireFormatVersion(int version)
canProcessWireFormatVersion
in class WireFormat
version
- the version number to test
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion
in class WireFormat
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)
protected String getXmppType(ActiveMQMessage message)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |