public class ReplicaJournalCursor extends org.apache.directory.api.ldap.model.cursor.AbstractCursor<ReplicaEventMessage>
Constructor and Description |
---|
ReplicaJournalCursor(PartitionTxn partitionTxn,
JdbmTable<String,ReplicaEventMessage> journal,
String consumerCsn)
Creates a cursor on top of the given journal
|
Modifier and Type | Method and Description |
---|---|
void |
after(ReplicaEventMessage arg0) |
void |
afterLast() |
boolean |
available() |
void |
before(ReplicaEventMessage arg0) |
void |
beforeFirst() |
void |
close() |
void |
close(Exception cause) |
protected void |
delete()
delete the current message
used for internal log cleanup ONLY
|
boolean |
first() |
ReplicaEventMessage |
get() |
Iterator<ReplicaEventMessage> |
iterator() |
boolean |
last() |
boolean |
next() |
boolean |
previous() |
protected void |
skipQualifyingWhileFetching()
sets the flag to skip CSN based checking while traversing
used for internal log cleanup ONLY
|
checkNotClosed, isAfterLast, isBeforeFirst, isClosed, isFirst, isLast, setClosureMonitor, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEach, spliterator
public ReplicaJournalCursor(PartitionTxn partitionTxn, JdbmTable<String,ReplicaEventMessage> journal, String consumerCsn) throws Exception
partitionTxn
- The Transaction to usejournal
- the log journalconsumerCsn
- the consumer's CSN taken from cookieException
- If the cursor creation failedpublic void after(ReplicaEventMessage arg0) throws org.apache.directory.api.ldap.model.exception.LdapException, org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.exception.LdapException
org.apache.directory.api.ldap.model.cursor.CursorException
public void afterLast() throws org.apache.directory.api.ldap.model.exception.LdapException, org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.exception.LdapException
org.apache.directory.api.ldap.model.cursor.CursorException
public boolean available()
public void before(ReplicaEventMessage arg0) throws org.apache.directory.api.ldap.model.exception.LdapException, org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.exception.LdapException
org.apache.directory.api.ldap.model.cursor.CursorException
public void beforeFirst() throws org.apache.directory.api.ldap.model.exception.LdapException, org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.exception.LdapException
org.apache.directory.api.ldap.model.cursor.CursorException
public boolean first() throws org.apache.directory.api.ldap.model.exception.LdapException, org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.exception.LdapException
org.apache.directory.api.ldap.model.cursor.CursorException
public ReplicaEventMessage get() throws org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.cursor.CursorException
public boolean last() throws org.apache.directory.api.ldap.model.exception.LdapException, org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.exception.LdapException
org.apache.directory.api.ldap.model.cursor.CursorException
public boolean next() throws org.apache.directory.api.ldap.model.exception.LdapException, org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.exception.LdapException
org.apache.directory.api.ldap.model.cursor.CursorException
public boolean previous() throws org.apache.directory.api.ldap.model.exception.LdapException, org.apache.directory.api.ldap.model.cursor.CursorException
org.apache.directory.api.ldap.model.exception.LdapException
org.apache.directory.api.ldap.model.cursor.CursorException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in class org.apache.directory.api.ldap.model.cursor.AbstractCursor<ReplicaEventMessage>
IOException
public void close(Exception cause) throws IOException
close
in interface org.apache.directory.api.ldap.model.cursor.Cursor<ReplicaEventMessage>
close
in class org.apache.directory.api.ldap.model.cursor.AbstractCursor<ReplicaEventMessage>
IOException
protected void skipQualifyingWhileFetching()
protected void delete()
public Iterator<ReplicaEventMessage> iterator()
iterator
in interface Iterable<ReplicaEventMessage>
iterator
in class org.apache.directory.api.ldap.model.cursor.AbstractCursor<ReplicaEventMessage>
Copyright © 2003–2020 The Apache Software Foundation. All rights reserved.