我的应用程序要求通过 HTTP/FTP 协议将文件从一个应用程序发送到另一个应用程序。我发现以下链接表明可以使用带有 Blob 消息的 Active MQ 来完成相同的操作:
activemq.apache.org/blob-messages.html
我在我的 Windows 机器上配置了 ActiveMq 5.8 ,在我的机器中包含了ActiveMQ lib所需的依赖项,pom.xml
我能够发送简单的javax.jms.TextMessage
和javax.jms.MapMessage
org.springframework.jms.core.JmsTemplate
BlobMessage
但是,当我开始使用以下方法发送 BlobMessage 时,在从对象创建对象时出现编译时错误 javax.jms.Session
,上面写着
Session 类型的方法 createBlobMessage(File) 未定义
这是我正在使用的方法:
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);
}
}
);
}
请帮助解决此编译时错误。
问候,
阿伦