code: @Override
      public void startListener(final ReceiveQueueListener<T> listener) {
          queue.startListener(item -> listener.receive(fromJsonFunction.apply(item)));
      }
docs: Start a listener.
  
  @param listener listener