/**
 * @author BNTang
 */
@Configuration
public class ProducerConfig {

    @Bean
    public Queue queue() {
        // 这里面可以和之前的Hello项目一样，进行5个参数的配置
        return new Queue("hello");
    }
}

@SpringBootTest
class RabbitmqSpringbootProducerApplicationTests {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    void testDirectlyConnected() {
        this.rabbitTemplate.convertAndSend("hello", "hello world");
        System.out.println("消息发送成功");
    }
}

/**
 * @author BNTang
 */
@Component
@RabbitListener(queuesToDeclare = {@Queue("hello")})
public class HelloConsumer {
    @RabbitHandler
    public void receive1(String message) {
        System.out.println("接收到消息：" + message);
    }
}

/**
 * @author BNTang
 */
@Component
public class HelloConsumer {

    @RabbitListener(queuesToDeclare = {@Queue("hello")})
    public void receive2(String message) {
        System.out.println("接收到消息" + message);
    }

}