ActiveMQ를 통해 거대한 파일을 보내야하는데 그 이유는 for Large message이라는 설명서를 따르기는했지만에 파일을 채우는 중 오류 이 발생했습니다. 내 질문은ActiveMq에서 파일 문자열 보내기 및 받기 5.15.2
는 pom.xml 파일
BytesMessage message = session.createBytesMessage();
FileInputStream fileInputStream = new FileInputStream(txFile);
BufferedInputStream bufferedInput = new BufferedInputStream(fileInputStream);
message.setObjectProperty("JMS_AMQ_InputStream", bufferedInput);
producer.send(message);
ActiveMQ를 5.15.2에 파일을 전송하기위한 올바른 접근 방식이란
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-all</artifactId>
<version>5.15.2</version>
</dependency>
예외 :
Caught: javax.jms.MessageFormatException: Only objectified primitive objects, String, Map and List types are allowed but was: [email protected] type: class java.io.BufferedInputStream
javax.jms.MessageFormatException: Only objectified primitive objects, String, Map and List types are allowed but was: [email protected] type: class java.io.BufferedInputStream
at org.apache.activemq.command.ActiveMQMessage.checkValidObject(ActiveMQMessage.java:538)
at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:504)
at org.apache.activemq.command.ActiveMQMessage.setObjectProperty(ActiveMQMessage.java:488)
at org.apache.activemq.command.ActiveMQBytesMessage.setObjectProperty(ActiveMQBytesMessage.java:918)
at com.svm.mq.test.Producer.run(Producer.java:80)
at java.lang.Thread.run(Thread.java:745)`