I ended up using a MessageListenerAdapter
with a custom delegate object and JsonMessageConverter
as the MessageConverter
. Like so:
SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer();
listenerContainer.setMessageListener(new MessageListenerAdapter(new EventHandler(), new JsonMessageConverter()));
My EventHandler
class has a single method called handleMessage which gets the deserialized JSON object passed to it.