Package | Description |
---|---|
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 |
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
|
void |
SchedulerBroker.scheduledJob(String id,
ByteSequence job) |
Constructor and Description |
---|
JobImpl(org.apache.activemq.broker.scheduler.JobLocation location,
ByteSequence bs) |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
MessageDatabase.toByteSequence(JournalCommand<?> data) |
Modifier and Type | Method and Description |
---|---|
ByteSequence |
PListEntry.getByteSequence() |
Modifier and Type | Method and Description |
---|---|
void |
PList.addFirst(String id,
ByteSequence bs) |
void |
PList.addLast(String id,
ByteSequence bs) |
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 |
---|
Journal.WriteCommand(Location location,
ByteSequence data,
boolean sync) |
Journal.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
|
ByteSequence |
ByteArrayOutputStream.toByteSequence() |
Modifier and Type | Method and Description |
---|---|
int |
ByteSequence.indexOf(ByteSequence needle,
int pos) |
void |
DataByteArrayInputStream.restart(ByteSequence sequence)
reset the
StoreByteArrayInputStream to use an new
ByteSequence |
Constructor and Description |
---|
ByteArrayInputStream(ByteSequence sequence) |
DataByteArrayInputStream(ByteSequence sequence)
Creates a
StoreByteArrayInputStream . |
Copyright © 2005–2015. All rights reserved.