Azure SDK for Java to process messages from Service Bus queue

Question

Azure SDK for Java to process messages from Service Bus queue

Yuvaraj Madheswaran 390

Hi,

We are using the Azure SDK for Java to process messages from Service Bus queue. We are referring the document from azure doc link,

https://learn.microsoft.com/en-us/java/api/com.azure.messaging.servicebus.servicebusreceiverasyncclient?view=azure-java-stable

As per the doc, we marked the processed message complete but its not working. The messages are not being removed from queue even after setting the status as complete. Any thoughts on this issues?

MayankBargali-MSFT 70,936 Reputation points Moderator

2023-07-18T11:56:31.8566667+00:00

@Yuvaraj Madheswaran Thanks for reaching out. Can you share the sample code?

Yuvaraj Madheswaran 390

Hi @MayankBargali-MSFT ,
Please find the sample code as below,

 ServiceBusReceiverAsyncClient receiver = new ServiceBusClientBuilder()
            .connectionString(connectionString)
            .receiver()
            .disableAutoComplete()
            .queueName(queueName)
            .buildAsyncClient();

         receiver.receiveMessages()
            .flatMap(message -> {
                boolean messageProcessed = processMessage(message);

               
                if (messageProcessed) {
                    return receiver.complete(message);
                } else {
                    return receiver.abandon(message);
                }
            }).subscribe(
                (ignore) -> System.out.println("Message processed."),
                error -> sampleSuccessful.set(false)
            );

MayankBargali-MSFT 70,936 Reputation points Moderator

2023-07-24T04:47:06.7033333+00:00

@Yuvaraj Madheswaran In the above code the message will only be marked as completed if your processMessage returns true. Have you debugged your code to confirm if your function returns the true value? I don't see any issue with the above shared code. I will suggest debugging your code further to review if your function processMessage return true value.
Yuvaraj Madheswaran 390 Reputation points

2023-07-25T16:38:31.93+00:00

@MayankBargali-MSFT , yes it does returns the true value and false in case of any exception but still the the client not marking the status as complete for true value
MayankBargali-MSFT 70,936 Reputation points Moderator

2023-07-27T05:08:39.5133333+00:00

@Yuvaraj Madheswaran Thanks for your response. I would suggest to open a support ticket with us to review it over one on one support to assist you further. In case if you don't have the support plan then please let me know.
Yuvaraj Madheswaran 390 Reputation points

2023-08-08T21:46:38.0866667+00:00

@MayankBargali-MSFT ,
I can able to fix the issue by adding the below code snippet,

receiver.complete(message).subscribe();

Accepted answer

0 additional answers

Your answer

MayankBargali-MSFT 70,936 Reputation points Moderator

2023-07-18T11:56:31.8566667+00:00

@Yuvaraj Madheswaran Thanks for reaching out. Can you share the sample code?
Yuvaraj Madheswaran 390 Reputation points

2023-07-20T14:42:16.7566667+00:00

Hi @MayankBargali-MSFT ,
Please find the sample code as below,

ServiceBusReceiverAsyncClient receiver = new ServiceBusClientBuilder() .connectionString(connectionString) .receiver() .disableAutoComplete() .queueName(queueName) .buildAsyncClient(); receiver.receiveMessages() .flatMap(message -> { boolean messageProcessed = processMessage(message); if (messageProcessed) { return receiver.complete(message); } else { return receiver.abandon(message); } }).subscribe( (ignore) -> System.out.println("Message processed."), error -> sampleSuccessful.set(false) );
MayankBargali-MSFT 70,936 Reputation points Moderator

2023-07-24T04:47:06.7033333+00:00

@Yuvaraj Madheswaran In the above code the message will only be marked as completed if your processMessage returns true. Have you debugged your code to confirm if your function returns the true value? I don't see any issue with the above shared code. I will suggest debugging your code further to review if your function processMessage return true value.
Yuvaraj Madheswaran 390 Reputation points

2023-07-25T16:38:31.93+00:00

@MayankBargali-MSFT , yes it does returns the true value and false in case of any exception but still the the client not marking the status as complete for true value
MayankBargali-MSFT 70,936 Reputation points Moderator

2023-07-27T05:08:39.5133333+00:00

@Yuvaraj Madheswaran Thanks for your response. I would suggest to open a support ticket with us to review it over one on one support to assist you further. In case if you don't have the support plan then please let me know.
Yuvaraj Madheswaran 390 Reputation points

2023-08-08T21:46:38.0866667+00:00

@MayankBargali-MSFT ,
I can able to fix the issue by adding the below code snippet,

receiver.complete(message).subscribe();

Answer 1

Hi @Yuvaraj Madheswaran

I'm glad to see you were able to resolve your issue. Thanks for posting your solution so that others experiencing the same thing can easily reference this.

Since the Microsoft Q&A community has a policy that the question author cannot accept their own answer, they can only accept answers by others, I'll repost your solution in case you'd like to Accept the answer.

Issue: You observed that when you marked the message as complete, the message is not being removed from queue even. receiver.complete(message)

Resolve: You found that you need to use the subscribe() method on the complete call as below to resolve the issue receiver.complete(message).subscribe();

Share via

Azure SDK for Java to process messages from Service Bus queue

0 additional answers

Your answer