文件传输

启动Primeton MQ时，也启动Jetty(即pmq.xml中有import jetty.xml)，此时Jetty中运行了一个Primeton MQ自带的Http文件服务器。

使用

jms.blobTransferPolicy.uploadUrl=http://127.0.0.1:8161/fileserver

创建Connection，然后创建Consumer和Producer。

Producer:

 BlobMessage blobMessage = session.createBlobMessage(new File("filePath");
 producer.send(blobMessage);

Consumer：

public class MyListener implements MessageListener {
  public void onMessage(Message message) {
    if (message instanceof BlobMessage) {
      BlobMessage blobMessage = (BlobMessage) message;
      InputStream in = blobMessage.getInputStream();

      // process the stream...
    }
  }
}

注：

其中 http://127.0.0.1:8161/fileserver 为系统自带文件服务器地址，生产不推荐使用，建议用户自己搭建文件服务器。