java - SQS message acknowledgement -


my sring boot application listens amazon sqs queue. right need implement correct message acknowledgement - need receive message, business logic after in case of success need ack message(delete message queue). example, in case of error in business logic message must re-enqueued.

this sqs config:

    /**      * aws credentials bean      */     @bean     public awscredentials awscredentials() {         return new basicawscredentials(accesskey, secretaccesskey);     }      /**      * aws client bean      */     @bean     public amazonsqs amazonsqsasyncclient() {         amazonsqs sqsclient = new amazonsqsclient(awscredentials());         sqsclient.setregion(region.getregion(regions.us_east_1));         return sqsclient;     }      /**      * aws connection factory      */     @bean     public sqsconnectionfactory connectionfactory() {         sqsconnectionfactory.builder factorybuilder = new sqsconnectionfactory.builder(                 region.getregion(regions.us_east_1));         factorybuilder.setawscredentialsprovider(new awscredentialsprovider() {              @override             public awscredentials getcredentials() {                 return awscredentials();             }              @override             public void refresh() {             }          });         return factorybuilder.build();     }      /**      * registering queuelistener queuename      */     @bean     public defaultmessagelistenercontainer defaultmessagelistenercontainer() {         defaultmessagelistenercontainer messagelistenercontainer = new defaultmessagelistenercontainer();         messagelistenercontainer.setconnectionfactory(connectionfactory());         messagelistenercontainer.setmessagelistener(new messagelisteneradapter(new myqueuelistener()));         messagelistenercontainer.setdestinationname(queuename);          return messagelistenercontainer;     }

my queue listener:

public class myqueuelistener {      public void handlemessage(string messagecontent) throws jmsexception {         //do job         //todo: ack message     } }

right don't know how ack message listener.

normally defaultmessagelistenercontainer acknowledges message before or after execution of handlemessage automatically. don't need anything.

but recommended defaultmessagelistenercontainer use transactions instead of client ack mode. not sure if amazon sqs has such option.


-

Comments

Post a Comment

Popular posts from this blog

c# - Binding a comma separated list to a List<int> in asp.net web api -

the default binder in web api expecst http://url.com/webapi/report/?pageids=3243&pageids=2365 to bind public ihttpactionresult report(list<int> pageids){ // exciting webapi code} i wish bind http://url.com/webapi/report/?pageids=3243,2365 as running out of space in url get . i have created class public class commaseparatedmodelbinder : system.web.http.modelbinding.imodelbinder { public bool bindmodel(httpactioncontext actioncontext, modelbindingcontext bindingcontext) { //binding in here } } and registered in webapiconfig.cs var provider = new simplemodelbinderprovider( typeof(list<int>), new commaseparatedmodelbinder()); config.services.insert(typeof(modelbinderprovider), 0, provider); i have altered method signature use model binder so public ihttpactionresult report( [modelbinder] list<int> pageids){ // exciting webapi code} however break point in binder not being
Read more

Delphi 7 and decode UTF-8 base64 -

in delphi 7, have widestring encoded base64(that received web service widestring result) : pd94bwwgdmvyc2lvbj0ims4wij8+dqo8c3ryaw5nptiq2lpyqjwvc3ryaw5npg== when decoded it, result not utf-8: <?xml version="1.0"?> <string>طھط³طھ</string> but when decoded base64decode.org, result true : <?xml version="1.0"?> <string>تست</string> i have use encddecd unit decodestring function. the problem have using decodestring . function, in delphi 7, treats decoded binary data being ansi encoded. , problem text utf-8 encoded. to continue encddecd unit have couple of options. can switch decodestream . instance, code produce utf-8 encoded text file data: {$apptype console} uses classes, encddecd; const data = 'pd94bwwgdmvyc2lvbj0ims4wij8+dqo8c3ryaw5nptiq2lpyqjwvc3ryaw5npg=='; var input: tstringstream; output: tfilestream; begin input := tstringstream.create(data); try output := tfilestream.
Read more

html - Is there any way to exclude a single element from the style? (Bootstrap) -

so, have img logo, overlaid on div styled background-image: url("...") , , both elements inside 2 div classes .to-color , .to-overlay respectively, black transparent overlay. is there way exclude logo style given these 2 classes? here's jsfiddle example: link html , css example: - html - <div class="to-color"> <div class="to-overlay"> <div class="respo"> <div class="row"> <div class="col-xs-4 col-xs-offset-4 text-center"> <img src="http://ansonalex.com/wp-content/uploads/2011/06/google-logo-768x260.png" alt="..." class="img-responsive"> </div> </div> </div> </div> </div> - css - .to-color { background-color: #000; } .to-overlay { opacity : 0.5; } .respo { background-image: url("https://source.unsplash.com/category/objects/1600x900"); background-position: center center;
Read more