Package | Description |
---|---|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.openwire | |
org.apache.activemq.openwire.v1 | |
org.apache.activemq.openwire.v10 | |
org.apache.activemq.openwire.v9 | |
org.apache.activemq.util | |
org.apache.activemq.wireformat |
An API for WireFormats which are used to turn object into bytes and bytes into objects.
|
Modifier and Type | Field and Description |
---|---|
protected ByteSequence |
Message.content |
protected ByteSequence |
Message.marshalledProperties |
protected ByteSequence |
WireFormatInfo.marshalledProperties |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
WireFormatInfo.getCachedMarshalledForm(WireFormat wireFormat) |
ByteSequence |
Message.getContent() |
ByteSequence |
Message.getMarshalledProperties() |
ByteSequence |
WireFormatInfo.getMarshalledProperties() |
Modifier and Type | Method and Description |
---|---|
protected byte[] |
ActiveMQBytesMessage.decompress(ByteSequence dataSequence) |
void |
WireFormatInfo.setCachedMarshalledForm(WireFormat wireFormat,
ByteSequence data) |
void |
Message.setContent(ByteSequence content) |
void |
Message.setMarshalledProperties(ByteSequence marshalledProperties) |
void |
WireFormatInfo.setMarshalledProperties(ByteSequence marshalledProperties) |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
OpenWireFormat.marshal(Object command) |
Modifier and Type | Method and Description |
---|---|
Object |
OpenWireFormat.unmarshal(ByteSequence sequence) |
Modifier and Type | Method and Description |
---|---|
protected ByteSequence |
BaseDataStreamMarshaller.looseUnmarshalByteSequence(DataInput dataIn) |
protected ByteSequence |
BaseDataStreamMarshaller.tightUnmarshalByteSequence(DataInput dataIn,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseDataStreamMarshaller.looseMarshalByteSequence(OpenWireFormat wireFormat,
ByteSequence data,
DataOutput dataOut) |
protected int |
BaseDataStreamMarshaller.tightMarshalByteSequence1(ByteSequence data,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalByteSequence2(ByteSequence data,
DataOutput dataOut,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
protected ByteSequence |
BaseDataStreamMarshaller.looseUnmarshalByteSequence(DataInput dataIn) |
protected ByteSequence |
BaseDataStreamMarshaller.tightUnmarshalByteSequence(DataInput dataIn,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseDataStreamMarshaller.looseMarshalByteSequence(OpenWireFormat wireFormat,
ByteSequence data,
DataOutput dataOut) |
protected int |
BaseDataStreamMarshaller.tightMarshalByteSequence1(ByteSequence data,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalByteSequence2(ByteSequence data,
DataOutput dataOut,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
protected ByteSequence |
BaseDataStreamMarshaller.looseUnmarshalByteSequence(DataInput dataIn) |
protected ByteSequence |
BaseDataStreamMarshaller.tightUnmarshalByteSequence(DataInput dataIn,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseDataStreamMarshaller.looseMarshalByteSequence(OpenWireFormat wireFormat,
ByteSequence data,
DataOutput dataOut) |
protected int |
BaseDataStreamMarshaller.tightMarshalByteSequence1(ByteSequence data,
BooleanStream bs) |
protected void |
BaseDataStreamMarshaller.tightMarshalByteSequence2(ByteSequence data,
DataOutput dataOut,
BooleanStream bs) |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
DataByteArrayOutputStream.toByteSequence()
Get a ByteSequence from the stream
|
ByteSequence |
ByteArrayOutputStream.toByteSequence() |
Modifier and Type | Method and Description |
---|---|
int |
ByteSequence.indexOf(ByteSequence needle,
int pos) |
static int |
ByteSequenceData.read(ByteSequence packet) |
static boolean |
ByteSequenceData.readBoolean(ByteSequence packet) |
static byte |
ByteSequenceData.readByte(ByteSequence packet) |
static char |
ByteSequenceData.readCharBig(ByteSequence packet) |
static char |
ByteSequenceData.readCharLittle(ByteSequence packet) |
static double |
ByteSequenceData.readDoubleBig(ByteSequence packet) |
static double |
ByteSequenceData.readDoubleLittle(ByteSequence packet) |
static float |
ByteSequenceData.readFloatBig(ByteSequence packet) |
static float |
ByteSequenceData.readFloatLittle(ByteSequence packet) |
static void |
ByteSequenceData.readFully(ByteSequence packet,
byte[] b) |
static void |
ByteSequenceData.readFully(ByteSequence packet,
byte[] b,
int off,
int len) |
static int |
ByteSequenceData.readIntBig(ByteSequence packet) |
static int |
ByteSequenceData.readIntLittle(ByteSequence packet) |
static long |
ByteSequenceData.readLongBig(ByteSequence packet) |
static long |
ByteSequenceData.readLongLittle(ByteSequence packet) |
static short |
ByteSequenceData.readShortBig(ByteSequence packet) |
static short |
ByteSequenceData.readShortLittle(ByteSequence packet) |
static int |
ByteSequenceData.readUnsignedByte(ByteSequence packet) |
static int |
ByteSequenceData.readUnsignedShortBig(ByteSequence packet) |
static int |
ByteSequenceData.readUnsignedShortLittle(ByteSequence packet) |
static int |
ByteSequenceData.remaining(ByteSequence packet) |
void |
DataByteArrayInputStream.restart(ByteSequence sequence)
reset the
StoreByteArrayInputStream to use an new
ByteSequence |
static int |
ByteSequenceData.skipBytes(ByteSequence packet,
int n) |
static byte[] |
ByteSequenceData.toByteArray(ByteSequence packet) |
static void |
ByteSequenceData.write(ByteSequence packet,
byte[] b) |
static void |
ByteSequenceData.write(ByteSequence packet,
byte[] b,
int off,
int len) |
static void |
ByteSequenceData.write(ByteSequence packet,
int b) |
static void |
ByteSequenceData.writeBoolean(ByteSequence packet,
boolean v) |
static void |
ByteSequenceData.writeByte(ByteSequence packet,
int v) |
static void |
ByteSequenceData.writeCharBig(ByteSequence packet,
int v) |
static void |
ByteSequenceData.writeCharLittle(ByteSequence packet,
int v) |
static void |
ByteSequenceData.writeDoubleBig(ByteSequence packet,
double v) |
static void |
ByteSequenceData.writeDoubleLittle(ByteSequence packet,
double v) |
static void |
ByteSequenceData.writeFloatBig(ByteSequence packet,
float v) |
static void |
ByteSequenceData.writeFloatLittle(ByteSequence packet,
float v) |
static void |
ByteSequenceData.writeIntBig(ByteSequence packet,
int v) |
static void |
ByteSequenceData.writeIntLittle(ByteSequence packet,
int v) |
static void |
ByteSequenceData.writeLongBig(ByteSequence packet,
long v) |
static void |
ByteSequenceData.writeLongLittle(ByteSequence packet,
long v) |
static void |
ByteSequenceData.writeRawDoubleBig(ByteSequence packet,
double v) |
static void |
ByteSequenceData.writeRawDoubleLittle(ByteSequence packet,
double v) |
static void |
ByteSequenceData.writeRawFloatBig(ByteSequence packet,
float v) |
static void |
ByteSequenceData.writeRawFloatLittle(ByteSequence packet,
float v) |
static void |
ByteSequenceData.writeShortBig(ByteSequence packet,
int v) |
static void |
ByteSequenceData.writeShortLittle(ByteSequence packet,
int v) |
Constructor and Description |
---|
ByteArrayInputStream(ByteSequence sequence) |
DataByteArrayInputStream(ByteSequence sequence)
Creates a
StoreByteArrayInputStream . |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
WireFormat.marshal(Object command)
Packet based marshaling
|
ByteSequence |
ObjectStreamWireFormat.marshal(Object command) |
Modifier and Type | Method and Description |
---|---|
Object |
WireFormat.unmarshal(ByteSequence packet)
Packet based un-marshaling
|
Object |
ObjectStreamWireFormat.unmarshal(ByteSequence packet) |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.