package com.work.activemq;
import java.io.File;
/**
* @author wangmingjie
* @date 2009-7-29上午09:21:53
*/
public class BlobMessageClient {
/**
* topic方式,必须先启动消费者,然后是生产者,否则接收不到消息。
* queue方式,最好先启动生产者,然后启动消费者,否则也容易收不到消息。
* @param args
*/
public static void main(String[] args) throws Exception {
BlobMessageSendTest producer = new BlobMessageSendTest();
BlobMessageReceiveTest consumer = new BlobMessageReceiveTest();
String fileName = "e:/javagood/clearbug1.6.zip";
// String fileName = "d:/JAVA+开发视频会议系统详细设计.doc";
File file = new File(fileName);
producer.produceMessage(file);
producer.close();
// 延时500毫秒之后停止接受消息
Thread.sleep(2000);
// 开始监听
consumer.consumeMessage();
// 延时500毫秒之后发送消息
Thread.sleep(2000);
consumer.close();
}
}
分享到:
相关推荐
activeMQ5.2的jar包及使用实例,它既支持点到点(point-to-point)(PTP)模型和发布/订阅(Pub/Sub)模型。支持同步与异步消息发送。JDBC持久性管理使用数据库表来存储消息 。
ActiveMQ 5.2 Reference Guide v1.8 英文版
activemq 通过ajax发送接收消息简单例子
ActiveMQ新版本的指导手册,讲述内容涵盖了activeMQ的配置到实现原理,包括持久化等特性。
这是我精力整理的ActiveMQ发送和接收protobuf协议消息的实例。 也对ActiveMQ进行了简化封装,也配置了自动重连机制,亲测可用!
SpringBoot+ActiveMq+MQTT实现消息的发送和接收 后台消费者、生产者、消息发送接口、发送消息业务类等相关配置
实现了ActiveMQ的初步封装,比较适合新手入门学习,简单明了
ActiveMQ基于Java和JavaScript的应用实例 改造ActiveMQ官方例子,用Java和JavaScript实现实时监听,收发消息
activeMQ的测试工具,用于发送和接收activeMQ消息,jar包形式的,安装完jdk之后用java -jar xxx.jar命令运行
springboot集成activemq实现消息接收demo
本代码关于activemq-cpp的核心代码参考的chenxun2009的博客园,其他部分包括:从配置文件中读取消息通道,过滤条件等信息。
今天小编就为大家分享一篇python 发送和接收ActiveMQ消息的实例,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
使用C# 2013开发的ActiveMQ发布者和接收者
Spring JMS with ActiveMQ – 发送和接收消息示例。 此代码假装是将 ActiveMQ 与 JMS Spring Beans 一起使用的简单概念证明。 这个想法是查找 Spring 上下文来处理 JMS bean。 配置 您需要配置一个名为 BATCH_CONF ...
支持持久化的采用Spring整合activeMQ与quartz的JMS数据同步实例,包含依赖的jar包
JMS简明教程+JMS规范教程+activemq以及activemq和tomcat的整合+整合实例代码+持久化消息配置以及工程+tomcat服务器的配置+整合需要的lib文件+部署多个tomcat服务器方案等
activeMQ的发送消息后接收者返回信息
此实例基于Spring+JMS+ActiveMQ+Tomcat,注解的完整实例,包含jar包