activemq整合springboot使用方法(个人微信小程序用)

<parent>

<groupid>org.springframework.boot</groupid>

   <artifactid>spring-boot-starter-parent</artifactid>

   <version> 1.5 . 3 .release</version>

   <relativepath /> <!-- lookup parent from repository -->

</parent>

<dependency>

   <groupid>org.springframework.boot</groupid>

   <artifactid>spring-boot-starter-activemq</artifactid>

</dependency>

spring.activemq.in-memory= true

spring.activemq.pool.enabled= false

<dependency>

    <groupid>org.apache.activemq</groupid>

    <artifactid>activemq-pool</artifactid>

</dependency>

#服务端口， 8080 被另一服务占用

server.port= 9090

spring.activemq.broker-url=tcp: //127.0.0.1:61616

# 在考虑结束之前等待的时间

#spring.activemq.close-timeout=15s

# 默认代理url是否应该在内存中。如果指定了显式代理，则忽略此值。

spring.activemq.in-memory= true

# 是否在回滚回滚消息之前停止消息传递。这意味着当启用此命令时，消息顺序不会被保留。

spring.activemq.non-blocking-redelivery= false

# 等待消息发送响应的时间。设置为 0 等待永远。

spring.activemq.send-timeout= 0

#默认情况下activemq提供的是queue模式，若要使用topic模式需要配置下面配置

spring.jms.pub-sub-domain= true

#账号

spring.activemq.user=admin

# 密码

spring.activemq.password=admin

# 是否信任所有包

#spring.activemq.packages.trust-all=

# 要信任的特定包的逗号分隔列表（当不信任所有包时）

#spring.activemq.packages.trusted=

# 当连接请求和池满时是否阻塞。设置 false 会抛[jmsexception异常]。

#spring.activemq.pool.block- if -full= true

# 如果池仍然满，则在抛出异常前阻塞时间。

#spring.activemq.pool.block- if -full-timeout=-1ms

# 是否在启动时创建连接。可以在启动时用于加热池。

#spring.activemq.pool.create-connection-on-startup= true

# 是否用pooledconnectionfactory代替普通的connectionfactory。

#spring.activemq.pool.enabled= false

# 连接过期超时。

#spring.activemq.pool.expiry-timeout=0ms

# 连接空闲超时

#spring.activemq.pool.idle-timeout=30s

# 连接池最大连接数

#spring.activemq.pool.max-connections= 1

# 每个连接的有效会话的最大数目。

#spring.activemq.pool.maximum-active-session-per-connection= 500

# 当有 "jmsexception" 时尝试重新连接

#spring.activemq.pool.reconnect-on-exception= true

# 在空闲连接清除线程之间运行的时间。当为负数时，没有空闲连接驱逐线程运行。

#spring.activemq.pool.time-between-expiration-check=-1ms

# 是否只使用一个messageproducer

#spring.activemq.pool.use-anonymous-producers= true

@bean

public queue queue() {

   return new activemqqueue( "queuename1" );

}

@resource

jmsmessagingtemplate jmsmessagingtemplate;

public void sendmessage(destination destination, string message) {

   jmsmessagingtemplate.convertandsend(destination, message);

}

@jmslistener (destination = "queuename1" )

public void receivequeue(string message) {

   log.info( "=========接受到了消息:" + message);

   grabservice.addsearchcontent(message, mainconfig.getcharset());

}