1,
myConnFactory = new com.sun.messaging.ConnectionFactory();
Connection myConn = myConnFactory.createConnection();
Session mySess = myConn.createSession(false, Session.AUTO_ACKNOWLEDGE);
myQueue = new com.sun.messaging.Queue("world");
MessageProducer myMsgProducer = mySess.createProducer(myQueue);
TextMessage myTextMsg = mySess.createTextMessage();
myTextMsg.setText("Hello World");
System.out.println("Sending Message: " + myTextMsg.getText());
myMsgProducer.send(myTextMsg);
MessageConsumer myMsgConsumer = mySess.createConsumer(myQueue);
Message msg = myMsgConsumer.receive();
2,
String MYCF_LOOKUP_NAME = "MyConnectionFactory";
String MYQUEUE_LOOKUP_NAME = "MyQueue";
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.fscontext.RefFSContextFactory");
env.put(Context.PROVIDER_URL, "file:///C:/Temp");
ctx = new InitialContext(env);
myConnFactory = (javax.jms.ConnectionFactory) ctx.lookup(MYCF_LOOKUP_NAME);
myQueue = (javax.jms.Queue)ctx.lookup(MYQUEUE_LOOKUP_NAME);
3,ConnectionFactory myFctry = new com.sun.messaging.ConnectionFactory();
myFctry.setProperty(ConnectionConfiguration.imqAddressList,
"localhost:7676, broker2:5000, broker3:9999");
myFctry.setProperty(ConnectionConfiguration.imqReconnectEnabled, "true");
Comannd:
imqbrokerd -tty
The -tty option causes all logged messages to be displayed to the terminal console.
imqcmd query bkr -u admin
to test a Broker
imqcmd purge dst -t destType -n destName
分享到:
相关推荐
openmq 编译依赖包
OpenMq 基本管理命令,安装、集群、管理命令、查看队列、链接等相关服务
sun公司OpenMq的安装指南,比较详细,可以惨嚎
openmq 4.4.2源码
habari-openmq-20190131-src.zip
OpenMQ项目JMS SI(规范实施) 该项目包含以下模块:更多详细信息可在下一个文件夹中找到,
habari-openmq-6.1-installer.exe
在传送过程中,系统处理JMS消息分为以下两类: ■ 有效负荷消息,由生成方发送给使用方的消息。 ■ 控制消息,代理与客户端运行时环境之间传送的私有消息,用于确保有效负荷消息成功传送和控制跨连接的消息流。...
基于JMS标准的消息中间件实现的产品有很多,JBossMQ、ActiveMQ、OpenMQ、OpenJMS等等,最常用的还是apache的ActiveMQ。有时也使用Sun的OpenMQ。在官网http://mq.java.net/处可以下载。Open Message Queue是Sun Java ...
消息队列中间件调研文档。ActiveMQ、RabbitMQ、RocketMq、Joram、HornetQ、OpenMQ等的对比。
glassfish食谱将安装和配置GlassFish应用程序服务器以及与GlassFish应用程序服务器捆绑在一起的OpenMQ消息代理。 该菜谱还定义了用于创建和配置GlassFish应用程序域和OpenMQ代理实例的资源。 项目中提供了一个带有...
ActiveMQ、RabbitMQ、RocketMq、Joram、HornetQ、OpenMQ、MuleMQ、SonicMQ、ZeroMQ、Kafka 从关注度,成熟度,社区活跃度、文档、特点、授权方式、语言、事务、集群、持久化、协议,部署方式、UI、评价等诸多维度
这使得用Rust编写的程序可以与消息队列服务进行交互,例如ActiveMQ,RabbitMQ,HornetQ和OpenMQ。 连接订阅发送确认(自动/客户端/客户端个人)交易收据断开心跳信号踩踏程序的API尚不稳定,并且可能在v1.0之前波动...
使用ActiveMQ(或OpenMQ)。 使用SOAP协议,创建一个Web服务,该服务使用RSA协议对给定消息进行加密(首先在数据库中找到接收者的公共密钥),然后将其发送给接收者的适当地址,而发送消息的客户端可以发送回复。 ...
OpenMQ Open-MQ 是一个开源的消息中间件,类似IBM的 WebSphere MQ(MQSeries),采用 C++ 和 Qt 库编写的,支持Windows、Unix 以及 Mac OS 平台,支持 JMS。 ZeroMQ ZeroMQ(简称ZMQ)是一个基于消
为 OpenMQ (GlassFish JMS) / Oracle WebLogic MQ 开发基于队列消息管理 gui 的工具。 工具名称为 QBrowserV2。 它旨在实现新消息创建/发送、删除消息、转发消息、订阅主题等功能。