0

私は axonframework 2.3.1 を使用しています。アプリケーションの単体テストには、いくつかのイベント ハンドラーを含むAggregate クラスがあります。Aggregate クラスに含まれる commandhandler メソッドを inovking する前に、これらのハンドラー メソッド @Before および @After の aop トレースを適用したいと考えています。
私は FixtureConfiguration インターフェイスを使用しており、newGivenWhenThenFixture を集約クラスに適用しています。これは、軸索構成クラスの配線が軸索フレームワークによって行われるためです。
別の xml ファイルで aop 構成を構成し、テスト ケースを実行する前にその xml ファイルをロードします。aop トレースを axon ワイヤード集約クラスと統合するにはどうすればよいですか。
ありがとう

http://www.axonframework.org/axon-2-quickstart-guide/#step1でこの例を使用しました。この例では、class ToDoEventHandler 呼び出されたすべてのメソッドのトレース メッセージの前後にログを記録できるようにしたいと考えています 。

以下は、構成するいくつかの集計とアスペクトを記述した同様のコードです。私は1つの集約クラスを持っています

    public class ToDoItem extends AbstractAnnotatedAggregateRoot{

    @AggregateIdentifier
    private String id;

     @CommandHandler
        public ToDoItem(CreateToDoItemCommand command) {
            apply(new ToDoItemCreatedEvent(command.getToDoId(), command.getDescription()));
    }
    @CommandHandler
    public void markCompleted(MarkCompletedCommand command){
        apply(new ToDoItemCompletedEvent(id));      
    }
    public ToDoItem(){

    }

    @EventHandler
    public void on(ToDoItemCreatedEvent event){
        this.id=event.getTodoid();
    }

}

および 1 つの EventHandler クラス

    public class ToDoEventHandler {

    @EventHandler
    public void handle(ToDoItemCreatedEvent event) {
        System.out.println("We are starting a task: "
                + event.getDescription() + " (" + event.getTodoid() + ")");
    }

    @EventHandler
    public void handle(ToDoItemCompletedEvent event) {
        System.out.println("We've completed a task: " + event.getTodoid());
    }

}

構成ファイル spring-axon を次のように

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:axon="http://www.axonframework.org/schema/core"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                       http://www.axonframework.org/schema/core http://www.axonframework.org/schema/axon-core-2.0.xsd">

<axon:command-bus id="commandBus" />
<axon:event-bus id="eventBus" />

<axon:event-sourcing-repository id="toDoRepository"
    aggregate-type="com.my.axon.ToDoItem" />

<axon:aggregate-command-handler id="toDoItemHandler"
    aggregate-type="com.my.axon.ToDoItem" repository="toDoRepository"
    command-bus="commandBus" />

<axon:filesystem-event-store id="eventStore"
    base-dir="events" />


<bean
    class="org.axonframework.commandhandling.gateway.CommandGatewayFactoryBean">
    <property name="commandBus" ref="commandBus" />
</bean>

<axon:annotation-config />
<bean class="com.my.axon.ToDoEventHandler" />

<bean class="com.my.axon.AopConfigurator"></bean>

ToDoEventHandler クラスの前/後に、呼び出されたすべてのメソッドでアスペクトの前後をログに記録できるようにしたいので、アスペクトを作成して構成しました。

/**
 * This class is used to configure the AOP related beans 
 * instead of doing the entries the beans are configured here and the
 * same effect is achieved using @EnableAspectJAutoProxy annotation. 
 * @author anand.kadhi
 *
 */
@Configuration
@EnableAspectJAutoProxy
public class AopConfigurator {

    @Bean
    public AspectRunner aspectOperation()
    {
        return new AspectRunner();
    }   
}

とアスペクト

    @Aspect 
    public class AspectRunner {

        /**
         * This pointcut will call respective before and after method execution 
         * points
         */
        @Pointcut("execution(* com.my.axon.ToDoEventHandler.*(..))")
        public void logging(){};

        @Before("logging()")
        public void entering(JoinPoint joinPoint)
        {

            System.out.println("After completing Class : "+joinPoint.getTarget().getClass().getName() +" and method : "+joinPoint.getSignature().getName());
        }

        @After("logging()")
        public void exiting(JoinPoint joinPoint)
        {
            System.out.println("After completing Class : "+joinPoint.getTarget().getClass().getName() +" and method : "+joinPoint.getSignature().getName());


        }
    }

メインクラスがあります

public class ToDoItemRunner {

private CommandGateway commandGateway;

public ToDoItemRunner(CommandGateway commandGateway) {
    this.commandGateway = commandGateway;
}

public static void main(String[] args) {
    ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring-axon.xml");
    ToDoItemRunner runner = new ToDoItemRunner(applicationContext.getBean(CommandGateway.class));
    runner.run();
}

private void run() {
    final String itemId = UUID.randomUUID().toString();
    commandGateway.send(new CreateToDoItemCommand(itemId, "Need to do this"));
    commandGateway.send(new MarkCompletedCommand(itemId));
}

}

ToDoEventHandler クラスの前/後に i と呼ばれるすべてのメソッドが、アスペクトの前後にログを記録できるようにする必要があります。

前もって感謝します。

4

0 に答える 0