package com.springbootdev.examples.producer.service; | |
import com.springbootdev.examples.producer.model.Car; | |
import org.slf4j.Logger; | |
import org.slf4j.LoggerFactory; | |
import org.springframework.amqp.rabbit.core.RabbitTemplate; | |
import org.springframework.beans.factory.annotation.Autowired; | |
import org.springframework.stereotype.Service; | |
@Service | |
public class ProducerService { | |
@Autowired | |
private RabbitTemplate rabbitTemplate; | |
private static final String EXCHANGE_NAME = "vehicle_exchange"; | |
private static final Logger logger = LoggerFactory.getLogger(ProducerService.class); | |
private String[] routeKeys = new String[]{ | |
"nissan.cars.japan", | |
"nissan.cars", | |
"toyota.cars.japan.manufactured", | |
"japan.toyota.cars", | |
"import.nissan.cars.from.japan", | |
"toyota.cars.manufatured", | |
"no.latest.cars.toyota" | |
}; | |
public void produce() { | |
for (String routingKey : routeKeys) { | |
logger.info(" sending the message with routing key {}", routingKey); | |
Car car = new Car(routingKey); | |
rabbitTemplate.convertAndSend(EXCHANGE_NAME, routingKey, car); | |
} | |
} | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment