Class PlatformEventFilterListenerImpl
- java.lang.Object
-
- org.apache.ignite.internal.processors.platform.events.PlatformEventFilterListenerImpl
-
- All Implemented Interfaces:
Externalizable,Serializable,PlatformEventFilterListener,IgniteBiPredicate<UUID,Event>,IgnitePredicate<Event>
public class PlatformEventFilterListenerImpl extends Object implements PlatformEventFilterListener, Externalizable
Platform event filter. Delegates apply to native platform.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description PlatformEventFilterListenerImpl()Externalizablesupport.PlatformEventFilterListenerImpl(long hnd, PlatformContext ctx)Constructor.PlatformEventFilterListenerImpl(Object pred, int... types)Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanapply(UUID uuid, Event evt)Predicate body.booleanapply(Event evt)Predicate body.booleanequals(Object o)inthashCode()voidinitialize(GridKernalContext gridCtx)Initializes the filter.voidonClose()Callback invoked when filter is closed.voidreadExternal(ObjectInput in)voidwriteExternal(ObjectOutput out)-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.ignite.lang.IgniteBiPredicate
and
-
-
-
-
Constructor Detail
-
PlatformEventFilterListenerImpl
public PlatformEventFilterListenerImpl()
Externalizablesupport.
-
PlatformEventFilterListenerImpl
public PlatformEventFilterListenerImpl(long hnd, PlatformContext ctx)Constructor.- Parameters:
hnd- Handle in the native platform.ctx- Context.
-
PlatformEventFilterListenerImpl
public PlatformEventFilterListenerImpl(Object pred, int... types)
Constructor.- Parameters:
pred- .Net binary predicate.
-
-
Method Detail
-
apply
public boolean apply(Event evt)
Predicate body.- Specified by:
applyin interfaceIgnitePredicate<Event>- Parameters:
evt- Predicate parameter.- Returns:
- Return value.
-
apply
public boolean apply(UUID uuid, Event evt)
Predicate body.- Specified by:
applyin interfaceIgniteBiPredicate<UUID,Event>- Parameters:
uuid- First parameter.evt- Second parameter.- Returns:
- Return value.
-
onClose
public void onClose()
Callback invoked when filter is closed.- Specified by:
onClosein interfacePlatformEventFilterListener
-
initialize
public void initialize(GridKernalContext gridCtx)
Initializes the filter.- Specified by:
initializein interfacePlatformEventFilterListener
-
writeExternal
public void writeExternal(ObjectOutput out) throws IOException
- Specified by:
writeExternalin interfaceExternalizable- Throws:
IOException
-
readExternal
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
- Specified by:
readExternalin interfaceExternalizable- Throws:
IOExceptionClassNotFoundException
-
-