public class DefaultRecordProducer extends Object implements RecordProducer
| Constructor and Description |
|---|
DefaultRecordProducer(AbstractJournal journal,
String id)
Create a new instance of this class.
|
public DefaultRecordProducer(AbstractJournal journal, String id)
journal - journalid - producer idpublic Record append() throws JournalException
Record.update() or Record.cancelUpdate().
on the record returned.append in interface RecordProducerJournalException - if an error occursprotected AppendRecord createRecord() throws JournalException
JournalException - if an error occursCopyright © 2004-2020 The Apache Software Foundation. All Rights Reserved.