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

2023年7月17日 439次阅读

我的应用程序要求通过HTTP / FTP协议将文件从一个应用程序发送到另一个应用程序.我找到了以下链接,告诉我们使用Active MQ和Blopo消息可以完成相同的操作：

activemq.apache.org/blob-messages.html

我在我的Windows机器上配置了ActiveMq 5.8,在我的pom.xml中包含了ActiveMQ lib所需的依赖项,我可以使用org.springframework.jms.core.JmsTemplate发送简单的javax.jms.TextMessage和javax.jms.MapMessage

但是当我使用以下方法移动发送BlobMessage时,从javax.jms.Session对象创建BlobMessage对象时出现编译时错误

The method createBlobMessage(File) is undefined for the type 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);
          }
        }


);
}

请帮忙解决这个编译时错误.

问候,

阿伦

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

点赞