| Package | Description |
|---|---|
| org.apache.directory.server.ldap.replication.provider |
| Modifier and Type | Field and Description |
|---|---|
private ReplicaEventMessage |
ReplicaJournalCursor.qualifiedEvtMsg |
| Modifier and Type | Field and Description |
|---|---|
private JdbmTable<java.lang.String,ReplicaEventMessage> |
ReplicaJournalCursor.journal
the event log journal
|
private JdbmTable<java.lang.String,ReplicaEventMessage> |
ReplicaEventLog.journal
The Journal of modifications
|
private org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<java.lang.String,ReplicaEventMessage>> |
ReplicaJournalCursor.tupleCursor
the underlying journal's cursor
|
| Modifier and Type | Method and Description |
|---|---|
ReplicaEventMessage |
ReplicaJournalCursor.get() |
| Modifier and Type | Method and Description |
|---|---|
java.util.Iterator<ReplicaEventMessage> |
ReplicaJournalCursor.iterator() |
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicaJournalCursor.after(ReplicaEventMessage arg0) |
void |
ReplicaJournalCursor.before(ReplicaEventMessage arg0) |
private boolean |
ReplicaJournalCursor.isQualified(java.lang.String csn,
ReplicaEventMessage evtMsg)
selects the current queue entry if qualified for sending to the consumer
|
void |
ReplicaEventLog.log(ReplicaEventMessage message)
Stores the given message in the queue
|
| Constructor and Description |
|---|
ReplicaJournalCursor(JdbmTable<java.lang.String,ReplicaEventMessage> journal,
java.lang.String consumerCsn)
Creates a cursor on top of the given journal
|