Examples of de.novanic.eventservice.service.registry.EventRegistry.listen()

de.novanic.eventservice.service.registry.EventRegistry.listen()

The listen method returns all events for the user (events for all domains where the user is registered and user specific events). If no events are available, the method waits a defined time before the events are returned. The listen method is designed for the EventService functionality. The client side calls the method with a defined interval to receive all events. If the client don't call the method in the interval, the user will be removed from the EventRegistry. The timeout time and the min and max waiting time can be configured by {@link de.novanic.eventservice.config.EventServiceConfiguration}. @param aServerEventListener {@link de.novanic.eventservice.service.connection.strategy.connector.ConnectionStrategyServerConnector} for the listening method @param aUserId user @return list of events

    public void testRemoveEventFilter_2() {
        final EventRegistry theEventRegistry = EventRegistryFactory.getInstance().getEventRegistry();
        theEventRegistry.registerUser(TEST_DOMAIN, TEST_USER_ID, null);


        theEventRegistry.addEvent(TEST_DOMAIN, new EmptyEvent());
        assertEquals(1, theEventRegistry.listen(getLongPollingListener(), TEST_USER_ID).size());


        assertNull(myEventExecutorService.getEventFilter(TEST_DOMAIN));


        final EmptyEventFilter theEventFilter = new EmptyEventFilter(0);
        myEventExecutorService.setEventFilter(TEST_DOMAIN, new EmptyEventFilter(0));


        assertNotNull(myEventExecutorService.getEventFilter(TEST_DOMAIN));
        assertEquals(theEventFilter, myEventExecutorService.getEventFilter(TEST_DOMAIN));


        theEventRegistry.addEvent(TEST_DOMAIN, new EmptyEvent());
        assertEquals(0, theEventRegistry.listen(getLongPollingListener(), TEST_USER_ID).size());


        myEventExecutorService.setEventFilter(TEST_DOMAIN, null);


        theEventRegistry.addEvent(TEST_DOMAIN, new EmptyEvent());
        assertEquals(1, theEventRegistry.listen(getLongPollingListener(), TEST_USER_ID).size());

        assertEquals(0, theEventRegistry.listen(getLongPollingListener(), TEST_USER_ID).size());


        myEventExecutorService.setEventFilter(TEST_DOMAIN, null);


        theEventRegistry.addEvent(TEST_DOMAIN, new EmptyEvent());
        assertEquals(1, theEventRegistry.listen(getLongPollingListener(), TEST_USER_ID).size());
    }


    private static class EmptyEvent implements Event {}


    private static class EmptyEventFilter implements EventFilter

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.