|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ByteSequence | |
---|---|
org.apache.activemq.broker.region.cursors | Cursors used to page persistent messages into the broker from the store |
org.apache.activemq.broker.scheduler | |
org.apache.activemq.store.kahadb | |
org.apache.activemq.store.kahadb.plist | |
org.apache.kahadb.journal | journal based data storage - scalable and fast |
org.apache.kahadb.util |
Uses of ByteSequence in org.apache.activemq.broker.region.cursors |
---|
Methods in org.apache.activemq.broker.region.cursors that return ByteSequence | |
---|---|
protected ByteSequence |
FilePendingMessageCursor.getByteSequence(Message message)
|
Methods in org.apache.activemq.broker.region.cursors with parameters of type ByteSequence | |
---|---|
protected Message |
FilePendingMessageCursor.getMessage(ByteSequence bs)
|
Uses of ByteSequence in org.apache.activemq.broker.scheduler |
---|
Methods in org.apache.activemq.broker.scheduler with parameters of type ByteSequence | |
---|---|
void |
JobScheduler.schedule(java.lang.String jobId,
ByteSequence payload,
long delay)
Add a job to be scheduled |
void |
JobSchedulerFacade.schedule(java.lang.String jobId,
ByteSequence payload,
long delay)
|
void |
JobScheduler.schedule(java.lang.String jobId,
ByteSequence payload,
java.lang.String cronEntry)
Add a job to be scheduled |
void |
JobSchedulerFacade.schedule(java.lang.String jobId,
ByteSequence payload,
java.lang.String cronEntry)
|
void |
JobScheduler.schedule(java.lang.String jobId,
ByteSequence payload,
java.lang.String cronEntry,
long delay,
long period,
int repeat)
Add a job to be scheduled |
void |
JobSchedulerFacade.schedule(java.lang.String jobId,
ByteSequence payload,
java.lang.String cronEntry,
long start,
long period,
int repeat)
|
void |
JobListener.scheduledJob(java.lang.String id,
ByteSequence job)
A Job that has been scheduled is now ready |
void |
SchedulerBroker.scheduledJob(java.lang.String id,
ByteSequence job)
|
Constructors in org.apache.activemq.broker.scheduler with parameters of type ByteSequence | |
---|---|
JobImpl(org.apache.activemq.broker.scheduler.JobLocation location,
ByteSequence bs)
|
Uses of ByteSequence in org.apache.activemq.store.kahadb |
---|
Methods in org.apache.activemq.store.kahadb that return ByteSequence | |
---|---|
ByteSequence |
MessageDatabase.toByteSequence(JournalCommand<?> data)
|
Uses of ByteSequence in org.apache.activemq.store.kahadb.plist |
---|
Methods in org.apache.activemq.store.kahadb.plist that return ByteSequence | |
---|---|
ByteSequence |
PListEntry.getByteSequence()
|
Methods in org.apache.activemq.store.kahadb.plist with parameters of type ByteSequence | |
---|---|
void |
PList.addFirst(java.lang.String id,
ByteSequence bs)
|
void |
PList.addLast(java.lang.String id,
ByteSequence bs)
|
Uses of ByteSequence in org.apache.kahadb.journal |
---|
Fields in org.apache.kahadb.journal declared as ByteSequence | |
---|---|
ByteSequence |
Journal.WriteCommand.data
|
Methods in org.apache.kahadb.journal that return ByteSequence | |
---|---|
ByteSequence |
Journal.read(Location location)
|
Methods in org.apache.kahadb.journal with parameters of type ByteSequence | |
---|---|
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,
java.lang.Runnable onComplete)
|
void |
Journal.update(Location location,
ByteSequence data,
boolean sync)
|
Location |
Journal.write(ByteSequence data,
boolean sync)
|
Location |
Journal.write(ByteSequence data,
java.lang.Runnable onComplete)
|
Constructors in org.apache.kahadb.journal with parameters of type ByteSequence | |
---|---|
Journal.WriteCommand(Location location,
ByteSequence data,
boolean sync)
|
|
Journal.WriteCommand(Location location,
ByteSequence data,
java.lang.Runnable onComplete)
|
Uses of ByteSequence in org.apache.kahadb.util |
---|
Methods in org.apache.kahadb.util that return ByteSequence | |
---|---|
ByteSequence |
DataByteArrayOutputStream.getByteSequence()
|
ByteSequence |
DataByteArrayOutputStream.toByteSequence()
Get a ByteSequence from the stream |
ByteSequence |
ByteArrayOutputStream.toByteSequence()
|
Methods in org.apache.kahadb.util with parameters of type ByteSequence | |
---|---|
int |
ByteSequence.indexOf(ByteSequence needle,
int pos)
|
void |
DataByteArrayInputStream.restart(ByteSequence sequence)
reset the StoreByteArrayInputStream to use an new
ByteSequence |
Constructors in org.apache.kahadb.util with parameters of type ByteSequence | |
---|---|
ByteArrayInputStream(ByteSequence sequence)
|
|
DataByteArrayInputStream(ByteSequence sequence)
Creates a StoreByteArrayInputStream . |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |