＜artifactId＞spring-cloud-azure-starter-servicebus＜/artifactId＞

115 阅读 0 评论 76 点赞

我是靠谱客的博主花痴水池，这篇文章主要介绍＜artifactId＞spring-cloud-azure-starter-servicebus＜/artifactId＞，现在分享给大家，希望可以做个参考。

@SpringBootApplication
@EnableAzureServiceBus
public class MyApplication {
    public static void main(String[] args) {
        SpringApplication.run(MyApplication.class, args);
    }
}

@Component
public class MyComponent {
    @AzureServiceBusQueue(name = "myqueue")
    private Queue queue;

    @SendTo("myqueue")
    public void sendMessage(String message) {
        queue.send(MessageBuilder.withPayload(message).build());
    }
}

@Component
public class MyConsumer {
    @JmsListener(destination = "myqueue")
    public void processMessage(String message) {
        // 处理消息
    }
}

@Configuration
public class MyConfiguration {
    @Bean
    public AzureServiceBusConnectionFactory connectionFactory() {
        return new AzureServiceBusConnectionFactory(
            "your-service-bus-namespace",
            "your-access-key"
        );
    }
}