| | |
| | | |
| | | import org.opends.messages.Message; |
| | | import org.opends.server.loggers.debug.DebugTracer; |
| | | import org.opends.server.replication.common.CSN; |
| | | import org.opends.server.replication.server.changelog.api.*; |
| | | import org.opends.server.replication.server.changelog.je.DraftCNDB.*; |
| | | import org.opends.server.types.DebugLogLevel; |
| | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public String getBaseDN() |
| | | public CNIndexData getCNIndexData() |
| | | { |
| | | try |
| | | { |
| | | return this.draftCNDbCursor.currentBaseDN(); |
| | | return this.draftCNDbCursor.currentData(); |
| | | } |
| | | catch(Exception e) |
| | | catch (Exception e) |
| | | { |
| | | TRACER.debugCaught(DebugLogLevel.ERROR, e); |
| | | return null; |
| | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public CSN getCSN() |
| | | { |
| | | try |
| | | { |
| | | return this.draftCNDbCursor.currentCSN(); |
| | | } |
| | | catch(Exception e) |
| | | { |
| | | TRACER.debugCaught(DebugLogLevel.ERROR, e); |
| | | return null; |
| | | } |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public long getChangeNumber() |
| | | { |
| | | return ((ReplicationDraftCNKey) draftCNDbCursor.getKey()).getChangeNumber(); |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public boolean next() throws ChangelogException |
| | | { |
| | | if (draftCNDbCursor != null) |