ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); factory.setPort(5672); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); String queueName = "myQueue"; String message = "Hello, RabbitMQ!"; channel.basicPublish("", queueName, null, message.getBytes("UTF-8")); channel.basicConsume(queueName, true, (consumerTag, delivery) -> { String receivedMessage = new String(delivery.getBody(), "UTF-8"); System.out.println("Received message: " + receivedMessage); }, consumerTag -> {});