ActiveMQ5.8.0 发送BlobMessage出错

Question

activemq401 Unauthorized异常BlobMessage

Answer 1

用过5.6的，不过没传过文件，public static void main(String[] args) { ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
try {
Connection connection = factory.createConnection(); Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE); Destination destination = session.createTopic("test_topic1"); MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);  

while (i<1000000) {
Message message = session.createTextMessage("hello world!" + i);
producer.send(message);

}
producer.close();
session.close(); connection.close();


} catch (JMSException e) {
e.printStackTrace();
}finally{

}

Answer 2

tcp://localhost:61616?jms.blobTransferPolicy.defaultUploadUrl=http://localhost:8161/fileserver/\
activeMQ 5.7 没有问题ActiveMQ 5.8 要求访问 http://localhost:8161/fileserver/ 带User and passsw

Answer 3

请问楼上，带上user和passw的格式应该怎么写呢？
求举个例子，谢谢～

Answer 4

同问,如何解决??????????谢谢,带上user和passw的格式应该怎么写呢？

Answer 5

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
            ActiveMQConnection.DEFAULT_USER,
            ActiveMQConnection.DEFAULT_PASSWORD,
            "tcp://localhost:61616?jms.blobTransferPolicy.defaultUploadUrl=http://localhost:8161/fileserver/");
增加用户名和密码