How to configure @ServiceBusListener ServiceBusReceiveMode among Spring Message

[kensinzl]

Query/Question

• I am using Spring Message @ServiceBusListener to receive the Azure Service Bus Queue message.
• I refer to this official page https://learn.microsoft.com/en-us/azure/developer/java/spring-framework/using-service-bus-in-spring-applications
• I know the difference between PEEK_LOCK and RECEIVE_AND_DELETE of the ServiceBusReceiveMode, but
  1. I did not find any attribute of @ServiceBusListener to configure the above receive mode?
  2. Meanwhile, even I have tried to configure spring.cloud.azure.servicebus.consumer.receive-mode=RECEIVE_AND_DELETE or spring.cloud.azure.servicebus.processor.receive-mode=RECEIVE_AND_DELETE at the application.properties file, the result seems still PEEK_LOCK, that means the message does not be deleted upon receiving

my question is how to configure the ServiceBusReceiveMode for the Java springboot if you use the annotation, eg: @ServiceBusListener

Setup (please complete the following information if applicable):

• Java Spring Boot

      <dependency>
          <groupId>com.azure.spring</groupId>
          <artifactId>spring-messaging-azure-servicebus</artifactId>
          <version>5.9.1</version>
      </dependency>

### Tasks

[joshfree]

@yiliuTo could you take a look?

/cc @Azure/azsdk-sb-java

[Netyyyy]

Hi @kensinzl Thank you for reporting this issue. We have received your submission and will take a look. We appreciate your input and will review this matter as soon as possible. Please feel free to provide any additional information or context that you think may be helpful. We'll keep you updated on the progress of our review.

[kensinzl]

Hey, is there any progress, seems no one take this issue to have a look

[kensinzl]

@yiliuTo @Netyyyy @joshfree any progress for this ticket? thanks

[nikoladjuran]

I'm stuck with a similar issue where I want to configure the @ServiceBusListener to use PEEK_LOOK and to enable sessions on the consumer as the subscription has sessions enabled. Properties like spring.cloud.azure.servicebus.processor.session-enabled=true spring.cloud.azure.servicebus.processor.receive-mode=peek_lock do not seem to work with the annotated listeners.

[nikoladjuran]

@kensinzl FYI: Managed to figure it out... Those properties don't configure the @ServiceBusListener but seem to be for other approaches like ServiceBusClient. I've managed to configure the listeners with the following bean declaration.

@Bean
public PropertiesSupplier<ConsumerIdentifier, ProcessorProperties> propertiesSupplier() {
    return key -> {
        var processorProperties = new ProcessorProperties();
        processorProperties.setEntityType(ServiceBusEntityType.TOPIC);
        processorProperties.setReceiveMode(ServiceBusReceiveMode.PEEK_LOCK);
        processorProperties.setSessionEnabled(Boolean.TRUE);

        return processorProperties;
    };
}

[kensinzl]

@nikoladjuran Hey man, thanks for the information.

I still use the @ServiceBusListener(Spring messaging) to monitor the service bus queue. If my understanding is correct, the @ServiceBusListener source code is using the default ServiceBusReceiveMode.PEEK_LOCK and also embed the commit to delete the message if successfully executed.

again, the document of azure is quite a mess, particularly the Java Azure SDK. Hopefully, I am on the right track.