org.codehaus.activemq.transport.jabber
Class JabberWireFormat
java.lang.Object
org.codehaus.activemq.io.AbstractWireFormat
org.codehaus.activemq.transport.jabber.JabberWireFormat
- All Implemented Interfaces:
- org.codehaus.activemq.io.WireFormat
- public class JabberWireFormat
- extends org.codehaus.activemq.io.AbstractWireFormat
A wire format which uses XMPP format of messages
- Version:
- $Revision: 1.2 $
Methods inherited from class org.codehaus.activemq.io.AbstractWireFormat |
fromBytes, fromBytes, initiateProtocol, readPacket, toBytes, writePacket |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JabberWireFormat
public JabberWireFormat()
copy
public org.codehaus.activemq.io.WireFormat copy()
readPacket
public org.codehaus.activemq.message.Packet readPacket(DataInput in)
throws IOException
- Throws:
IOException
readPacket
public org.codehaus.activemq.message.Packet readPacket(int firstByte,
DataInput in)
throws IOException
- Throws:
IOException
writePacket
public void writePacket(org.codehaus.activemq.message.Packet packet,
DataOutput out)
throws IOException,
JMSException
- Throws:
IOException
JMSException
canProcessWireFormatVersion
public boolean canProcessWireFormatVersion(int version)
- Can this wireformat process packets of this version
- Parameters:
version
- the version number to test
- Returns:
- true if can accept the version
getCurrentWireFormatVersion
public int getCurrentWireFormatVersion()
- Returns:
- the current version of this wire format
writeObjectMessage
protected void writeObjectMessage(org.codehaus.activemq.message.ActiveMQObjectMessage message,
DataOutput out)
throws JMSException,
IOException
- Throws:
JMSException
IOException
writeTextMessage
protected void writeTextMessage(org.codehaus.activemq.message.ActiveMQTextMessage message,
DataOutput out)
throws JMSException,
IOException
- Throws:
JMSException
IOException
writeBytesMessage
protected void writeBytesMessage(org.codehaus.activemq.message.ActiveMQBytesMessage message,
DataOutput out)
throws IOException
- Throws:
IOException
writeMessage
protected void writeMessage(org.codehaus.activemq.message.ActiveMQMessage message,
String body,
DataOutput out)
throws IOException
- Throws:
IOException
encodeBinary
protected String encodeBinary(byte[] data)
getXmppType
protected String getXmppType(org.codehaus.activemq.message.ActiveMQMessage message)
Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.