package com.example.springboot.common;
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.io.Serializable;
|
|
@Component
|
public class MessageSender {
|
|
@Autowired
|
private RabbitTemplate rabbitTemplate;
|
|
public void sendMessage(String message) {
|
rabbitTemplate.convertAndSend(RabbitConfig.DIRECT_EXCHANGE_NAME, RabbitConfig.ROUTING_KEY, message);
|
System.out.println("send message: " + message);
|
}
|
|
public void sendMessage2(Person person) {
|
rabbitTemplate.convertAndSend(RabbitConfig.DIRECT_EXCHANGE_NAME, RabbitConfig.SECOND_ROUTING_KEY, person);
|
}
|
|
public static class Person implements Serializable {
|
private String name;
|
private int age;
|
|
public Person(String name, int age) {
|
this.name = name;
|
this.age = age;
|
}
|
|
public String getName() {
|
return name;
|
}
|
|
public int getAge() {
|
return age;
|
}
|
|
// getter和setter方法省略
|
}
|
|
}
|
