Package org.axonframework.messaging.queryhandling.interception

Class QueryMessageHandlerInterceptorChain

java.lang.Object

org.axonframework.messaging.queryhandling.interception.QueryMessageHandlerInterceptorChain

All Implemented Interfaces:

MessageHandlerInterceptorChain<QueryMessage>

@Internal
public class QueryMessageHandlerInterceptorChain
extends Object
implements MessageHandlerInterceptorChain<QueryMessage>

A MessageHandlerInterceptorChain that intercepts QueryMessages for QueryHandlers.

Since:

5.0.0

Author:

Allard Buijze, Simon Zambrovski, Steven van Beelen

Constructor Summary

Constructors

Constructor	Description
QueryMessageHandlerInterceptorChain(List<MessageHandlerInterceptor<? super QueryMessage>> interceptors, QueryHandler queryHandler)	Constructs a new QueryMessageHandlerInterceptorChain with a list of interception and an queryHandler.

Method Summary

Modifier and Type	Method	Description
MessageStream<?>	proceed(QueryMessage query, ProcessingContext context)	Signals this interceptor chain to continue processing the message.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueryMessageHandlerInterceptorChain

public QueryMessageHandlerInterceptorChain(@Nonnull
 List<MessageHandlerInterceptor<? super QueryMessage>> interceptors,
 @Nonnull
 QueryHandler queryHandler)

Constructs a new QueryMessageHandlerInterceptorChain with a list of interception and an queryHandler.

Parameters:

interceptors - The list of handler interception that are part of this chain.

queryHandler - The query handler to be invoked at the end of the interceptor chain.

Method Details

proceed

@Nonnull
public MessageStream<?> proceed(@Nonnull
 QueryMessage query,
 @Nonnull
 ProcessingContext context)

Description copied from interface: MessageHandlerInterceptorChain

Signals this interceptor chain to continue processing the message.

Specified by:

proceed in interface MessageHandlerInterceptorChain<QueryMessage>

Parameters:

query - The message to pass down the chain.

context - The active processing context the given message is being processed in.

Returns:

A MessageStream containing the result of processing the given message.