Package org.axonframework.eventhandling

Examples of org.axonframework.eventhandling.EventListener

118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
        Object postProcessedBean = testSubject.postProcessAfterInitialization(result1, "beanName");

        assertTrue(postProcessedBean instanceof EventListener);
        assertTrue(postProcessedBean instanceof SyncEventListener);

        EventListener eventListener = (EventListener) postProcessedBean;
        SyncEventListener annotatedEventListener = (SyncEventListener) postProcessedBean;
        FailingEvent domainEvent = new FailingEvent();
        try {
            eventListener.handle(new GenericEventMessage<FailingEvent>(domainEvent));
            fail("Expected exception to be propagated");
        } catch (RuntimeException e) {
            assertEquals("Don't like this event", e.getMessage());
        }
    }
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
    }

    @Test
    public void testEventHandlerAdapterIsInitializedAndDestroyedProperly_NoStopSignal() throws Exception {
        Object result1 = testSubject.postProcessBeforeInitialization(new SyncEventListener(), "beanName");
        EventListener postProcessedBean = (EventListener) testSubject.postProcessAfterInitialization(result1,
                                                                                                     "beanName");

        verify(mockEventBus, never()).subscribe(isA(EventListener.class));
        verify(mockEventBus, never()).unsubscribe(isA(EventListener.class));
View Full Code Here
151
152
153
154
155
156
157
158
159
160
161
    }

    @Test
    public void testEventHandlerAdapterIsInitializedAndDestroyedProperly_NormalLifecycle() throws Exception {
        Object result1 = testSubject.postProcessBeforeInitialization(new SyncEventListener(), "beanName");
        EventListener postProcessedBean = (EventListener) testSubject.postProcessAfterInitialization(result1,
                                                                                                     "beanName");

        verify(mockEventBus, never()).subscribe(isA(EventListener.class));
        verify(mockEventBus, never()).unsubscribe(isA(EventListener.class));
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
114
    }

    @Test
    public void testCustomOrderedClusterBean() {
        Cluster cluster = applicationContext.getBean("customOrderedCluster", Cluster.class);
        final EventListener listener = mock(EventListener.class);
        final EventListener listener2 = mock(EventListener.class);
        cluster.subscribe(listener);
        cluster.subscribe(listener2);
        OrderResolver mockOrderResolver = applicationContext.getBean("orderResolver", OrderResolver.class);
        verify(mockOrderResolver, atLeastOnce()).orderOf(listener);
        verify(mockOrderResolver, atLeastOnce()).orderOf(listener2);
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
    @Test
    public void testEventProcessingDelayed_ScheduledExecutorService() {
        EventMessage<? extends StubDomainEvent> event1 = new GenericEventMessage<StubDomainEvent>(new StubDomainEvent());
        EventMessage<? extends StubDomainEvent> event2 = new GenericEventMessage<StubDomainEvent>(new StubDomainEvent());
        final EventListener listener = mock(EventListener.class);
        ScheduledExecutorService mockExecutorService = mock(ScheduledExecutorService.class);
        testSubject = new EventProcessor(mockExecutorService, new NullShutdownCallback(),
                                         new DefaultErrorHandler(RetryPolicy.retryAfter(500, TimeUnit.MILLISECONDS)),
                                         new DefaultUnitOfWorkFactory(mockTransactionManager),
                                         Collections.singleton(listener), multiplexingEventProcessingMonitor);
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
    @Test
    public void testEventProcessingDelayed_ExecutorDoesNotSupportScheduling() {
        EventMessage<? extends StubDomainEvent> event1 = new GenericEventMessage<StubDomainEvent>(new StubDomainEvent());
        EventMessage<? extends StubDomainEvent> event2 = new GenericEventMessage<StubDomainEvent>(new StubDomainEvent());
        final EventListener listener = mock(EventListener.class);
        ExecutorService mockExecutorService = mock(ExecutorService.class);
        testSubject = new EventProcessor(mockExecutorService, new NullShutdownCallback(),
                                         new DefaultErrorHandler(RetryPolicy.retryAfter(500, TimeUnit.MILLISECONDS)),
                                         new DefaultUnitOfWorkFactory(mockTransactionManager),
                                         Collections.singleton(listener), multiplexingEventProcessingMonitor);
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
     */
    @Test
    public void testEventProcessingRetried_TransactionStartupFails() {
        EventMessage<? extends StubDomainEvent> event1 = new GenericEventMessage<StubDomainEvent>(new StubDomainEvent());
        EventMessage<? extends StubDomainEvent> event2 = new GenericEventMessage<StubDomainEvent>(new StubDomainEvent());
        final EventListener listener = mock(EventListener.class);
        ExecutorService mockExecutorService = mock(ExecutorService.class);
        testSubject = new EventProcessor(mockExecutorService, new NullShutdownCallback(),
                                         new DefaultErrorHandler(RetryPolicy.retryAfter(500, TimeUnit.MILLISECONDS)),
                                         new DefaultUnitOfWorkFactory(mockTransactionManager),
                                         Collections.singleton(listener), multiplexingEventProcessingMonitor);
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
        testSubject = new AsynchronousCluster("async", executor,
                                              new SequentialPerAggregatePolicy());
        final List<EventMessage> ackedMessages = listenForAcknowledgedMessages();
        final List<EventMessage> failedMessages = listenForFailedMessages();

        EventListener mockEventListener = mock(EventListener.class);
        testSubject.subscribe(mockEventListener);

        final EventMessage<Object> message1 = asEventMessage(new Object());
        final EventMessage<Object> message2 = asEventMessage(new Object());
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
        assertEquals(eventMessage, ackedMessages.get(0));
    }

    @Test
    public void testSubscriptions() throws Exception {
        EventListener mockEventListener = mock(EventListener.class);
        testSubject.subscribe(mockEventListener);
        assertTrue(testSubject.getMembers().contains(mockEventListener));

        testSubject.unsubscribe(mockEventListener);
        assertFalse(testSubject.getMembers().contains(mockEventListener));
View Full Code Here
150
151
152
153
154
155
156
157
158
159
160
161
    @Test
    public void testExceptionsIgnoredWhenErrorPolicyIsProceed_IncludesAsyncHandler() {
        final List<EventMessage> ackedMessages = listenForAcknowledgedMessages();
        final List<EventMessage> failedMessages = listenForFailedMessages();

        EventListener mockEventListener1 = mock(EventListener.class);
        EventListener mockEventListener2 = mock(EventListener.class);
        AsyncHandler mockEventListener3 = mock(AsyncHandler.class);

        final ArgumentCaptor<EventProcessingMonitor> argumentCaptor = ArgumentCaptor.forClass(EventProcessingMonitor.class);
        doNothing().when(mockEventListener3).subscribeEventProcessingMonitor(argumentCaptor.capture());
View Full Code Here
TOP

Related Classes of org.axonframework.eventhandling.EventListener

  • org.axonframework.contextsupport.spring.ClusterBeanDefinitionParserTest
  • org.axonframework.eventhandling.amqp.spring.AMQPTerminalTest
  • org.axonframework.eventhandling.annotation.AnnotationEventListenerBeanPostProcessorTest
  • org.axonframework.eventhandling.async.AsynchronousClusterConcurrencyTest
  • org.axonframework.eventhandling.async.AsynchronousClusterTest
  • org.axonframework.eventhandling.async.EventProcessorTest
  • org.axonframework.eventhandling.ClassNamePatternClusterSelectorTest
  • org.axonframework.eventhandling.replay.ReplayingClusterTest
  • org.axonframework.eventhandling.scheduling.quartz.QuartzSagaTimerIntegrationTest
  • org.axonframework.integration.eventbus.MessageHandlerAdapterTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.