Package de.hybris.platform.servicelayer.event

Class AbstractAsynchronousEventServiceTest.TestEventQueueBasedListener

java.lang.Object
de.hybris.platform.servicelayer.event.impl.AbstractEventListener<AbstractEvent>
de.hybris.platform.servicelayer.event.AbstractAsynchronousEventServiceTest.TestEventQueueBasedListener
All Implemented Interfaces:
EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<AbstractEvent>
Enclosing class:
AbstractAsynchronousEventServiceTest
protected static class AbstractAsynchronousEventServiceTest.TestEventQueueBasedListener extends AbstractEventListener<AbstractEvent>

  • Constructor Details

    • TestEventQueueBasedListener

      public TestEventQueueBasedListener(int timeoutSeconds)

  • Method Details

    • setSourceFilter

      public void setSourceFilter(Predicate<?> sourceFilter)

    • onEvent

      protected void onEvent(AbstractEvent event)
      Description copied from class: AbstractEventListener
      This method is called by ApplicationListener.onApplicationEvent(ApplicationEvent) and processes the given event.
      Specified by:
      onEvent in class AbstractEventListener<AbstractEvent>
      Parameters:
      event - the event to be processed
      See Also:
      • ApplicationListener.onApplicationEvent(ApplicationEvent)

    • pollEvent

      public AbstractEvent pollEvent()

    • setExpectedEventClass

      public void setExpectedEventClass(Class<? extends AbstractEvent> clazz)