com.hammurapi.eventbus
Class DuplicatesFilter<E,P extends Comparable<P>,C,K,H extends EventBus.Handle<E,P,C>,S extends EventStore<E,P,C,H,S>>
java.lang.Object
com.hammurapi.eventbus.DuplicatesFilter<E,P,C,K,H,S>
- All Implemented Interfaces:
- InferenceFilter<E,P,C,K,H,S>
public class DuplicatesFilter<E,P extends Comparable<P>,C,K,H extends EventBus.Handle<E,P,C>,S extends EventStore<E,P,C,H,S>>
- extends Object
- implements InferenceFilter<E,P,C,K,H,S>
Discards post commands with events already present in event store.
|
Method Summary |
boolean |
accept(InferenceCommand<E,P,C,K,H,S> inferenceCommand,
EventBus<E,P,C,K,H,S> bus)
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DuplicatesFilter
public DuplicatesFilter()
accept
public boolean accept(InferenceCommand<E,P,C,K,H,S> inferenceCommand,
EventBus<E,P,C,K,H,S> bus)
- Specified by:
accept in interface InferenceFilter<E,P extends Comparable<P>,C,K,H extends EventBus.Handle<E,P,C>,S extends EventStore<E,P,C,H,S>>