|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.io.AbstractWireFormat
Represents a strategy of encoding packets on the wire or on disk using some kind of serialization or wire format.
We use a default efficient format for Java to Java communication but other formats to other systems can be used, such as using simple text strings when talking to JavaScript or coming up with other formats for talking to C / C# languages or proprietary messaging systems we wish to interface with at the wire level etc.
Constructor Summary | |
AbstractWireFormat()
|
Method Summary | |
Packet |
fromBytes(byte[] bytes)
Reads the packet from the given byte[] |
Packet |
fromBytes(byte[] bytes,
int offset,
int length)
Reads the packet from the given byte[] |
void |
initiateProtocol(DataOutput dataOut)
Some wire formats require a handshake at start-up |
Packet |
readPacket(String channelID,
DatagramPacket dpacket)
Read a packet from a Datagram packet from the given channelID. |
byte[] |
toBytes(Packet packet)
A helper method which converts a packet into a byte array |
DatagramPacket |
writePacket(String channelID,
Packet packet)
Writes the given package to a new datagram |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.codehaus.activemq.io.WireFormat |
canProcessWireFormatVersion, copy, getCurrentWireFormatVersion, readPacket, readPacket, writePacket |
Constructor Detail |
public AbstractWireFormat()
Method Detail |
public Packet readPacket(String channelID, DatagramPacket dpacket) throws IOException
readPacket
in interface WireFormat
channelID
- is the unique channel IDdpacket
-
IOException
public DatagramPacket writePacket(String channelID, Packet packet) throws IOException, JMSException
writePacket
in interface WireFormat
channelID
- is the unique channel IDpacket
- is the packet to write
IOException
JMSException
public Packet fromBytes(byte[] bytes, int offset, int length) throws IOException
fromBytes
in interface WireFormat
bytes
- offset
- length
-
IOException
public Packet fromBytes(byte[] bytes) throws IOException
fromBytes
in interface WireFormat
bytes
-
IOException
public byte[] toBytes(Packet packet) throws IOException, JMSException
toBytes
in interface WireFormat
packet
-
IOException
JMSException
public void initiateProtocol(DataOutput dataOut) throws IOException, JMSException
initiateProtocol
in interface WireFormat
dataOut
-
IOException
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |