Class MultiMethodKafkaListenerEndpoint<K,V>

Type Parameters:
K - the key type.
V - the value type.
All Implemented Interfaces:
Aware, BeanFactoryAware, InitializingBean, KafkaListenerEndpoint

public class MultiMethodKafkaListenerEndpoint<K,V> extends MethodKafkaListenerEndpoint<K,V>
The MethodKafkaListenerEndpoint extension for several POJO methods based on the KafkaHandler.
Author:
Gary Russell, Wang Zhiyang
See Also:
  • Constructor Details

    • MultiMethodKafkaListenerEndpoint

      public MultiMethodKafkaListenerEndpoint(List<Method> methods, @Nullable Method defaultMethod, Object bean)
      Construct an instance for the provided methods, default method and bean.
      Parameters:
      methods - the methods.
      defaultMethod - the default method.
      bean - the bean.
      Since:
      2.1.3
  • Method Details

    • getMethods

      public List<Method> getMethods()
      Get a method list.
      Returns:
      the method list.
      Since:
      3.2
    • setMethods

      public void setMethods(List<Method> methods)
      Set a method list.
      Parameters:
      methods - the methods.
      Since:
      3.2
    • getDefaultMethod

      public Method getDefaultMethod()
      Get a default method.
      Returns:
      the default method.
      Since:
      3.2
    • setDefaultMethod

      public void setDefaultMethod(Method defaultMethod)
      Set a default method.
      Parameters:
      defaultMethod - the default method.
      Since:
      3.2
    • setValidator

      public void setValidator(Validator validator)
      Set a payload validator.
      Parameters:
      validator - the validator.
      Since:
      2.5.11
    • configureListenerAdapter

      protected HandlerAdapter configureListenerAdapter(MessagingMessageListenerAdapter<K,V> messageListener)
      Description copied from class: MethodKafkaListenerEndpoint
      Create a HandlerAdapter for this listener adapter.
      Overrides:
      configureListenerAdapter in class MethodKafkaListenerEndpoint<K,V>
      Parameters:
      messageListener - the listener adapter.
      Returns:
      the handler adapter.