Hi,

I have created a ReactorNettyTcpStompClient to connect to RabbitMQ STOMP.

My requirement is to send protobuf ByteString to the destination queue. I tried with all the message converters that are available under org.springframework.messaging.converter package. Either i get MessageDeliveryException: nested exception is java.lang.ClassCastException or MessageConversionException: Unable to convert payload with....

I am thinking of overriding/overloading the send() method of DefaultStompSession class and use it.

Is there any other easier way?

How to use protocol buffers with Spring Messaging?

Thanks,
Strive