File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 60
60
不设置异步同时持久化的情况下,send 方法都是同步的,并且一直阻塞直到ActiveMQ
61
61
发回确认消息:消息已经存储在持久性数据存储中,接受到 broker 的确认消息之前应用程序或线程会被阻塞。 PERSISTENT (异步也能保证持久性)
62
62
63
- ###同步发送代码示例:
63
+ ### 同步发送代码示例:
64
64
65
65
``` java
66
66
connection. createSession(Boolean . TRUE , Session . AUTO_ACKNOWLEDGE );
@@ -256,4 +256,4 @@ public class LogConsumerWithAMQ implements MessageListener {
256
256
1 . [ 消息队列对比传统模式的优点] ( https://blog.csdn.net/wonderful_life_mrchi/article/details/84667426 )
257
257
2 . [ ActiveMQ异步发送使用及常见误区] ( https://www.jianshu.com/p/58e9deae6c4b )
258
258
3 . [ activemq发送同步发送和异步发送] ( https://blog.csdn.net/YAOQINGGG/article/details/79833378 )
259
- 4 . [ jms的消息确认和事务] ( https://segmentfault.com/a/1190000015920000 )
259
+ 4 . [ jms的消息确认和事务] ( https://segmentfault.com/a/1190000015920000 )
You can’t perform that action at this time.
0 commit comments