Package org.axonframework.eventhandling

Examples of org.axonframework.eventhandling.OrderResolver


        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


    @Test
    public void testOrderingOfListeners() {
        testSubject = new AsynchronousCluster("async", new DirectExecutor(),
                                              new DefaultUnitOfWorkFactory(mockTransactionManager),
                                              new SequentialPolicy(), new DefaultErrorHandler(RetryPolicy.proceed()),
                                              new OrderResolver() {
            @Override
            public int orderOf(EventListener listener) {
                if (listener instanceof EventListenerProxy) {
                    return ((EventListenerProxy) listener).getTargetType().getSuperclass()
                                                          .getAnnotation(Order.class).value();
View Full Code Here

TOP

Related Classes of org.axonframework.eventhandling.OrderResolver

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.