code: @SuppressWarnings("unchecked")
      @Override
      public void start(final Listener<?> listener, final Infrastructure infra) throws MessageTransportException {
          this.listener = (Listener<Object>) listener;
      }
docs: A receiver is started with a Listener and a threading model.