Azure服务总线-Spring启动禁用autostart（com.microsoft.Azure:Azure servicebusSpring启动启动程序）

Question

我有下面的实现来使用Spring Boot应用程序使用来自Azure Service Bus的消息，但是我希望能够控制ServiceBusConsumer使用Spring Boot profile属性自动开始侦听主题

在应用程序中类似这样的内容。亚马尔

 servicebus.consumer.enable=false

它应该禁止ServiceBusConsumer侦听主题，并且我应该能够使用RESTAPI启动ServiceBusConsumer-例如：/api/servicebus/consumer/start？

import com.microsoft.azure.servicebus.ExceptionPhase;
import com.microsoft.azure.servicebus.IMessage;
import com.microsoft.azure.servicebus.IMessageHandler;
import com.microsoft.azure.servicebus.ISubscriptionClient;
import lombok.extern.log4j.Log4j2;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.event.EventListener;
import org.springframework.core.Ordered;
import org.springframework.stereotype.Component;

import java.util.concurrent.CompletableFuture;

@Log4j2
@Component
class ServiceBusConsumer implements Ordered {

    private final ISubscriptionClient iSubscriptionClient;

    ServiceBusConsumer(ISubscriptionClient isc) {
        this.iSubscriptionClient = isc;
    }

    @EventListener(ApplicationReadyEvent.class)
    public void consume() throws Exception {

        this.iSubscriptionClient.registerMessageHandler(new IMessageHandler() {

            @Override
            public CompletableFuture<Void> onMessageAsync(IMessage message) {
                log.info("received message " + new String(message.getBody()) + " with body ID " + message.getMessageId());
                return CompletableFuture.completedFuture(null);
            }

            @Override
            public void notifyException(Throwable exception, ExceptionPhase phase) {
                log.error("eeks!", exception);
            }
        });

    }

    @Override
    public int getOrder() {
        return Ordered.HIGHEST_PRECEDENCE;
    }
}

Answer 1

通过像这样添加@ConditionalOnProperty注释，可以有条件地创建ServiceBusConsumerbean，以确保仅在servicebus时创建bean。消费者enabled=true：

@Log4j2
@Component
@ConditionalOnProperty(prefix = "servicebus.consumer", name = "enabled") 
class ServiceBusConsumer implements Ordered {
...
}