【问题标题】:Setting ActiveMQ Objectmessage serializable from Scala从 Scala 设置 ActiveMQ Objectmessage 可序列化
【发布时间】: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


    【解决方案1】:

    我刚刚添加了以下静态代码行,它可以工作:

    System.setProperty("org.apache.activemq.SERIALIZABLE_PACKAGES", """*""")
    

    【讨论】:

      猜你喜欢
      • 2011-10-17
      • 1970-01-01
      • 2019-04-09
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2018-09-19
      • 2019-07-09
      • 2015-12-16
      相关资源
      最近更新 更多