标签：spring activeMQ 使用 springframework queue import org activemq

IDEA 创建 SpringBoot 项目，因为 SpringBoot 已经内置了对 ActiveMQ 的支持，所以直接引入依赖 spring-boot-starter-activemq 就行。

1.引入依赖

<!--activeMq 依赖-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<!--消息队列连接池-->
<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-pool</artifactId>
    <version>5.15.0</version>
</dependency>

2.配置yaml文件

spring:
  # activeMq 配置
  activemq:
    broker-url: tcp://localhost:61616
    user: admin
    password: admin
    pool:
      # 使用flase,此处改为true报错，不清楚什么原因
      enabled: false
      max-connections: 10
#配置队列名
queueName: publish.queue
topicName: publish.topic

3.定义jms消息发送配置类，该类主要用于配置队列信息

ActiveMQConfig

package com.ry.bill.sys.config;

import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.annotation.EnableJms;

import javax.jms.Queue;
/**
 * @author CKFuture
 * @since 2021-01-02 15:45
 * @descrption ActiveMQ 配置类
 */
@EnableJms
@Configuration
public class ActiveMQConfig {
    @Bean
    public Queue queue() {
        return new ActiveMQQueue("sms.queue");
    }
}

标签：spring,activeMQ,使用,springframework,queue,import,org,activemq
来源： https://www.cnblogs.com/ckfuture/p/15089899.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。