code: protected Message produceMessage(Tuple input) {
      return Message.forSending(
          extractBody(input),
          specifyHeaders(input),
          determineExchangeName(input),
          determineRoutingKey(input),
          specifyContentType(input),
          specifyContentEncoding(input),
          specifyMessagePersistence(input)
      );
    }
docs: Convert the incoming {@link Tuple} on the Storm stream to a {@link Message}
  for posting to RabbitMQ.
  
  @param input
  The incoming {@link Tuple} from Storm
  @return The {@link Message} for the {@link RabbitMQProducer} to publish. If
  transformation fails this should return Message.NONE.