activemq5.2发送跟接收BlobMessage简单实例

activemq5.2发送和接收BlobMessage简单实例

?
?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();?
}
}