in Sample-Code-Snippets/Java/azure-service-bus-emulator-console-sample/src/main/java/com/contoso/org/Main.java [12:41]
public static void main(String[] args) {
// Create a ServiceBusClientBuilder
ServiceBusClientBuilder builder = new ServiceBusClientBuilder()
.connectionString(CONNECTION_STRING);
// Sending a message
ServiceBusSenderClient senderClient = builder
.sender()
.queueName(QUEUE_NAME)
.buildClient();
String message = "Hello, Service Bus!";
senderClient.sendMessage(new ServiceBusMessage(message));
System.out.println("Sent : " + message);
// Receiving a message
ServiceBusReceiverClient receiverClient = builder
.receiver()
.queueName(QUEUE_NAME)
.buildClient();
receiverClient.receiveMessages(1).forEach(msg -> {
System.out.println("Received: " + msg.getBody().toString());
receiverClient.complete(msg);
});
// Close the clients
senderClient.close();
receiverClient.close();
}