Package org.springframework.kafka.listener.adapter

Class HandlerAdapter

java.lang.Object

org.springframework.kafka.listener.adapter.HandlerAdapter

public class HandlerAdapter
extends Object

A wrapper for either an InvocableHandlerMethod or DelegatingInvocableHandler. All methods delegate to the underlying handler.

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
HandlerAdapter(DelegatingInvocableHandler delegatingHandler)	Construct an instance with the provided delegating handler.
HandlerAdapter(InvocableHandlerMethod invokerHandlerMethod)	Construct an instance with the provided method.

Method Summary

Modifier and Type	Method	Description
Object	getBean()
InvocationResult	getInvocationResultFor(Object result, Object inboundPayload)
String	getMethodAsString(Object payload)
Object	invoke(Message<?> message, Object... providedArgs)
boolean	isAsyncReplies()	Return true if any handler method has an async reply type.

Methods inherited from class java.lang.Object

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

Constructor Details

HandlerAdapter

public HandlerAdapter(InvocableHandlerMethod invokerHandlerMethod)

Construct an instance with the provided method.

Parameters:

invokerHandlerMethod - the method.

HandlerAdapter

public HandlerAdapter(DelegatingInvocableHandler delegatingHandler)

Construct an instance with the provided delegating handler.

Parameters:

delegatingHandler - the handler.

Method Details

isAsyncReplies

public boolean isAsyncReplies()

Return true if any handler method has an async reply type.

Returns:

the asyncReply.

Since:

3.2

invoke

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

Throws:

Exception

getMethodAsString

public String getMethodAsString(Object payload)

getBean

public Object getBean()

getInvocationResultFor

@Nullable
public InvocationResult getInvocationResultFor(Object result,
 @Nullable
 Object inboundPayload)