removes and returns next event from the queue , blocking if empty . concode_field_sep int commitTimeout concode_elem_sep long eventCount concode_elem_sep BlockingQueue<ReplDBMSEvent> serialQueue concode_elem_sep Logger logger concode_elem_sep List<ConcurrentLinkedQueue<ReplDBMSEvent>> taskQueues concode_elem_sep String name concode_elem_sep int maxSize concode_elem_sep long commitCount concode_elem_sep CommitAction commitAction concode_elem_sep int partitions concode_elem_sep ReplDBMSHeader[] lastHeader concode_elem_sep String FAILURE_TAG concode_field_sep void setName concode_elem_sep void rollback concode_elem_sep void prepare concode_elem_sep String getName concode_elem_sep long getMaxStoredSeqno concode_elem_sep void setPartitions concode_elem_sep void release concode_elem_sep void setCommitTimeout concode_elem_sep void setLastHeader concode_elem_sep ReplDBMSHeader getLastHeader concode_elem_sep void commit concode_elem_sep void configure concode_elem_sep int getCommitTimeout concode_elem_sep void setCommitAction concode_elem_sep void setMaxSize concode_elem_sep void put concode_elem_sep ReplDBMSEvent peek concode_elem_sep long getMinStoredSeqno concode_elem_sep int getMaxSize concode_elem_sep int size concode_elem_sep int getPartitions concode_elem_sep CommitAction getCommitAction concode_elem_sep TungstenProperties status
ReplDBMSEvent function ( ) { return serialQueue . take ( ) ; }