org.cg.eventbus.policy

Class StrictCommitPolicy

java.lang.Object

org.cg.eventbus.policy.CommitPolicy

org.cg.eventbus.policy.StrictCommitPolicy

public class StrictCommitPolicy
extends CommitPolicy

A very strict commit policy.
Consumer will commit its offset after consume every single message.

Author:

liang.li

Constructor Summary

Constructors

Constructor and Description
StrictCommitPolicy()

Method Summary

Modifier and Type	Method and Description
boolean	needCommit()
boolean	needCommit(Message msg)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StrictCommitPolicy

public StrictCommitPolicy()

Method Detail

needCommit

public boolean needCommit()

Specified by:

needCommit in class CommitPolicy

needCommit

public boolean needCommit(Message msg)

Specified by:

needCommit in class CommitPolicy