anchor.diff:  [source,java]
   ----
   // Receive payload
  -String payload = consumerTemplate.receiveBody("paho:topic", String.class);
  +String payload = consumerTemplate.receiveBody("paho-mqtt5:topic", String.class);
   
   // Send payload
   String payload = "message";
  -producerTemplate.sendBody("paho:topic", payload);
  +producerTemplate.sendBody("paho-mqtt5:topic", payload);
   ----
   
   
  
positive.code: [source,java]
  ----
  // Receive payload
  byte[] payload = (byte[]) consumerTemplate.receiveBody("paho:topic");
  
  // Send payload
  byte[] payload = "message".getBytes();
  producerTemplate.sendBody("paho:topic", payload);
  ----
  
  But of course Camel build-in xref:manual::type-converter.adoc[type conversion
  
negative.code: ----
  from("direct:test")
      .setHeader(PahoConstants.CAMEL_PAHO_OVERRIDE_TOPIC, simple("${header.customerId}"))
      .to("paho-mqtt5:some/target/queue");
  ----
  
  
  