Skip to content

utsmannn/rabbitmq-basic

Repository files navigation

RabbitMQ basic implementation on Java client

Create connection

RabbitConnection connection = new RabbitConnection.Builder()
    .setQueueName("hallo")
    .build("localhost");

Receiver message

connection.receiver((queueName, consumerTag, message) -> {
    // message received
    Utils.printLn(" [x] received: '" + message + "'");
});

Sending message

connection.send("message will be sent");

About

Basic implementation of RabbitMQ Java client

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages