co.cask.cdap.messaging.store

Class MessageFilter<T>

java.lang.Object

co.cask.cdap.messaging.store.MessageFilter<T>

Type Parameters:

T -

All Implemented Interfaces:

com.google.common.base.Function<T,MessageFilter.Result>

Direct Known Subclasses:

TransactionMessageFilter

public abstract class MessageFilter<T>
extends Object
implements com.google.common.base.Function<T,MessageFilter.Result>

Filter messages read from MessageTable.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MessageFilter.Result The result of the filtering.

Constructor Summary

Constructors

Constructor and Description
MessageFilter()

Method Summary

Modifier and Type	Method and Description
static <T> MessageFilter<T>	alwaysAccept() Creates a MessageFilter that always accept.
abstract MessageFilter.Result	apply(T input)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.base.Function

equals

Constructor Detail

MessageFilter

public MessageFilter()

Method Detail

apply

@Nonnull
public abstract MessageFilter.Result apply(@Nullable
                                                    T input)

Specified by:

apply in interface com.google.common.base.Function<T,MessageFilter.Result>

alwaysAccept

public static <T> MessageFilter<T> alwaysAccept()

Creates a MessageFilter that always accept.

Type Parameters:

T - type of input to filter on

Returns:

a MessageFilter that accepts on all input