【发布时间】:2016-04-26 13:14:23
【问题描述】:
在 ActiveMQ 版本更改(从 5.9.0 r4 到 r4)后,有必要明确标记 ActiveMQ 的 ObjectMessage 可序列化,如下所示:http://activemq.apache.org/objectmessage.html。按照建议设置环境变量 (-Dorg.apache.activemq.SERIALIZABLE_PACKAGES="*") 可以正常工作,但是,在我们的案例中,这不是一个优雅的解决方案。我需要从 Scala 源代码进行设置。目前连接设置如下:
val properties = new java.util.Properties()
properties.setProperty(javax.naming.context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.jndi.ActiveMQInitialContextFactory")
properties.setProperty(javax.naming.context.PROVIDER_URL, "tcp://localhost:61616")
val context = new InitialContext(properties)
val topicConnection = context.lookup("ConnectionFactory").asInstanceOf[TopicConnectionFactory].createTopicConnection
我找不到可以插入建议的factory.setTrustAllPackages(true) 的地方。谁能告诉我们在我们的例子中如何做到这一点,或者如何从 Scala 设置 org.apache.activemq.SERIALIZABLE_PACKAGES 环境变量?谢谢!
【问题讨论】:
标签: scala serialization activemq