Package org.springframework.pulsar.listener.adapter

Class DelegatingInvocableHandler

java.lang.Object

org.springframework.pulsar.listener.adapter.DelegatingInvocableHandler

public class DelegatingInvocableHandler
extends Object

Delegates to an InvocableHandlerMethod based on the message payload type. Matches a single, non-annotated parameter or one that is annotated with Payload. Matches must be unambiguous.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
DelegatingInvocableHandler(List<InvocableHandlerMethod> handlers, InvocableHandlerMethod defaultHandler, Object bean, BeanExpressionResolver beanExpressionResolver, BeanExpressionContext beanExpressionContext, BeanFactory beanFactory, Validator validator)

Method Summary

Modifier and Type	Method	Description
protected InvocableHandlerMethod	findHandlerForPayload(Class<? extends Object> payloadClass)
Object	getBean()	Return the bean for this handler.
protected InvocableHandlerMethod	getHandlerForPayload(Class<? extends Object> payloadClass)	Determine the InvocableHandlerMethod for the provided type.
String	getMethodNameFor(Object payload)	Return a string representation of the method that will be invoked for this payload.
boolean	hasDefaultHandler()
Object	invoke(Message<?> message, Object... providedArgs)	Invoke the method with the given message.
protected boolean	matchHandlerMethod(Class<? extends Object> payloadClass, InvocableHandlerMethod handler)

Methods inherited from class java.lang.Object

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

Constructor Details

DelegatingInvocableHandler

public DelegatingInvocableHandler(List<InvocableHandlerMethod> handlers,
 @Nullable
 InvocableHandlerMethod defaultHandler,
 Object bean,
 @Nullable
 BeanExpressionResolver beanExpressionResolver,
 @Nullable
 BeanExpressionContext beanExpressionContext,
 @Nullable
 BeanFactory beanFactory,
 @Nullable
 Validator validator)

Method Details

getBean

public Object getBean()

Return the bean for this handler.

Returns:

the bean.

invoke

public Object invoke(Message<?> message,
 Object... providedArgs)
              throws Exception

Invoke the method with the given message.

Parameters:

message - the message.

providedArgs - additional arguments.

Returns:

the result of the invocation.

Throws:

Exception - raised if no suitable argument resolver can be found, or the method raised an exception.

getHandlerForPayload

protected InvocableHandlerMethod getHandlerForPayload(Class<? extends Object> payloadClass)

Determine the InvocableHandlerMethod for the provided type.

Parameters:

payloadClass - the payload class.

Returns:

the handler.

findHandlerForPayload

@Nullable
protected InvocableHandlerMethod findHandlerForPayload(Class<? extends Object> payloadClass)

matchHandlerMethod

protected boolean matchHandlerMethod(Class<? extends Object> payloadClass,
 InvocableHandlerMethod handler)

getMethodNameFor

public String getMethodNameFor(Object payload)

Return a string representation of the method that will be invoked for this payload.

Parameters:

payload - the payload.

Returns:

the method name.

hasDefaultHandler

public boolean hasDefaultHandler()