Camel Pulsar

[Steve973 <st...@gmail.com>]

Hello.  I am trying to use Pulsar, and the documentation is not super
thorough.  I have set up a server, and my camel app can connect to it.
But, when I try to send a message through it, when I receive it, I cannot
decode it!  I have tried just letting it serialize the pojo, and then
deserialize it when receiving.  That did not work, so I attempted to
convert it to a json string, and then convert it back to a string on
receipt, and then use unmarshal().json().  I searched for camel pulsar
examples, but I haven't found much.  Can anyone point me in the right
direction, please?

Here is what my attempt looks like:

I am running pulsar in a container in standalone mode.

Sending:
ControlMessage message = createSubscribeMessage();
String json = mapper.writeValueAsString(message);
producerTemplate.sendBody(subscribeUri, json);

Receiving:
from(mainRouterConfig.controlEntrypoint())
.convertBodyTo(String.class)
.unmarshal().json(ControlMessage.class)
.process(exchange -> Optional.ofNullable
(exchange.getIn().getBody(ControlMessage.class))

I can either use, or omit, the .convertBodyTo(String.class) part, and the
result is the same:
com.fasterxml.jackson.core.JsonParseException: Unexpected character ('¬'
(code 172)): expected a valid value (JSON String, Number, Array, Object or
token 'null', 'true' or 'false')

Any ideas?

Thanks,
Steve