- 浏览: 665589 次
- 性别:
- 来自: 长沙
文章分类
- 全部博客 (364)
- quick start (57)
- bboss aop (43)
- bboss mvc (48)
- bboss persistent (96)
- bboss taglib (30)
- bboss event (10)
- bbossgroups (52)
- bboss (32)
- bboss会话共享 (17)
- bboss rpc (7)
- bboss 国际化 (5)
- bboss 序列化 (9)
- bboss cxf webservice (8)
- bboss hessian (3)
- bboss 安全认证SSO (15)
- bboss 工作流 (6)
- 平台 (18)
- bboss quartz (3)
- 杂谈 (5)
- 大数据 (1)
- bboss elastic (24)
- bboss http (1)
- bboss kafka (1)
- Elasticsearch Scroll和Slice Scroll查询API使用案例 (1)
最新评论
-
qianhao123:
...
采用gradle构建和发布bboss方法介绍 -
qianhao123:
[img][/img]
采用gradle构建和发布bboss方法介绍 -
yin_bp:
欢迎大家参与working
高性能elasticsearch ORM开发库使用介绍 -
qq641879434:
万分感谢
bboss 持久层sql xml配置文件编写和加载方法介绍 -
yin_bp:
qq641879434 写道怎么设置配置文件 可以查看执行的S ...
bboss 持久层sql xml配置文件编写和加载方法介绍
bbossgroups jms组件框架
bboss aop框架的jms组件提供针对jms规范的一组简单的操作接口,可一通过 JMSTemplate组件来实现JMS消息的接收和发送功能。
系统中提供了两个JMS Template实现:
org.frameworkset.mq.JMSTemplate—提供所有的jms接收和发送接口,不带主题订阅功能接口
org.frameworkset.mq.JMSReceiveTemplate-提供所有的jms接收和发送接口,带主题订阅功能接口
下面是举一些简单的例子,说明这连个模板类的使用方法。
系统中可以方便地通过扩展连接工程管理抽象类
org.frameworkset.mq.JMSConnectionFactory来实现不同的jms服务提供商的jms服务器的支持。开发人员只需要实现JMSConnectionFactory的抽象方法:
/**
* 构建特定提供商的连接工厂
*
* @return
*/
public abstract ConnectionFactory buildConnectionFactory() throws Exception;
bboss aop框架中的jms组件提供了对apache activemq server的实现:
org.frameworkset.mq. AMQConnectionFactory
本章都是以apache activemq server为例来说明jms组件的基本接口。
由于篇幅问题,省略相关配置的介绍,感兴趣的朋友可以到以下地址下载详细的文档介绍:
http://sourceforge.net/projects/bboss/files/bbossgroups-1.0/bbossgroups%20document.zip/download
其中aop框架技术白皮书中有bboss jms组件的详细介绍,这里只列出一些测试用例。
测试用例
1.2.1 从连接池工厂中获取jms connection
下面的代码从连接池工厂中获取jms connection对象,先后获取两次验证连接池是否生效。
JMSConnectionFactory factory = (JMSConnectionFactory)BaseSPIManager.getBeanObject("test.amq.PooledConnectionFactory");
try
{
Connection connection = factory.getConnection();
connection.start();
connection.close();
connection = factory.getConnection();
connection.start();
connection.close();
}
catch (JMSException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
1.2.2 从连接工厂中获取jms connection
从连接工厂中获取jms connection,每次都会创建新的jms connection
JMSConnectionFactory factory = (JMSConnectionFactory)BaseSPIManager.getBeanObject("test.amq.ConnectionFactory");
try
{
Connection connection = factory.getConnection();
connection.start();
connection.close();
connection = factory.getConnection();
connection.start();
}
catch (JMSException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
1.2.3 向队列atest中发送消息
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
template.send("atest", "ahello");
}
catch (JMSException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.4 向队列atest发送持久化的消息
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
template.send("atest", "phello",true);
}
catch (JMSException e)
{
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.5 向队列atest中发送持久化消息,指定优先级和过期时间
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
template.send("atest", "allhello",true,4,10000);
}
catch (JMSException e)
{
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.6 从队列atest中同步接收消息
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
Message msg = template.receive("atest");
System.out.println("testReceiveMessage:"+ msg);
}
catch (JMSException e)
{
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.7 从队列atest中异步接收消息
利用test.jms.receive.template模板从队列atest中异步接收消息。
JMSReceiveTemplate template = (JMSReceiveTemplate)BaseSPIManager.getBeanObject("test.jms.receive.template");
try
{
template.setMessageListener("atest",new MessageListener() {
public void onMessage(Message arg0)
{
System.out.println("msg comming:"+arg0);
}
});
}
catch (Exception e)
{
template.stop();
}
finally
{
}
1.2.8 向主题getsubtest发送消息
JMSTemplate template = (JMSTemplate)BaseSPIManager.getBeanObject("test.jmstemplate");
try
{
template.send("topic://getsubtest", "getsubtest");
}
catch (JMSException e)
{
e.printStackTrace();
}
finally
{
template.stop();
}
1.2.9 从主题订阅消息
JMSReceiveTemplate template = (JMSReceiveTemplate)BaseSPIManager.getBeanObject("test.topic.receive.jmstemplate");
try
{
template.getTopicSubscriber("getsubtest", "subscribename").setMessageListener(new MessageListener() {
public void onMessage(Message arg0)
{
System.out.println("topic msg comming:"+arg0);
}
});
}
catch (Exception e)
{
template.stop();
}
finally
{
}
1.2.10 从主题退订消息
JMSReceiveTemplate template = (JMSReceiveTemplate)BaseSPIManager.getBeanObject("test.topic.receive.jmstemplate");
try
{
template.unsubscribe("subscribename");
}
catch (Exception e)
{
template.stop();
}
finally
{
}
注意事项:使用主题发布和订阅消息时,不要使用连接池连接工厂。
发表评论
-
bboss离线开发文档下载
2013-05-14 18:08 1775bboss离线开发文档下载 为了便于bboss开发人员离线查找 ... -
bboss 3.6发布,丰富的功能扩展和改进
2012-10-07 09:50 1928bboss 3.6 (官网下载,sf下载)发布了,新版本相比之 ... -
Bboss国际化实践PPT
2012-06-10 12:52 1252Bboss国际化实践PPT,点击链接即可下载: Bboss国际 ... -
bboss国际化功能简介
2012-05-09 08:59 1158借助bboss国际化功能,我们可以非常方便快捷地实现系统 ... -
bboss 4.10.7及更低版本ant构建方法
2012-03-23 22:54 5829本文适用bboss 4.10.7及更低版本,4.10.8及后续 ... -
bboss 将内容为GBK编码文件转UTF-8工具介绍
2012-03-23 15:53 1606bboss 将内容为GBK编码文件转UTF-8工具介绍 bb ... -
bbossgroups 3.5 发布
2012-02-18 14:51 1098版本:bbossgroups-3.5 官网:http://w ... -
bboss 序列化功能详解
2012-01-27 11:04 1563bboss 序列化功能详解,bboss序列化组件是bbossg ... -
bboss 序列化机制重大改进-支持复杂对象及对象之间关系序列化和恢复功能
2012-01-09 23:19 1309bboss 序列化机制重大改进-支持复杂对象及对象之间关系序列 ... -
bbossgroups 3.4发布
2011-10-26 22:45 1066版本: bbossgroups-3.4 bboss gro ... -
bbossgroups 对象xml序列化/反序列化性能测试
2011-10-10 23:16 1296本文探讨开源项目bbossgroups 中对象xml序列化/反 ... -
bbossgroups 开发系列文章之一 最佳实践
2011-10-01 12:50 1362bbossgroups 开发系列文章之-最佳实践 一、概述 ... -
bboss 组件容器的使用方法浅析
2011-08-20 00:21 1562本文重点介绍bboss 中的4大组件容器的特点及使用方法 4 ... -
bbossgroups 3.3 发布
2011-08-19 23:02 1019bbossgroups 3.3 发布,该版本在3.2的基础上做 ... -
bbossgroups框架发布的jar包和依赖jar包概览
2011-08-09 23:16 1923bbossgroups框架发布的jar包和依赖jar包概览 j ... -
我们需要一站式解决方案还是混合组合方案
2011-08-05 14:10 1103这年头提供一站式解决方案的框架才具备真正的核心竞 ... -
bbossgroups的特色特点介绍
2011-07-10 10:49 1374很多朋友都在问bbossgroups框架和其他mvc框架 、s ... -
bbossgroups 相关资料整理
2011-06-24 08:13 1079为了方便大家了解bbossgroups,我特意把相关的资料整理 ... -
bbossgroups项目demo站点升级完毕,朋友们可以去看看
2011-06-19 22:52 1126bbossgroups项目demo站点升级完毕,访问地址: h ... -
开源项目bbossgroups,诚邀有志之士加盟
2011-06-15 10:03 537国内新兴的j2ee开源项目bbossgroups,诚邀有志之士 ...
相关推荐
bbossgroups 3.1SQLExecutor组件ap使用实例bbossgroups 3.1SQLExecutor组件ap使用实例
bbossgroups 开发系列文章之一 最佳实践bbossgroups 开发系列文章之一 最佳实践bbossgroups 开发系列文章之一 最佳实践
bbossgroups 3.1培训教程 bbossgroups 3.1即将发布,新增很多实用的功能,先发给培训教程上来:比如组件异步调用,mvc地址别名配置,sql配置管理,配置sql执行组件等等
Bbossgroups体系架构.ppt
bbossgroups 3.0 发布,这是国内首款集aop,mvc,persistent,jsp taglib,分布式rpc服务,分布式事件框架于一身的企业级j2ee开发框架 详细信息请看: http://www.javaeye.com/news/20177-bbossmvc-bbossaop
NULL 博文链接:https://yin-bp.iteye.com/blog/1004719
弹性Tran老板数据交换模块使用文档: : Bboss是一个很好的Elasticsearch Java Rest客户端。 它运行并访问像mybatis这样的... 首先将BBoss的maven依赖项添加到pom.xml中: < dependency> < groupId>com.bbossgroups.p
java版地图源码弹性搜索Bboss Bboss 是一个很好的 elasticsearch Java rest 客户端。 它以类似于mybatis的方式操作和访问elasticsearch。 环保要求 JDK 要求:JDK 1.7+ Elasticsearch ...>com.bbossgroups.p