How to Get all the pending tasks and purge queue in Pika RabbitMQ












0















I want to get all the pending tasks in the queue to save in database.
and remove those tasks from the queue.



I know channel.purgeQueue but it will only remove them.



I need to know the pending tasks in the queue.



How to get them










share|improve this question



























    0















    I want to get all the pending tasks in the queue to save in database.
    and remove those tasks from the queue.



    I know channel.purgeQueue but it will only remove them.



    I need to know the pending tasks in the queue.



    How to get them










    share|improve this question

























      0












      0








      0








      I want to get all the pending tasks in the queue to save in database.
      and remove those tasks from the queue.



      I know channel.purgeQueue but it will only remove them.



      I need to know the pending tasks in the queue.



      How to get them










      share|improve this question














      I want to get all the pending tasks in the queue to save in database.
      and remove those tasks from the queue.



      I know channel.purgeQueue but it will only remove them.



      I need to know the pending tasks in the queue.



      How to get them







      python rabbitmq queue pika






      share|improve this question













      share|improve this question











      share|improve this question




      share|improve this question










      asked Nov 23 '18 at 14:04









      Shan KhanShan Khan

      3,23143470




      3,23143470
























          1 Answer
          1






          active

          oldest

          votes


















          0














          This is a basic RabbitMQ functionality, please read this:



          https://www.rabbitmq.com/tutorials/tutorial-two-python.html



          The code you are looking of is:



          def callback(ch, method, properties, body):
          print " [x] Received %r" % (body,)
          ### PUT_YOUR_CODE_HERE
          print " [x] Done"
          ch.basic_ack(delivery_tag = method.delivery_tag)

          channel.basic_consume(callback,
          queue='hello')


          When you execute the ch.basic_ack the message is removed from the queue






          share|improve this answer


























          • I want to run some function in the consumer when main purge is called in order to persist its messages.

            – Shan Khan
            Nov 23 '18 at 15:19











          • @ShanKhan is enough to put your code inside the callback, I modified the answer

            – Gabriele
            Nov 23 '18 at 15:45











          Your Answer






          StackExchange.ifUsing("editor", function () {
          StackExchange.using("externalEditor", function () {
          StackExchange.using("snippets", function () {
          StackExchange.snippets.init();
          });
          });
          }, "code-snippets");

          StackExchange.ready(function() {
          var channelOptions = {
          tags: "".split(" "),
          id: "1"
          };
          initTagRenderer("".split(" "), "".split(" "), channelOptions);

          StackExchange.using("externalEditor", function() {
          // Have to fire editor after snippets, if snippets enabled
          if (StackExchange.settings.snippets.snippetsEnabled) {
          StackExchange.using("snippets", function() {
          createEditor();
          });
          }
          else {
          createEditor();
          }
          });

          function createEditor() {
          StackExchange.prepareEditor({
          heartbeatType: 'answer',
          autoActivateHeartbeat: false,
          convertImagesToLinks: true,
          noModals: true,
          showLowRepImageUploadWarning: true,
          reputationToPostImages: 10,
          bindNavPrevention: true,
          postfix: "",
          imageUploader: {
          brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
          contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
          allowUrls: true
          },
          onDemand: true,
          discardSelector: ".discard-answer"
          ,immediatelyShowMarkdownHelp:true
          });


          }
          });














          draft saved

          draft discarded


















          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53448147%2fhow-to-get-all-the-pending-tasks-and-purge-queue-in-pika-rabbitmq%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown

























          1 Answer
          1






          active

          oldest

          votes








          1 Answer
          1






          active

          oldest

          votes









          active

          oldest

          votes






          active

          oldest

          votes









          0














          This is a basic RabbitMQ functionality, please read this:



          https://www.rabbitmq.com/tutorials/tutorial-two-python.html



          The code you are looking of is:



          def callback(ch, method, properties, body):
          print " [x] Received %r" % (body,)
          ### PUT_YOUR_CODE_HERE
          print " [x] Done"
          ch.basic_ack(delivery_tag = method.delivery_tag)

          channel.basic_consume(callback,
          queue='hello')


          When you execute the ch.basic_ack the message is removed from the queue






          share|improve this answer


























          • I want to run some function in the consumer when main purge is called in order to persist its messages.

            – Shan Khan
            Nov 23 '18 at 15:19











          • @ShanKhan is enough to put your code inside the callback, I modified the answer

            – Gabriele
            Nov 23 '18 at 15:45
















          0














          This is a basic RabbitMQ functionality, please read this:



          https://www.rabbitmq.com/tutorials/tutorial-two-python.html



          The code you are looking of is:



          def callback(ch, method, properties, body):
          print " [x] Received %r" % (body,)
          ### PUT_YOUR_CODE_HERE
          print " [x] Done"
          ch.basic_ack(delivery_tag = method.delivery_tag)

          channel.basic_consume(callback,
          queue='hello')


          When you execute the ch.basic_ack the message is removed from the queue






          share|improve this answer


























          • I want to run some function in the consumer when main purge is called in order to persist its messages.

            – Shan Khan
            Nov 23 '18 at 15:19











          • @ShanKhan is enough to put your code inside the callback, I modified the answer

            – Gabriele
            Nov 23 '18 at 15:45














          0












          0








          0







          This is a basic RabbitMQ functionality, please read this:



          https://www.rabbitmq.com/tutorials/tutorial-two-python.html



          The code you are looking of is:



          def callback(ch, method, properties, body):
          print " [x] Received %r" % (body,)
          ### PUT_YOUR_CODE_HERE
          print " [x] Done"
          ch.basic_ack(delivery_tag = method.delivery_tag)

          channel.basic_consume(callback,
          queue='hello')


          When you execute the ch.basic_ack the message is removed from the queue






          share|improve this answer















          This is a basic RabbitMQ functionality, please read this:



          https://www.rabbitmq.com/tutorials/tutorial-two-python.html



          The code you are looking of is:



          def callback(ch, method, properties, body):
          print " [x] Received %r" % (body,)
          ### PUT_YOUR_CODE_HERE
          print " [x] Done"
          ch.basic_ack(delivery_tag = method.delivery_tag)

          channel.basic_consume(callback,
          queue='hello')


          When you execute the ch.basic_ack the message is removed from the queue







          share|improve this answer














          share|improve this answer



          share|improve this answer








          edited Nov 23 '18 at 15:45

























          answered Nov 23 '18 at 14:59









          GabrieleGabriele

          14.7k42334




          14.7k42334













          • I want to run some function in the consumer when main purge is called in order to persist its messages.

            – Shan Khan
            Nov 23 '18 at 15:19











          • @ShanKhan is enough to put your code inside the callback, I modified the answer

            – Gabriele
            Nov 23 '18 at 15:45



















          • I want to run some function in the consumer when main purge is called in order to persist its messages.

            – Shan Khan
            Nov 23 '18 at 15:19











          • @ShanKhan is enough to put your code inside the callback, I modified the answer

            – Gabriele
            Nov 23 '18 at 15:45

















          I want to run some function in the consumer when main purge is called in order to persist its messages.

          – Shan Khan
          Nov 23 '18 at 15:19





          I want to run some function in the consumer when main purge is called in order to persist its messages.

          – Shan Khan
          Nov 23 '18 at 15:19













          @ShanKhan is enough to put your code inside the callback, I modified the answer

          – Gabriele
          Nov 23 '18 at 15:45





          @ShanKhan is enough to put your code inside the callback, I modified the answer

          – Gabriele
          Nov 23 '18 at 15:45


















          draft saved

          draft discarded




















































          Thanks for contributing an answer to Stack Overflow!


          • Please be sure to answer the question. Provide details and share your research!

          But avoid



          • Asking for help, clarification, or responding to other answers.

          • Making statements based on opinion; back them up with references or personal experience.


          To learn more, see our tips on writing great answers.




          draft saved


          draft discarded














          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53448147%2fhow-to-get-all-the-pending-tasks-and-purge-queue-in-pika-rabbitmq%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown





















































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown

































          Required, but never shown














          Required, but never shown












          Required, but never shown







          Required, but never shown







          Popular posts from this blog

          404 Error Contact Form 7 ajax form submitting

          How to know if a Active Directory user can login interactively

          TypeError: fit_transform() missing 1 required positional argument: 'X'