code: @Override
      public void onExecute(StreamMessage input)
      {
          StreamMessageHeader header = input.getHeader();
          Object body = input.getBody();
  
          logger.info("ReceiveHeader=" + header.toString() + " ,ReceiveBody="
                  + ToStringBuilder.reflectionToString(body, ToStringStyle.SHORT_PREFIX_STYLE));
      }
docs: {@inheritDoc}