Springboot项目Activemq延迟自定义消息完整代码案例（亲测可用）

 1、porm.xml增加依赖

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-activemq</artifactId>
</dependency>

2、application.properties增加配置

# 连接地址
spring.activemq.broker-url=failover:tcp://172.16.5.156:41616
spring.activemq.user= admin
spring.activemq.password=Password2017
#true表示使用连接池；false时，每发送一条数据创建一个连接
spring.activemq.pool.enabled=true
spring.jms.template.delivery-mode=persistent

3、springboot启动类增加注解@EnableJms

4、相关代码，配置类，生产者，消费者

package com.config;import com.joysuch.wwyt.pod.constants.PodConstant;
import lombok.Getter;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ActiveMQSession;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotati