@Test(expected = IllegalArgumentException.class) public void testRelayNullTopicEvent() throws Exception { eventRelay.relayTopicEvent(null); }
public void relayTopicEvent(MotechEvent event) { verifyEventNotNull(event); Set<EventListener> listeners = getEventListeners(event); for (EventListener listener : listeners) { handleTopicEvent(listener, event); } if (proxyInOsgi(event)) { sendInOSGi(event); } }
ServerEventRelay implements EventRelay, EventHandler { public void relayTopicEvent(MotechEvent event) { verifyEventNotNull(event); Set<EventListener> listeners = getEventListeners(event); for (EventListener listener : listeners) { handleTopicEvent(listener, event); } if (proxyInOsgi(event)) { sendInOSGi(event); } } }
ServerEventRelay implements EventRelay, EventHandler { public void relayTopicEvent(MotechEvent event) { verifyEventNotNull(event); Set<EventListener> listeners = getEventListeners(event); for (EventListener listener : listeners) { handleTopicEvent(listener, event); } if (proxyInOsgi(event)) { sendInOSGi(event); } } @Autowired  ServerEventRelay(OutboundEventGateway outboundEventGateway, EventListenerRegistry eventListenerRegistry, MotechEventConfig motechEventConfig,
                            EventAdmin osgiEventAdmin, BundleContext bundleContext); }
ServerEventRelay implements EventRelay, EventHandler { public void relayTopicEvent(MotechEvent event) { verifyEventNotNull(event); Set<EventListener> listeners = getEventListeners(event); for (EventListener listener : listeners) { handleTopicEvent(listener, event); } if (proxyInOsgi(event)) { sendInOSGi(event); } } @Autowired  ServerEventRelay(OutboundEventGateway outboundEventGateway, EventListenerRegistry eventListenerRegistry, MotechEventConfig motechEventConfig,
                            EventAdmin osgiEventAdmin, BundleContext bundleContext); @Override void sendEventMessage(MotechEvent event); @Override void broadcastEventMessage(MotechEvent event); void relayQueueEvent(MotechEvent event); void relayTopicEvent(MotechEvent event); @Override void handleEvent(Event osgiEvent); }
ServerEventRelay implements EventRelay, EventHandler { public void relayTopicEvent(MotechEvent event) { verifyEventNotNull(event); Set<EventListener> listeners = getEventListeners(event); for (EventListener listener : listeners) { handleTopicEvent(listener, event); } if (proxyInOsgi(event)) { sendInOSGi(event); } } @Autowired  ServerEventRelay(OutboundEventGateway outboundEventGateway, EventListenerRegistry eventListenerRegistry, MotechEventConfig motechEventConfig,
                            EventAdmin osgiEventAdmin, BundleContext bundleContext); @Override void sendEventMessage(MotechEvent event); @Override void broadcastEventMessage(MotechEvent event); void relayQueueEvent(MotechEvent event); void relayTopicEvent(MotechEvent event); @Override void handleEvent(Event osgiEvent);  }