Folders and files
| Name | Name | Last commit date | ||
|---|---|---|---|---|
HOW to send Message to RabbitMQ Broker.(First setup RabbitMQ broker and create exchange and queue using web console)
create spring boot project with RabbitMq dependency
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>
create bean of ConnectionFactory using CachingConnectionFactory class for RabbitTemplate Bean.
@Bean
public ConnectionFactory connectionFactory() {
CachingConnectionFactory factory = new CachingConnectionFactory("localhost");
factory.setPort(5672);
factory.setUsername("guest");
factory.setPassword("guest");
return factory;
}
Inject or Autowired RabbitTemplate Bean to call method of Rabbitemplate
@Autowired private RabbitTemplate rabbitTemplate;
@Override
public void run(String... args) throws Exception {
System.out.println("message sending started.");
rabbitTemplate.convertAndSend("ami.direct", "", "First Message from client code");
System.out.println("message sending finished.");
}
"ami.direct"--> Exchanged name
"First Message from client code"--> message to exchange
In RabbitMQ client cant send message direct to Queue(Topic not exist)..client can send message to exchange and exchange have binding to queue (one to one and one to many or many to one relations)
