1. Configuration List

For every producer, EzyRabbitMQ provides bellow properties:

For every consumer, EzyRabbitMQ provides bellow properties:

For every topic, EzyRabbitMQ provides bellow properties:

2. An Example

Let's we neen create a producer and a consumer named test and a topic named hello, you can put bellow configuration to your application.yaml file:

# for application.yaml
rabbitmq:
  producers:
    test: default
  consumers:
    test: default
  topics:
    hello:
      producer: default
      consumer: default

Or for application.properties file:

# for application.properties
rabbitmq.producers.test=default
rabbitmq.consumers.test=default
rabbitmq.topics.hello.producer=default
rabbitmq.topics.hello.consumer=default

3. Configure for producer

You can configure for producer like this:

EzyRabbitMQProxy proxy = EzyRabbitMQProxy.builder()
    .scan("com.tvd12.ezymq.rabbitmq.test")
    .mapTopicMessageType("hello", "hello", SumRequest.class)
    .build();
EzyRabbitRpcProducer producer = proxy.getRpcProducer("test");

4. Configure for consumer

You can configure for consumer like this:

EzyRabbitMQProxy.builder()
    .addSingleton(someSingleton)
    .scan("com.tvd12.ezymq.rabbitmq.test")
    .build();

5. Topic usage

You can get the topic like this:

EzyRabbitTopic<SumRequest> sumTopic = proxy.getTopic("hello");

And use the topic to publish a message like this:

sumTopic.publish("hello", new SumRequest(a, b));

You also can add message consumer for the topic like this:

sumTopic.addConsumer("hello", message ->
    System.out.println("sum request: " + message)
);