Queue processing one by one using RabbitMQ -

-


Queue processing one by one using RabbitMQ -

i have limited number of workers , unlimited number of queues named mask "q.*" (e.g. q.1, q.2). need process them in turn. 1 task per 1 worker. when worker finished task, receive new 1 next existing queue.

e.g. have queues:

q.1: task11, task12, task13 q.2: task21, task22, task23

and 3 workers. expect next order of executing:

worker1: task11 worker2: task21 worker3: task12 worker1: task22 worker2: task13 worker3: task23

i tried utilize topic , subscribed mask q.* leads fact each worker receives tasks queues. right decision?

think of each queue it's own bucket of work. q.1 has no relation q.2 @ , in fact doesn't know exists. may process things @ different rates q.2 , should have different consumers. worker on q.1 should concerned q.1, shouldn't bounce , forth between q.1 , q.2.

are trying chain 2 queues together? if have this:

message gets set q.1 message processed worker (call worker1) of q.1 after worker1 acks message inserts new message q.2 message processed worker (call worker2) of q.2

queue rabbitmq

Comments

Post a Comment

Popular posts from this blog

Using Android Volley to post an array to PHP -

-
Using Android Volley to post an array to PHP - this how post values volley: @override protected map<string, string> getparams() { jsonobject jsonobjectmembers=new jsonobject(); (int i=0; i<arr_added_userids.size(); i++) { seek { jsonobjectmembers.put("params_"+i,arr_added_userids.get(i)); } grab (jsonexception e) { e.printstacktrace(); } } map<string, string> params = new hashmap<string, string>(); params.put("host", session_userid); params.put("params",jsonobjectmembers.tostring()); homecoming params; } this tried: foreach($_post['params'] $key => $value) { seek { $stmt = $conn->prepare("insert crewmembers (crewid, member) values (:crewid, :member)"); $query_params = array( ':crewid' => $crewid, ':member' => $value ); ...
Read more

python - How to add an model instance to a django queryset? -

-
python - How to add an model instance to a django queryset? - it seems django queryset behaves somehow python list. but doesn't back upwards list's .append() method know. what want like: from my_django_app.models import mymodel queryset = mymodel.objects.none() queryset.append(mymodel.objects.first()) ## no list's .append() method! is there way add together model instance existing queryset? no. queryset representation of query - hence name - not arbitrary collection of instances. if need actual queryset rather list, seek accumulating ids of objects need , getting objects via __in query: list_of_ids = [] list_of_ids.append(my_id) ... queryset = mymodel.objects.filter(id__in=list_of_ids) this isn't efficient, though. python django
Read more

angularjs - No 'Access-Control-Allow-Origin' error from local domain to public API -

-
angularjs - No 'Access-Control-Allow-Origin' error from local domain to public API - i'm trying create app retrieve stock name, asking , purchase cost yahoo finance api, using restangular. i'm having problem accessing public api in local application i'm creating when request. url parameters i'm sending: http://finance.yahoo.com/d/quotes.csv?s=msft+ge&f=nab using postman, request returns array contains stock name, asking cost , purchase cost of stock. doing request in postman returns desired info without errors. when request in local, next error: xmlhttprequest cannot load http://finance.yahoo.com/d/quotes.csv?s=msft+ge&f=nab. no 'access-control-allow-origin' header nowadays on requested resource. origin 'http://localhost' hence not allowed access. the html code follows: <html ng-app="app"> <head> <title>restangular</title> <script src="https://ajax.googleapis.com/ajax/li...
Read more