c - AMQP RabbitMQ consumers blocking eachother? -


"itemprop =" text ">

I have coded a C (RabbitMQ-C) worker application which is published by a linear Python script (pica) consumption.

I have the following strange behavior that I can not seem to solve:

  1. Launching all the workers before the messages are published, the expected work
  2. 1 workers have been published as queue after the start of work
  3. However: after the start of additional workers means a worker has started taking from the queue That those workers (any message on the queue Do not see the message count = 0) and therefore just wait (there are still many messages in the queue due to the incident) The killing of the first worker will begin suddently messages all flown for waiting in all other (waiting) consumers.

Any ideas what can be happening?

I am sure that every consumer has its own channel (is it necessary?) But still the same behavior ...

Consumers ( Worker) Here's the code for: 

  conn = amqp_new_connection (); Sock = (amqp_socket_t *) (uint64_t) amqp_tcp_socket_new (conn); Amqp_socket_open (Sock, "Localhost", 5672); Amqp_login (conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"); If (amqp_channel_open (conn, chan) == faucet) LOG_ERR ("[!! Amqp failed to open channel! \ N"); LOG_ERR ("Queue \ N to fail to declare [!]" If ((Q = amqp_queue_declare (cone, chan, amqp_cstring_bytes ("borders"), 0, 0, 0, 0, amqp_empty_table)) == ; LOG_INFO ("[x] line (message count =% d) \ n", q- & gt; message_number); Amqp_queue_bind (conn, chan, amqp_cstring_bytes ("ranges"), amqp_empty_bytes, amqp_empty_table); Amqp_basic_consume (cone, chan, amqp_cstring_bytes ("borders"), amqp_empty_bytes, 0, 0, 0, amqp_empty_table); While (1) {amqp_maybe_release_buffers (conn); Amqp_consume_message (conn, & amp; e, NULL, 0); {Int n; Amqp_frame_t f; Unsigned char buff [8]; Unsigned char * pbuf = buf; Amqp_simple_wait_frame (conn, & amp; amp; f); // METHOD frame amqp_simple_wait_frame (conn, & amp; f); // header frame n = f.payload.properties.body_size; If (n! = Sizeof (range_buf) LOG_ERR ("[!] Invalid message size!"); While (n) {amqp_simple_wait_frame (conn, & amp; f); // Body Frame Mempie (PBF, FPLod.ad_framement.bites, FPLod.ID_framement.lann); N - = f.payload.body_fragment.len; Pbuf + = f.payload.body_fragment.len; } // something with the buff LOG_INFO ("Message received from [x] queue \ n"); } Amqp_destroy_envelope (& amp; A); Amqp_maybe_release_buffers (Conn); }

The problem here is most likely that all messages are pre-installed when your user starts - Receives. This is the default behavior by RabbitMQ, but if you can reduce the number of messages brought before by the consumer, then you better allow to spread the workload across multiple workers.

This means that one or more consumers will pick up all the messages, and none will leave the new consumers.

If you apply QoZ to your subscriber and limit pre-fetch to say 10 messages. Consumers will queue up to only 10 first messages, and new users can lift loose.

The function you are looking at to implement it is called, and in addition to this you get the consumer- prefetch


-

Comments

Post a Comment

Popular posts from this blog

sqlite3 - UPDATE a table from the SELECT of another one -

I have the first table article where some data is missing. In the table, articles_tmp I have a part of the missing data. So I want to update the articles. Where the path path is data in articles_tmp.path where the path is not zero . With SQLite , it does not work: update article SET path = (SELECT at.path FROM Articles_tmp as AS, WHERE at.article_id = a.id and a.asp, the text is in the form and not on. It has been transmitted) where the path is null MS Access Along with, it works fine: Update Articles Join the Inner Articles at articles_tmp articles.id = articles_tmp.id SETP articles.path = articles_tmp.path Can anyone help? Sin CE SQL Server Syntax, which I provided, was not working, here this solution With whom I have come. A little modification of your original query, but with my "correlation" suggestion added. There is a SQL Bella for this: Here is the code: update article SET path = (SELECT path from articles_tmp AS T WHERE t.id
Read more

c# - Showing a SelectedItem's Property -

So I have enabled a rightclick option for my DataGrid. I want to display the only chosen property but it is not behaving like what I would like it to display my name and additional. Public category Paymentinfo {public int PaymentNo {get; Set; } Public string date {get; Set; } Public Double Pay {get; Set; } Public Double Principle {get; Set; } Public Double Interest {get; Set; } Public Double Balance {Received; Set; }} Private Zero MenuItem_OnClick (Object Sender, RoutedEventArgs e) {MessageBox.Show (AmortGrid.SelectedItem.ToString ()); } I'm trying to apply it without using a View Module! If I place a breakpoint where the messagebox and the recipient place it on selected ITEM, then this property will display the payment. A date-payment-principle-interest-balance is the only value that needs payment. Was hoping that it would be something like this MessageBox.Show (AmortGrid.SelectedItem.PaymentNo.ToString ()); When you call ToString () So you get the class typ
Read more

javascript - Render HTML after each iteration in loop -

I'm trying to gradually increase the font size of text on a web page. The code works in my place, although the new HTML / CSS does not render after every iteration of the loop and when all this is done, then display only the text of 100 px size. To see the text as if it is slowly zooming, I need to do this JavaScript is down because it is being used from a different file here is what I have ... < Pre> & lt; P class = "game-title" style = "font-size: 50px" & gt; Test & lt; / P & gt; Function sleep (milliseconds) {var start = new date (). GetTime (); For (var i = 0; i & lt; 1e7; i ++) {if ((new date). GetTime () - start) & gt; Milliseconds {break; CSS ('font-size', 'parseInt ($ (' game-title '). CSS (' font-size ')) + 1 + "pixels"); } While (parasont ($ ('# text'). Css ('font-size')) & lt; = 100) {sleep (1000); IncreaseSize (); Using CSS: Use of jQuery (sample):
Read more