Running WriteCheck
初学者,自己参照网上写了个demo~~
我想问下这是正常的吗?谢谢各位,因为网上找不到答案~~
控制台信息如下:
——————————————————————————————————————
2017-12-08 14:55:51,066 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:01,070 - DEBUG - WriteChecker: 10005ms elapsed since last write check.
2017-12-08 14:56:01,070 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:11,075 - DEBUG - WriteChecker: 10005ms elapsed since last write check.
2017-12-08 14:56:11,075 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:21,013 - DEBUG - 30002ms elapsed since last read check.
2017-12-08 14:56:21,077 - DEBUG - WriteChecker: 10002ms elapsed since last write check.
2017-12-08 14:56:21,078 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:31,077 - DEBUG - WriteChecker: 10000ms elapsed since last write check.
2017-12-08 14:56:31,077 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:41,082 - DEBUG - WriteChecker: 10005ms elapsed since last write check.
2017-12-08 14:56:41,082 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
---------------------------------------
jms xml配置如下:
---------------------------------------
<!-- 配置连接ActiveMQ的ConnectionFactory -->
<bean id="amqConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>
<!--为了提高效率,配置一个连接池-->
<bean id="cachedConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
<property name="targetConnectionFactory" ref="amqConnectionFactory"/>
<property name="sessionCacheSize" value="10"/>
</bean>
<!-- 定义JmsTemplate的Queue类型,还可以定制订阅模式,这里不列出 -->
<bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate">
<!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->
<constructor-arg ref="cachedConnectionFactory" />
<!-- 非pub/sub模型(发布/订阅),即队列模式 -->
<property name="pubSubDomain" value="false" />
</bean>-----------------------------------------------
调用处如下:
------------------------------------------------
@RequestMapping("amqSend")
public void amqSend() {
JmsTemplate jmsTemplate = (JmsTemplate) SpringContextUtil.getBean("jmsQueueTemplate");
jmsTemplate.convertAndSend("testAmqSend", "I am Flxia");
}
-------------------------------------------------
初学者,自己参照网上写了个demo~~
我想问下这是正常的吗?谢谢各位,因为网上找不到答案~~
控制台信息如下:
——————————————————————————————————————
2017-12-08 14:55:51,066 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:01,070 - DEBUG - WriteChecker: 10005ms elapsed since last write check.
2017-12-08 14:56:01,070 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:11,075 - DEBUG - WriteChecker: 10005ms elapsed since last write check.
2017-12-08 14:56:11,075 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:21,013 - DEBUG - 30002ms elapsed since last read check.
2017-12-08 14:56:21,077 - DEBUG - WriteChecker: 10002ms elapsed since last write check.
2017-12-08 14:56:21,078 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:31,077 - DEBUG - WriteChecker: 10000ms elapsed since last write check.
2017-12-08 14:56:31,077 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
2017-12-08 14:56:41,082 - DEBUG - WriteChecker: 10005ms elapsed since last write check.
2017-12-08 14:56:41,082 - DEBUG - Running WriteCheck[tcp://127.0.0.1:61616]
---------------------------------------
jms xml配置如下:
---------------------------------------
<!-- 配置连接ActiveMQ的ConnectionFactory -->
<bean id="amqConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>
<!--为了提高效率,配置一个连接池-->
<bean id="cachedConnectionFactory"
class="org.springframework.jms.connection.CachingConnectionFactory">
<property name="targetConnectionFactory" ref="amqConnectionFactory"/>
<property name="sessionCacheSize" value="10"/>
</bean>
<!-- 定义JmsTemplate的Queue类型,还可以定制订阅模式,这里不列出 -->
<bean id="jmsQueueTemplate" class="org.springframework.jms.core.JmsTemplate">
<!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->
<constructor-arg ref="cachedConnectionFactory" />
<!-- 非pub/sub模型(发布/订阅),即队列模式 -->
<property name="pubSubDomain" value="false" />
</bean>-----------------------------------------------
调用处如下:
------------------------------------------------
@RequestMapping("amqSend")
public void amqSend() {
JmsTemplate jmsTemplate = (JmsTemplate) SpringContextUtil.getBean("jmsQueueTemplate");
jmsTemplate.convertAndSend("testAmqSend", "I am Flxia");
}
-------------------------------------------------
解决方案 »
- java 统计在线人数问题
- jstl-api-1.2.jar和jstl-impl-1.2.jar
- IBatis 多表联合查询的问题,请各位指导下
- dom4j生成xml的问题!!!!!!!!!!!!!!!
- 本地开发到服务器部署项目都需要注意哪些问题呢?
- Sping+Hibernate中的事务控制问题
- MyEclipse debug时间过长为什么会卡死?
- 执行EJB客户端时,出现我看不明白的问题。
- 关于System.exit(int status)?
- EJB的server和client在同一台电脑上有意义吗?JSP+Bean+EJB结构是不是需要三台电脑才合理?
- SSM框架使用Ueditor怎样向后台传数据
- 请问java分别赋值abcd四个整数排序怎么排呢?
1. 确认消息可以正常收发,不正常的收发可能导致消费者的反复检查。
2. 设置日志的threshold,这类DEBUG日志可以考虑屏蔽掉,防止日志输出过于啰嗦。
http://blog.csdn.net/qq_37142346/article/details/78758564