Modifier and Type | Method and Description |
---|---|
protected ByteSequence |
FilePendingMessageCursor.getByteSequence(Message message) |
Modifier and Type | Method and Description |
---|---|
protected Message |
FilePendingMessageCursor.getMessage(ByteSequence bs) |
Modifier and Type | Method and Description |
---|---|
void |
JobSchedulerFacade.schedule(String jobId,
ByteSequence payload,
long delay) |
void |
JobScheduler.schedule(String jobId,
ByteSequence payload,
long delay)
Add a job to be scheduled
|
void |
JobSchedulerFacade.schedule(String jobId,
ByteSequence payload,
String cronEntry) |
void |
JobScheduler.schedule(String jobId,
ByteSequence payload,
String cronEntry)
Add a job to be scheduled
|
void |
JobSchedulerFacade.schedule(String jobId,
ByteSequence payload,
String cronEntry,
long start,
long period,
int repeat) |
void |
JobScheduler.schedule(String jobId,
ByteSequence payload,
String cronEntry,
long delay,
long period,
int repeat)
Add a job to be scheduled
|
void |
JobListener.scheduledJob(String id,
ByteSequence job)
A Job that has been scheduled is now ready to be fired.
|
void |
SchedulerBroker.scheduledJob(String id,
ByteSequence job) |
Modifier and Type | Method and Description |
---|---|
void |
InMemoryJobScheduler.schedule(String jobId,
ByteSequence payload,
long delay) |
void |
InMemoryJobScheduler.schedule(String jobId,
ByteSequence payload,
String cronEntry) |
void |
InMemoryJobScheduler.schedule(String jobId,
ByteSequence payload,
String cronEntry,
long delay,
long period,
int repeat) |
Modifier and Type | Field and Description |
---|---|
protected ByteSequence |
Message.content |
protected ByteSequence |
WireFormatInfo.marshalledProperties |
protected ByteSequence |
Message.marshalledProperties |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
WireFormatInfo.getCachedMarshalledForm(WireFormat wireFormat) |
ByteSequence |
Message.getContent() |
ByteSequence |
WireFormatInfo.getMarshalledProperties() |
ByteSequence |
Message.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 |
WireFormatInfo.setMarshalledProperties(ByteSequence marshalledProperties) |
void |
Message.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 |
---|---|
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 |
---|---|
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 |
---|---|
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 |
PListEntry.getByteSequence() |
Modifier and Type | Method and Description |
---|---|
Object |
PList.addFirst(String id,
ByteSequence bs) |
Object |
PList.addLast(String id,
ByteSequence bs) |
Constructor and Description |
---|
PListEntry(String entry,
ByteSequence bs,
Object locator) |
Modifier and Type | Method and Description |
---|---|
protected ByteSequence |
AbstractKahaDBStore.toByteSequence(JournalCommand<?> data)
Creates a new ByteSequence that represents the marshaled form of the given Journal Command.
|
ByteSequence |
MessageDatabase.toByteSequence(JournalCommand<?> data) |
Modifier and Type | Method and Description |
---|---|
void |
TempMessageDatabase.processAdd(KahaAddMessageCommand command,
TransactionId txid,
ByteSequence data) |
Modifier and Type | Field and Description |
---|---|
ByteSequence |
Journal.WriteCommand.data |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
Journal.read(Location location) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationTarget.replicate(Location location,
ByteSequence sequence,
boolean sync) |
Location |
FileAppender.storeItem(ByteSequence data,
byte type,
boolean sync) |
Location |
FileAppender.storeItem(ByteSequence data,
byte type,
Runnable onComplete) |
void |
Journal.update(Location location,
ByteSequence data,
boolean sync) |
Location |
Journal.write(ByteSequence data,
boolean sync) |
Location |
Journal.write(ByteSequence data,
Runnable onComplete) |
Constructor and Description |
---|
WriteCommand(Location location,
ByteSequence data,
boolean sync) |
WriteCommand(Location location,
ByteSequence data,
Runnable onComplete) |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
DataByteArrayOutputStream.getByteSequence() |
ByteSequence |
DataByteArrayOutputStream.toByteSequence()
Get a ByteSequence from the stream
|
Modifier and Type | Method and Description |
---|---|
void |
DataByteArrayInputStream.restart(ByteSequence sequence)
reset the
StoreByteArrayInputStream to use an new
ByteSequence |
Constructor and Description |
---|
DataByteArrayInputStream(ByteSequence sequence)
Creates a
StoreByteArrayInputStream . |
Modifier and Type | Method and Description |
---|---|
Object |
PListImpl.addFirst(String id,
ByteSequence bs) |
Object |
PListImpl.addLast(String id,
ByteSequence bs) |
Modifier and Type | Method and Description |
---|---|
protected ByteSequence |
JobSchedulerStoreImpl.getPayload(Location location)
Retrieve the scheduled Job's byte blob from the journal.
|
Modifier and Type | Method and Description |
---|---|
void |
JobSchedulerImpl.schedule(String jobId,
ByteSequence payload,
long delay) |
void |
JobSchedulerImpl.schedule(String jobId,
ByteSequence payload,
String cronEntry) |
void |
JobSchedulerImpl.schedule(String jobId,
ByteSequence payload,
String cronEntry,
long delay,
long period,
int repeat) |
Constructor and Description |
---|
JobImpl(org.apache.activemq.store.kahadb.scheduler.JobLocation location,
ByteSequence bs) |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
MQTTWireFormat.marshal(Object command) |
Modifier and Type | Method and Description |
---|---|
Object |
MQTTWireFormat.unmarshal(ByteSequence packet) |
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 The Apache Software Foundation. All rights reserved.