JMS - QueueBrowser
QueueBrowser 是一个专用对象,提供提前浏览 Queue 上的排队消息的功能,而实际上并没有真正消费这些消息。这是点对点消息传送模型的独有特性。从 QueueBrowser 获得消息是该队列中消息的副本,而且并未认为会被消费——它们仅是用于浏览而已。还有,QueueBrowser 并不能保证提供的是队列消息的准确清单。QueueBrowser 包含的仅仅是创建 QueueBrowser 时队列的一个快照或者它的一个副本。队列的内容可能会在创建 QueueBrowser 和查看的时间间隔内发生变化。
Sample Code:
public static void main(String[] args) {try {Context context = new InitialContext();QueueConnectionFactory connFactory = (QueueConnectionFactory) context.lookup("QueueCF"); Connection conn = connFactory.createConnection(); conn.start();Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);Queue queue = session.createQueue("hello_queue");QueueBrowser browser = session.createBrowser(queue);Enumeration<?> messages = browser.getEnumeration();while (messages.hasMoreElements()) {TextMessage textMsg = (TextMessage) messages.nextElement();System.out.println(textMsg);}browser.close();conn.close();} catch (Exception e) {e.printStackTrace();} }
转载于:https://www.cnblogs.com/huey/p/4748314.html
JMS - QueueBrowser相关推荐
- jboss hornetq jms 用户文档
HornetQ 2.1用户手册 Putting the buzz in messaging Table of Contents 1. 法律声明 2. 前言 3. 项目信息 3.1. 软件下载 3.2. ...
- Java Spring连接Tibco Queue 总结
发送信息到Tibco Queue的完整代码. package com.jms;import java.util.Enumeration; import java.util.Properties;imp ...
- 安卓9可用的性能监视器_监视应用程序生态系统的性能和可用性
在这个三篇文章的系列的第1部分和第2部分中 ,我介绍了监视Java应用程序的技术和模式,重点是JVM和应用程序类. 在最后的最后一部分中,我将重点放在介绍用于从应用程序的依赖项(例如底层操作系统,网络 ...
- JMS ActiveMQ研究文档
1. 背景 当前,CORBA.DCOM.RMI等RPC中间件技术已广泛应用于各个领域.但是面对规模和复杂度都越来越高的分布式系统,这些技术也显示出其局限性:(1)同步通信:客户发出调用后,必须等待服务 ...
- JMS : Java Message Service (Java消息服务)之一 [转]
为什么80%的码农都做不了架构师?>>> 1 引言 1.1 编写目的 本文作为B2bi项目中开源产品JORAM的使用指导文档,旨在帮助项目组人员方便明了的进行JMS模块的详细设 ...
- spring jms 事务_Spring JMS:处理事务中的消息
spring jms 事务 1.引言 这篇文章将向您展示使用JMS异步接收消息期间使用者执行过程中的错误如何导致消息丢失. 然后,我将解释如何使用本地事务解决此问题. 您还将看到这种解决方案在某些情况 ...
- Spring JMS:处理事务中的消息
1.引言 这篇文章将向您展示在使用JMS异步接收消息期间,使用者执行过程中的错误如何导致消息丢失. 然后,我将解释如何使用本地事务解决此问题. 您还将看到这种解决方案在某些情况下可能导致消息重复(例如 ...
- 【ActiveMQ】JMS中间件ActiveMQ详解
1.JMS介绍 Java Message Service(JMS)是SUN提出的旨在统一各种MOM(Message-Oriented Middleware )系统接口的规范,它包含点对点(Point ...
- JAVA JMS 简介
JMS概述 消息服务是指,两个或者多个客户机能够通过发送和接受消息(以对等的方式)通信.消息是通过消息服务器有一个客户机发送到另一个客户机的"一块"数据,可以是文本的,也可是数值的 ...
最新文章
- 夏夏的php开发笔记开写啦
- python 3读取文件-python3的txt文件读写
- 研究发现,脸谱网和谷歌在流媒体上有广告跟踪器
- 区块链预言机(5)预言机原理
- 七十七、 二叉树的层次遍历和最大深度
- JDK 13中的JEP 355文本块
- C++实现简单走迷宫的代码
- ConcurrentHashMap和Collections.synchronizedMap(Map)的区别是什么?
- 20145122 《Java程序设计》第5周学习总结
- ios上传闪退 php,iOS应用上架后出现闪退原因浅析
- 应用宝apk_我花3天对比了8个手机应用商店 发现了这个你从未留意过的细节
- 如果您的iPhone关闭,静音或不打扰,警报是否会起作用?
- 关于H5唤起地图导航小结
- 洛谷-5149 会议座位
- Android项目实战--【谁是歌手-布局篇】
- ffmpeg分离视频音频流!
- 接口自动化测试项目实战
- c# mysql登录界面_C#窗体控件与MySQL实现登录功能
- Interactron | 体现自适应的目标检测器
- 海纳百川 有容乃大, 壁立千仞 无欲则刚
热门文章
- CTFshow 命令执行 web38
- 【解决方案】调用multiprocessing中创建的文件无法打开的问题FileNotFoundError: [WinError 2]
- 递归生成全排列【C/C++】
- java多线程共享信息_java多线程信息共享
- JS JavaScript模块化(ES Module/CommonJS/AMD/CMD)
- Ubuntu cocos2d-x 3.13版本游戏开发学习系列3 Cocos2d-x的坐标系
- chardet坑——比蜗牛还慢
- 利用.bat(批处理)来删除KEIL编译生成的无用文件
- 去百度,还是去创新工厂
- 高效缓存Memcached 集成使用说明