<dependency>
<groupId>org.appsensor</groupId>
<artifactId>ampsensor-amqp-client</artifactId>
<version>1.0.0</version>
</dependency>
import org.appsensor.amqp.client.producer.AmqpMessageProducer;
AmqpMessageProducer producer = new AmqpMessageProducer();
producer.initialize("amqp://guest:guest@localhost:5672");
producer.connect();
String queueName = "myQueue";
producer.declareQueue(queueName);
producer.sendMessage(queueName, "Hello, RabbitMQ!");
producer.disconnect();
import org.appsensor.amqp.client.consumer.AmqpMessageConsumer;
AmqpMessageConsumer consumer = new AmqpMessageConsumer();
consumer.initialize("amqp://guest:guest@localhost:5672");
consumer.connect();
String queueName = "myQueue";
consumer.declareQueue(queueName);
consumer.consume(queueName, (message) -> {
System.out.println("Received message: " + message);
});
consumer.disconnect();
