Examples of EventFilter

akka.testkit.EventFilter
com.cumulocity.me.sdk.client.event.EventFilter
A filter to be used in event queries. The setter (by*) methods return the filter itself to provide chaining: {@code EventFilter filter = new EventFilter().byType(type).bySource(source);}
com.cumulocity.sdk.client.event.EventFilter
A filter to be used in event queries. The setter (by*) methods return the filter itself to provide chaining: {@code EventFilter filter = new EventFilter().byType(type).bySource(source);}
com.hazelcast.spi.EventFilter
@author mdogan 12/14/12
com.netflix.eventbus.spi.EventFilter
Top level filter used by the event bus. A filter may be created in code or defined using a scripting language. @author elandau
com.qspin.qtaste.tools.converter.filter.EventFilter
de.novanic.eventservice.client.event.filter.EventFilter
An EventFilter can be used to filter events. When an event is filtered, the user/client shouldn't be informed about the event. EventFilters are useful when the filter function for domains/contexts is to common. @author sstrohschein
Date: 05.06.2008
Time: 19:09:11
eas.simulation.event.EventFilter
Implementation of an event filter interface. The isAcceptable method decides if a specific event should be accepted. This class is used by SimulationTime to decide to which plugins which events are propagated. Plugins can request notifications of events matching filters defined by this interface. @author Lukas König
javax.portlet.filter.EventFilter
The EventFilter is an object that performs filtering tasks on either the event request to a portlet, or on the event response from a portlet, or both.
Filters perform filtering in the doFilter method. Every Filter has access to a FilterConfig object from which it can obtain its initialization parameters, a reference to the PortletContext which it can use, for example, to load resources needed for filtering tasks.
Filters are configured in the portlet deployment descriptor of a portlet application. @since 2.0
javax.xml.stream.EventFilter
org.apache.jackrabbit.core.observation.EventFilter
The EventFilter class implements the filter logic based on the session's access rights and the specified filter rules.
org.apache.jackrabbit.oak.plugins.observation.EventFilter
Filter for filtering observation events according to a certain criterion.
org.apache.jackrabbit.oak.plugins.observation.filter.EventFilter
Filter for determining what changes to report the the {@link Listener}.
org.apache.jackrabbit.spi.EventFilter
An EventFilter is applied to the events as generated on the repository server. Event filter instances can be created with {@link RepositoryService#createEventFilter(SessionInfo,int,Path,boolean,String[],Name[],boolean)}. Some repository implementations may also support event filters that are directly instantiated by the client.
org.jboss.fresh.events.EventFilter
EventFilter contains a list of strings representing filters which are to be applied on events to determine which events match the filter and which don't.
This is primarily used inside EventCentrals to only let through events matching the filter.
Format of filter specification is the following:
<host_label> "/" <app_label> "/" <component_label> "/" <event_class> "/" <event_type>
Example:
hirohito/elan/CMSPersistence/CMS/onAfter

Component label can include ID specification. If present it is suffixed and nested inside two parentheses:
Example:
CMSPersistence(5da8122ef)
There are no constraints on the length of ID specification or the characters that compose an ID.
Every event should contain a component ID. This allows other components to send direct events to it.
Asterisk (*) can be used to specify zero or more characters in the pattern component. Question mark (?) can be used to specify exactly one character in the pattern component. If component is empty it is as if it was equal to * meaning it matches everything.

This class is not thread-safe.
org.wso2.carbon.event.core.subscription.EventFilter

Examples of com.hazelcast.spi.EventFilter

        return mapService.getMapServiceContext().addEventListener(listener, eventFilter, name);
    }


    protected String addEntryListenerInternal(
            EntryListener listener, Predicate predicate, final Data key, final boolean includeValue) {
        EventFilter eventFilter = new QueryEventFilter(includeValue, key, predicate);
        final MapService mapService = getService();
        return mapService.getMapServiceContext().addEventListener(listener, eventFilter, name);
    }

View Full Code Here

Examples of com.hazelcast.spi.EventFilter

    }


    @Override
    public String addEntryListener(EntryListener listener, Object key) {
        ValidationUtil.isNotNull(listener, "listener");
        EventFilter eventFilter = new ReplicatedEntryEventFilter(marshallKey(key));
        mapStats.incrementOtherOperations();
        return replicatedMapService.addEventListener(listener, eventFilter, getName());
    }

View Full Code Here

Examples of com.hazelcast.spi.EventFilter

    }


    @Override
    public String addEntryListener(EntryListener listener, Predicate predicate, Object key) {
        ValidationUtil.isNotNull(listener, "listener");
        EventFilter eventFilter = new ReplicatedQueryEventFilter(marshallKey(key), predicate);
        mapStats.incrementOtherOperations();
        return replicatedMapService.addEventListener(listener, eventFilter, getName());
    }

View Full Code Here

Examples of com.hazelcast.spi.EventFilter

                    endpoint.sendEvent(portableEntryEvent, getCallId());
                }
            }
        };


        EventFilter eventFilter;
        if (getPredicate() == null) {
            eventFilter = new EntryEventFilter(includeValue, key);
        } else {
            eventFilter = new QueryEventFilter(includeValue, key, getPredicate());
        }

View Full Code Here

Examples of com.netflix.eventbus.spi.EventFilter

        EventBusImpl bus = eventBus;
        TestAwareConsumerQueueSupplier consumerQueueSupplier = new TestAwareConsumerQueueSupplier();
        bus.setConsumerQueueSupplier(consumerQueueSupplier);


        StatefulEventHandler handler1 = new StatefulEventHandler("con1");
        EventFilter filter = new InfixFilterLanguageSupport().convert("xpath(\"//name\")=\"con1\"");
        bus.registerSubscriber(filter, handler1);
        TestAwareQueue handler1Q = consumerQueueSupplier.testAwareQueue;


        StatefulEventHandler handler2 = new StatefulEventHandler("con2");
        filter = new InfixFilterLanguageSupport().convert("xpath(\"//name\")=\"con1\"");

View Full Code Here

Examples of com.qspin.qtaste.tools.converter.filter.EventFilter

      LOGGER.error(pExc);
    }
    List<Filter> filters = new ArrayList<Filter>();
    for (Filter f: gestionnaire.getDecodedFilters() )
    {
      filters.add(new EventFilter(f));
    }
    return filters;
  }

View Full Code Here

Examples of de.novanic.eventservice.client.event.filter.EventFilter

public class ActivationCommandTest extends ClientCommandTestCase
{
    @Test
    public void testExecute() {
        final Domain theTestDomain = DomainFactory.getDomain("test_domain");
        final EventFilter theEventFilter = new TypeEventFilterTestMode();
        final TestEventNotification theTestEventNotification = new TestEventNotification();


        getRemoteEventConnectorMock().activate(theTestDomain, theEventFilter, theTestEventNotification, getCommandCallback());


        testExecute(new ActivationCommand(getRemoteEventConnectorMock(), theTestDomain, theEventFilter, theTestEventNotification, getCommandCallback()));

View Full Code Here

Examples of de.novanic.eventservice.client.event.filter.EventFilter

    public void deregisterEventFilter(Domain aDomain, AsyncCallback<Void> aCallback) {
        aCallback.onSuccess(null);
    }


    public void getEventFilter(Domain aDomain, AsyncCallback<EventFilter> aCallback) {
        aCallback.onSuccess(new EventFilter() {
            public boolean match(Event anEvent) {
                return false;
            }
        });
    }

View Full Code Here

Examples of eas.simulation.event.EventFilter

              + "*environment*.getSimTime().broadcastEvent(new ChartEvent(*...*));\n"
              + "To store an existing chart as PDF you can broadcast a 'ChartEventStoreAsPDF', e.g.,\n"
              + "*environment*.getSimTime().broadcastEvent(new ChartEventStoreAsPDF(*chartName*, *File*));\n"
              + "***********************************************************************\n");
      
      env.getSimTime().requestEvents(this, new EventFilter() {
            private static final long serialVersionUID = 3719917006278896507L;


            @Override
            public boolean isAcceptable(EASEvent event) {
                return event.getClass().isAssignableFrom(ChartEvent.class);

View Full Code Here

Examples of javax.portlet.filter.EventFilter

    public void doFilter(EventRequest request, EventResponse response) throws IOException, PortletException {
        if (filterListIndex <filterList.size()){
            Filter filter = filterList.get(filterListIndex);
            filterListIndex++;
            try {
                EventFilter eventFilter = (EventFilter) loader.loadClass(filter.getFilterClass()).newInstance();
                FilterConfigImpl filterConfig = new FilterConfigImpl(filter.getFilterName(),filter.getInitParams(),portletContext);
                eventFilter.init(filterConfig);
                eventFilter.doFilter(request, response, this);
                eventFilter.destroy();
            } catch (InstantiationException e) {
                e.printStackTrace();
            } catch (IllegalAccessException e) {
                e.printStackTrace();
            } catch (ClassNotFoundException e) {

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.