org.codehaus.activemq.transport.jabber
Class JabberWireFormat

java.lang.Object
  extended byorg.codehaus.activemq.io.AbstractWireFormat
      extended byorg.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 $

Constructor Summary
JabberWireFormat()
           
 
Method Summary
 boolean canProcessWireFormatVersion(int version)
          Can this wireformat process packets of this version
 org.codehaus.activemq.io.WireFormat copy()
           
protected  String encodeBinary(byte[] data)
           
 int getCurrentWireFormatVersion()
           
protected  String getXmppType(org.codehaus.activemq.message.ActiveMQMessage message)
           
 org.codehaus.activemq.message.Packet readPacket(DataInput in)
           
 org.codehaus.activemq.message.Packet readPacket(int firstByte, DataInput in)
           
protected  void writeBytesMessage(org.codehaus.activemq.message.ActiveMQBytesMessage message, DataOutput out)
           
protected  void writeMessage(org.codehaus.activemq.message.ActiveMQMessage message, String body, DataOutput out)
           
protected  void writeObjectMessage(org.codehaus.activemq.message.ActiveMQObjectMessage message, DataOutput out)
           
 void writePacket(org.codehaus.activemq.message.Packet packet, DataOutput out)
           
protected  void writeTextMessage(org.codehaus.activemq.message.ActiveMQTextMessage message, DataOutput out)
           
 
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
 

Constructor Detail

JabberWireFormat

public JabberWireFormat()
Method Detail

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.