直接测试就好了
@RestController
@RequestMapping("/api/admin/merchant")
public class MerchantAccountController {
@Autowired
private RabbitTemplate rabbitTemplate;
@RequestMapping("check")
public Object chect(){
//TODO 修改数据库的商家账号状态
rabbitTemplate.convertAndSend(RabbitMQConfig.NEW_MERCHANT_EXCHANGE,RabbitMQConfig.NEW_MERCHANT_ROUTIING_KEY,"商家账号通过审核");
Map<String,Object> map = new HashMap<>();
map.put("code",0);
map.put("msg","账号审核通过,请10秒内上传一个商品");
return map;
}
} 我们就可以直接看到相应的延时操作啦!

10秒后,此消息来到了死信!
本文作者为DBC,转载请注明。