i have customer converter implements messageconverter interface. however, dont see way register simplemessagelistenercontainerfactory. result error when try read message sqs in source format doesnt know how convert target object.
i looked through sqsconfiguration class , see simplemessagelistenercontainer bean being defined has queuemessagehandler set on it. queuemessagehandler has resolvers on it, 1 of compositemessageconverter takes collection of messageconverter types. guessing somehow need add custom messageconverter collection. cant seem handle how can that.
can help me point wayi can register customer messagemapper?
from can tell, way create own queuemessagehandlerfactory
whatever resolvers/converters need.
for example, add @configuration
class:
@bean public queuemessagehandlerfactory queuemessagehandlerfactory() { list<messageconverter> converters = ... compositemessageconverter converter = new compositemessageconverter(converters); queuemessagehandlerfactory factory = new queuemessagehandlerfactory(); factory.setargumentresolvers(arrays.aslist(new payloadargumentresolver(converter)); return factory; }
sqsconfiguration
should pick queuemessagehandlerfactory
bean won't create 1 itself.