<dependencies> <dependency> <groupId>com.azure</groupId> <artifactId>azure-messaging-servicebus</artifactId> <version>7.2.0</version> </dependency> <dependency> <groupId>com.azure.spring</groupId> <artifactId>spring-cloud-azure-servicebus-queue</artifactId> <version>2.8.0</version> </dependency> </dependencies> import com.azure.spring.integration.servicebus.queue.ServiceBusQueueOperation; import com.azure.spring.integration.servicebus.queue.ServiceBusQueueTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Component public class MessageReceiver { private final ServiceBusQueueTemplate serviceBusQueueTemplate; @Autowired public MessageReceiver(ServiceBusQueueOperation serviceBusQueueOperation) { this.serviceBusQueueTemplate= new ServiceBusQueueTemplate(serviceBusQueueOperation); } @ServiceBusQueueListener(queueName = "<your-queue-name>") public void receiveMessage(String message) { System.out.println("Received message: " + message); } }


上一篇:
下一篇:
切换中文