New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Protobuf MessageConverter in spring-messaging for use with STOMP #24022
Comments
Currently there isn't a MessageConverter in |
I created a converter that suits my needs (took a clue from ByteArrayMessageConverter). Thanks for adding this to 5.x backlog Regards, |
Could i take this task ? |
Yes, it is marked "ideal-for-contribution" and that means we've already identified it as something that should be straight-forward to address. |
Please check my PR #24087. |
This is now superseded by #24087. |
…amework into read_yuyang * 'master' of https://github.com/spring-projects/spring-framework: Allow ExchangeStrategies customizations in WebClient Delete unused JdbcTemplate fields in examples Polish BatchPreparedStatementSetter example in reference manual Fix examples for <tx:method/> settings in reference manual Enable reading from the remote build cache for all Introduce Checkstyle rule to prohibit class names ending with "Test" Polishing contribution Improve getMultipartContentType in mock request. Polishing contribution spring-projects#24022 - added protobuf MessageConverter Polish StringArrayPropertyEditor[Tests]
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
orMessageConversionException: 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
The text was updated successfully, but these errors were encountered: