@Test void handlerInterceptorRegisteredWithLocalSegment() { MessageHandlerInterceptor<QueryMessage<?, ?>> interceptor = (unitOfWork, interceptorChain) -> interceptorChain.proceed(); testSubject.registerHandlerInterceptor(interceptor); verify(localSegment).registerHandlerInterceptor(interceptor); }
@Override public Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?, ?>> interceptor) { return localSegment.registerHandlerInterceptor(interceptor); }
AxonServerQueryBus implements QueryBus, Distributed<QueryBus> { @Override public Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?, ?>> interceptor) { return localSegment.registerHandlerInterceptor(interceptor); } }
AxonServerQueryBus implements QueryBus, Distributed<QueryBus> { @Override public Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?, ?>> interceptor) { return localSegment.registerHandlerInterceptor(interceptor); } AxonServerQueryBus(Builder builder); }
AxonServerQueryBus implements QueryBus, Distributed<QueryBus> { @Override public Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?, ?>> interceptor) { return localSegment.registerHandlerInterceptor(interceptor); } AxonServerQueryBus(Builder builder); static Builder builder(); @StartHandler(phase = Phase.INBOUND_QUERY_CONNECTOR) void start(); @Override Registration subscribe(String queryName,
                                      Type responseType,
                                      MessageHandler<? super QueryMessage<?, R>> handler); @Override CompletableFuture<QueryResponseMessage<R>> query(QueryMessage<Q, R> queryMessage); @Override Stream<QueryResponseMessage<R>> scatterGather(QueryMessage<Q, R> queryMessage,
                                                                long timeout,
                                                                TimeUnit timeUnit); @Override SubscriptionQueryResult<QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> subscriptionQuery(
            SubscriptionQueryMessage<Q, I, U> query,
            SubscriptionQueryBackpressure backPressure,
            int updateBufferSize
    ); @Override QueryUpdateEmitter queryUpdateEmitter(); @Override QueryBus localSegment(); @Override Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?, ?>> interceptor); @Override Registration registerDispatchInterceptor(
            MessageDispatchInterceptor<? super QueryMessage<?, ?>> dispatchInterceptor); @ShutdownHandler(phase = Phase.INBOUND_QUERY_CONNECTOR) void disconnect(); @ShutdownHandler(phase = Phase.OUTBOUND_QUERY_CONNECTORS) CompletableFuture<Void> shutdownDispatching(); }
AxonServerQueryBus implements QueryBus, Distributed<QueryBus> { @Override public Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?, ?>> interceptor) { return localSegment.registerHandlerInterceptor(interceptor); } AxonServerQueryBus(Builder builder); static Builder builder(); @StartHandler(phase = Phase.INBOUND_QUERY_CONNECTOR) void start(); @Override Registration subscribe(String queryName,
                                      Type responseType,
                                      MessageHandler<? super QueryMessage<?, R>> handler); @Override CompletableFuture<QueryResponseMessage<R>> query(QueryMessage<Q, R> queryMessage); @Override Stream<QueryResponseMessage<R>> scatterGather(QueryMessage<Q, R> queryMessage,
                                                                long timeout,
                                                                TimeUnit timeUnit); @Override SubscriptionQueryResult<QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> subscriptionQuery(
            SubscriptionQueryMessage<Q, I, U> query,
            SubscriptionQueryBackpressure backPressure,
            int updateBufferSize
    ); @Override QueryUpdateEmitter queryUpdateEmitter(); @Override QueryBus localSegment(); @Override Registration registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?, ?>> interceptor); @Override Registration registerDispatchInterceptor(
            MessageDispatchInterceptor<? super QueryMessage<?, ?>> dispatchInterceptor); @ShutdownHandler(phase = Phase.INBOUND_QUERY_CONNECTOR) void disconnect(); @ShutdownHandler(phase = Phase.OUTBOUND_QUERY_CONNECTORS) CompletableFuture<Void> shutdownDispatching();  }