client/src/main/java/io/hoplin/DefaultQueueConsumer.java
/**
   * Add new handler bound to a specific type
   *
   * @param clazz
   * @param handler
   * @param <T>
   */
Add new handler bound to a specific type
@param clazz
@param handler
@param 
Add new handler bound to a specific type @param clazz @param handler @param
public synchronized <T> void addHandler(final Class<T> clazz,
      final BiFunction<T, MessageContext, Reply<?>> handler) {
    Objects.requireNonNull(clazz);
    Objects.requireNonNull(handler);
    Class<? super T> clz = clazz;
    while (clz != Object.class) {
      handlers.put(clz, MethodReference.of(clazz, handler));
      clz = clz.getSuperclass();
    }
    log.info("Adding handlers : {}", handlers);
  }
public synchronized < T > void addHandler ( final Class < T > clazz , final BiFunction < T , MessageContext , Reply < ? > > handler ) { Objects . requireNonNull ( clazz ) ; Objects . requireNonNull ( handler ) ; Class < ? super T > clz = clazz ; while ( clz != Object . class ) { handlers . put ( clz , MethodReference . of ( clazz , handler ) ) ; clz = clz . getSuperclass ( ) ; } log . info ( "Adding handlers : {}" , handlers ) ; }
Add new handler bound to a specific type
 @param clazz
 @param handler
 @param <T>
Add new handler bound to a specific type @param clazz @param handler @param <T >