美文网首页
Springboot ActiveMQ 全局配置

Springboot ActiveMQ 全局配置

作者: 曹振华 | 来源:发表于2017-04-25 20:41 被阅读852次

    1 .  Gradle 依赖
    compile("org.springframework.boot:spring-boot-starter-activemq")
    compile("org.apache.activemq:activemq-broker")

    1. application.properties
    jms.alwaysSyncSend=false&jms.useAsyncSend=true    用来设定producer(或者session)发送消息的方式:同步/异步.在brokerUrl中指定,单位:毫秒 jms.sendTimeout=30000 消息发送最大阻塞(等到ACK)时间。这个参数和syncSend方式配合使用,在同步发送方式中,send方法将会阻塞直到broker反馈ACK,不过这种阻塞的时长无法预期,我们需要使用sendTimeout来设定最大的阻塞时间,如果阻塞超时,将会抛出RequestTimedOutIOException。此值默认为0,表示永不超时
    
          spring.activemq.broker-url=failover:(tcp://localhost:61616,tcp://localhost:61626,tcp://localhost:61636)?initialReconnectDelay=100
          spring.activemq.user=admin
          spring.activemq.password=admin
          #broker kind to create if no broker-url is specified
          spring.activemq.in-memory=true
          # Specify if the default broker URL should be in memory. Ignored if an explicit broker has been specified.
          spring.activemq.packages.trust-all=false
          # Trust all packages.
          #spring.activemq.packages.trusted=
          # Comma-separated list of specific packages to trust (when not trusting all packages).
          #spring.activemq.pool.configuration.*= # See PooledConnectionFactory.
          spring.activemq.pool.enabled=false
          # Whether a PooledConnectionFactory should be created instead of a regular ConnectionFactory.
          spring.activemq.pool.expiry-timeout=0
          # Connection expiration timeout in milliseconds.
          spring.activemq.pool.idle-timeout=30000
          # Connection idle timeout in milliseconds.
          spring.activemq.pool.max-connections=10
          #consumer消费的最小和最大线程数
          spring.jms.listener.concurrency=10
          spring.jms.listener.max-concurrency=10
          #是否是订阅方式,true:队列;false:topic
          spring.jms.pub-sub-domain=false
          #消费端ack方式
          spring.jms.listener.acknowledge-mode=client

    相关文章

      网友评论

          本文标题:Springboot ActiveMQ 全局配置

          本文链接:https://www.haomeiwen.com/subject/xfkbzttx.html