How to increase autolock timeout on azure service bus using camel











up vote
0
down vote

favorite












I am using azure service bus for my project. I was able to establish the connection through camel amqp following this link Accessing Azure Service Bus with Apache Camel?



Now I am able to read the messages through the service bus queue, but I am having issues in increasing the auto-timeout lock for the messages. I have the set the timeout lock to be 30 seconds in the service bus properties, but for certain messages who need more time I want the time to extend.



I looked for solution online, but couldn't find anything that resolved the issue. I was trying to use backoffmultiplier() available with camel but it failed too.



Below is my implementation of what I have tried so far.



The URI to connect to the queue where I have specified requestTimeout and requestTimeoutChecker



QUEUE_CONNECTION=amqp:queue:testqueue?requestTimeout=4000&requestTimeoutCheckerInterval=3000&acknowledgementModeName=CLIENT_ACKNOWLEDGE&concurrentConsumers=2


The exception handling where I have used backoffmultiplier



onException(Exception.class).
process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
logger.error("Exception in exchange : ",cause);
// we now have the caused exception
}
}).useExponentialBackOff().backOffMultiplier(2).maximumRedeliveries(3);


Am I missing anything here? TIA.










share|improve this question


























    up vote
    0
    down vote

    favorite












    I am using azure service bus for my project. I was able to establish the connection through camel amqp following this link Accessing Azure Service Bus with Apache Camel?



    Now I am able to read the messages through the service bus queue, but I am having issues in increasing the auto-timeout lock for the messages. I have the set the timeout lock to be 30 seconds in the service bus properties, but for certain messages who need more time I want the time to extend.



    I looked for solution online, but couldn't find anything that resolved the issue. I was trying to use backoffmultiplier() available with camel but it failed too.



    Below is my implementation of what I have tried so far.



    The URI to connect to the queue where I have specified requestTimeout and requestTimeoutChecker



    QUEUE_CONNECTION=amqp:queue:testqueue?requestTimeout=4000&requestTimeoutCheckerInterval=3000&acknowledgementModeName=CLIENT_ACKNOWLEDGE&concurrentConsumers=2


    The exception handling where I have used backoffmultiplier



    onException(Exception.class).
    process(new Processor() {
    @Override
    public void process(Exchange exchange) throws Exception {
    Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
    logger.error("Exception in exchange : ",cause);
    // we now have the caused exception
    }
    }).useExponentialBackOff().backOffMultiplier(2).maximumRedeliveries(3);


    Am I missing anything here? TIA.










    share|improve this question
























      up vote
      0
      down vote

      favorite









      up vote
      0
      down vote

      favorite











      I am using azure service bus for my project. I was able to establish the connection through camel amqp following this link Accessing Azure Service Bus with Apache Camel?



      Now I am able to read the messages through the service bus queue, but I am having issues in increasing the auto-timeout lock for the messages. I have the set the timeout lock to be 30 seconds in the service bus properties, but for certain messages who need more time I want the time to extend.



      I looked for solution online, but couldn't find anything that resolved the issue. I was trying to use backoffmultiplier() available with camel but it failed too.



      Below is my implementation of what I have tried so far.



      The URI to connect to the queue where I have specified requestTimeout and requestTimeoutChecker



      QUEUE_CONNECTION=amqp:queue:testqueue?requestTimeout=4000&requestTimeoutCheckerInterval=3000&acknowledgementModeName=CLIENT_ACKNOWLEDGE&concurrentConsumers=2


      The exception handling where I have used backoffmultiplier



      onException(Exception.class).
      process(new Processor() {
      @Override
      public void process(Exchange exchange) throws Exception {
      Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
      logger.error("Exception in exchange : ",cause);
      // we now have the caused exception
      }
      }).useExponentialBackOff().backOffMultiplier(2).maximumRedeliveries(3);


      Am I missing anything here? TIA.










      share|improve this question













      I am using azure service bus for my project. I was able to establish the connection through camel amqp following this link Accessing Azure Service Bus with Apache Camel?



      Now I am able to read the messages through the service bus queue, but I am having issues in increasing the auto-timeout lock for the messages. I have the set the timeout lock to be 30 seconds in the service bus properties, but for certain messages who need more time I want the time to extend.



      I looked for solution online, but couldn't find anything that resolved the issue. I was trying to use backoffmultiplier() available with camel but it failed too.



      Below is my implementation of what I have tried so far.



      The URI to connect to the queue where I have specified requestTimeout and requestTimeoutChecker



      QUEUE_CONNECTION=amqp:queue:testqueue?requestTimeout=4000&requestTimeoutCheckerInterval=3000&acknowledgementModeName=CLIENT_ACKNOWLEDGE&concurrentConsumers=2


      The exception handling where I have used backoffmultiplier



      onException(Exception.class).
      process(new Processor() {
      @Override
      public void process(Exchange exchange) throws Exception {
      Exception cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Exception.class);
      logger.error("Exception in exchange : ",cause);
      // we now have the caused exception
      }
      }).useExponentialBackOff().backOffMultiplier(2).maximumRedeliveries(3);


      Am I missing anything here? TIA.







      azure apache-camel azureservicebus spring-amqp azure-servicebus-queues






      share|improve this question













      share|improve this question











      share|improve this question




      share|improve this question










      asked Nov 8 at 17:15









      Nikhil Jain

      319112




      319112





























          active

          oldest

          votes











          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',
          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%2f53212921%2fhow-to-increase-autolock-timeout-on-azure-service-bus-using-camel%23new-answer', 'question_page');
          }
          );

          Post as a guest















          Required, but never shown






























          active

          oldest

          votes













          active

          oldest

          votes









          active

          oldest

          votes






          active

          oldest

          votes
















          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.





          Some of your past answers have not been well-received, and you're in danger of being blocked from answering.


          Please pay close attention to the following guidance:


          • 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%2f53212921%2fhow-to-increase-autolock-timeout-on-azure-service-bus-using-camel%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







          這個網誌中的熱門文章

          Academy of Television Arts & Sciences

          L'Équipe

          1995 France bombings