spring - Java RabbitMQ consumer.nextMessage always gets same message -


we using java rabbitmq spring boot in distributed service architecture. 1 service gets http request , forwards unkown queue processing. @ same time has wait response on queue before can terminate http request. (it's preview request gets work done renderer).

there can more 1 instance of servicea (the http interface) , serviceb (the renderer) every preview message send unique id used routing key.

i'm having trouble blockingconsumer. whenever call consumer.nextmessage() same message on , on again. doubly weird, 1 should acked , removed queue , consumer shouldn't bother unique id used no longer bound queue. nextmessage returns before renderer service done , has sent done message back.

here's simplified setup:

general

all services use global directexchange messages 

@bean   public directexchange globaldirectexchange() {     return new directexchange(exchange_name, false, true);   }

servicea (handles http request): 

 private content requestpreviewbykey(rendermessage rendermessage, string previewkey) {     string renderdoneroutingkey= uuid.randomuuid().tostring();     rendermessage.setpreviewdonekey(renderdoneid);     binding binding = bindingbuilder.bind(previewdonequeue).to(globaldirectexchange)         .with(renderdoneroutingkey);     try {       amqpadmin.declarebinding(binding);       rabbitproducer.sendpreviewrequesttokey(rendermessage, previewkey);       return getcontentblocking();     } catch (exception e) {       logerrorifdebug(type, e);       throw new apiexception(baseerrorcode.communication_error, "could not render preview");     } {       amqpadmin.removebinding(binding);     }   }     private content getcontentblocking() {     blockingqueueconsumer blockingqueueconsumer = new blockingqueueconsumer(rabbitmqconfig.connectionfactory(), new defaultmessagepropertiesconverter(), new activeobjectcounter<>(), acknowledgemode.auto, true, 1, preview_done_queue);     try {       blockingqueueconsumer.start();       message message = blockingqueueconsumer.nextmessage(waitforpreviewms);       if (!stringutils.isempty(message)) {         string result = new string(message.getbody());         return jsonutils.stringtoobject(result, content.class);       }           throw new apiexception("could not render preview");     } catch (exception e) {       logerror(e);       throw new apiexception("could not render preview");     } {       blockingqueueconsumer.stop();     }

}

service b

i'll spare of code. log says going , done service sends correct message uuid key sent initial render request. 

public void sendpreviewdonemessage(content content, string previewdonekey) {     string message = jsonutils.objecttostring(content);     rabbittemplate.convertandsend(globaldirectexchange, previewdonekey, message); }

the whole thing works... once... real issues seems consumer setup. why keep getting same (first) message queue when use nextmessage(). doesn't creating , removing bindung ensure, messages bound routingkey received in instance? , doesn't nextmessage() acknowledge message , remove queue?!

thank's lot bearing me , more helpful answer!

blockingqueueconsumer not designed used directly; component of simplemessagelistenercontainer, take care of acking message after has been consumed listener (the container calls commitifnecessary).

there may other unexpected side effects of using consumer directly.

i advise using listener container consume messages.

if want receive messages on demand, use rabbittemplate receive() or receiveandconvert() method instead.


Comments

Post a Comment

Popular posts from this blog

angular - Ionic slides - dynamically add slides before and after -

hi i'm using ngfor create set of 3 slides while starting in middle i'm guaranteed able slide left or right on start. when slide right can simple listen reachedend , push slide array i'm looping. but have problem adding slide beginning. if same above , use e.g. array.unshift() or spread add item beginning, view think it's on position 0 , snaps view new slide. the code below work animates slide change index 1. slide = [0,1,2] //example loop slidechanged(event) { if(this.slides.isbeginning()){ this.slide = [this.slide[0]-1, ...this.slide]; this.slides.update(); this.slides.slideto(1) } } <ion-slides [initialslide]="1" (ionslidedidchange)="slidechanged($event)"> <ion-slide *ngfor="let item of slide"> <h1>slide {{item}}</h1> </ion-slide> </ion-slides> any appreciated! you can using ionslidenextend , ionslideprevend events slides . please
Read more

minify - Minimizing css files -

i want know how css files can minimized. currently, using external sites css minifier compress css files. however, after removing whitespaces, comments, etc, file sizes reduced 10-15%. how frameworks bootstrap manage make minimized versions kilobytes. as example, css is: body { background-color: #ff0; } the reduction goes 28 bytes 22 bytes other css files have lot more characters still smaller this. actually minifying code means it's remove thing code white space characters new line characters comments block delimiters it reduces amount of code has transferred on web , speed site load fastly.but unreadable format.
Read more

Add a dynamic header in angular 2 http provider -

i have http interceptor built via tutorial https://scotch.io/@kashyapmukkamala/using-http-interceptor-with-angular2 the problem need have dynamic header changes automatically once changes 'mode' in app. service able tell interceptor change header, or have interceptor pull header (which string)from service each request. able throwing away patch method, call http.patch('new header string') set header string. call in service controls 'mode' setting. wondering if there way interceptor pull recent value service each request or if can add method http provider via interceptor? i've tried call service in interceptor each request returns undefined. because creating new instance of service or copying value before service fired , loaded/changed data. i don't want pass header string every http provider call because defeats purpose of having interceptor, id able set once changes or have provider fetch service before makes request. tl;dr : need add autom
Read more