使用带有 BlobMessage 的 Active MQ 发送文件

Question

我的应用程序要求通过 HTTP/FTP 协议将文件从一个应用程序发送到另一个应用程序。我发现以下链接告诉我们可以使用支持 Blob 消息的 Active MQ 来完成同样的操作：

activemq.apache.org/blob-messages.html

我在我的 Windows 机器上配置了 ActiveMq 5.8，在我的 pom.xml 中包含了 ActiveMQ 库所需的依赖项，我可以发送简单的 javax.jms.TextMessage 和 @ 987654323@与org.springframework.jms.core.JmsTemplate

但是当我开始使用以下方法发送 BlobMessage 时，在从 javax.jms.Session 对象创建 BlobMessage 对象时出现编译时错误，上面写着

方法 createBlobMessage(File) 未定义 Session 类型

这是我使用的方法：

public void sendFile(){


        jmsTemplate.send(
        new MessageCreator() {
          public Message createMessage(Session session) throws JMSException {


              BlobMessage message = session.createBlobMessage(new File("/foo/bar"));
              return jmsTemplate.send(message);
          }
        }


);
}

请帮助解决这个编译时错误。

问候，

阿伦

Answer 1

BlobMessage 方法不是 JMS 规范方法，因此它们不会出现在 javax.jms.Session 接口中，您需要强制转换为 org.apache.activemq.ActiveMQSession 才能使用 BlobMessage 特定功能。