Examples of org.axonframework.saga.annotation.AsyncAnnotatedSagaManager.stop()

Package org.axonframework.saga.annotation

Class org.axonframework.saga.annotation.AsyncAnnotatedSagaManager

Examples of org.axonframework.saga.annotation.AsyncAnnotatedSagaManager.stop()

org.axonframework.saga.annotation.AsyncAnnotatedSagaManager.stop()
Unsubscribes this Saga Manager from the event bus and stops accepting new events. The method is blocked until all scheduled events have been processed. Note that any manually provided Executors using ( {@link #setExecutor(java.util.concurrent.Executor)} are not shut down.
If the Saga Manager was already stopped, nothing happens.

                                                                                                                identifier),
                                                                                                        MetaData.emptyInstance());
        sagaManager.handle(event);
        sagaManager.unsubscribe();
        verify(sagaFactory).createSaga(eq(StubSaga.class));
        sagaManager.stop();


        verify(correlationDataProvider).correlationDataFor(event);


        assertEquals("Saga was never stored in the saga repository",
                     1L, entityManager.createQuery("SELECT count(se) FROM SagaEntry se").getSingleResult());

View Full Code Here

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.