Rjms & ActiveMQ：初始化记录器时出现异常答案

【问题标题】：Rjms & ActiveMQ: exception when initializing loggerRjms & ActiveMQ：初始化记录器时出现异常
【发布时间】：2015-02-02 10:54:17
【问题描述】：

我安装了R 的Rjms 包，因为我想将消息发送到已经为我设置好的ActiveMQ 消息队列（称为test）。由于Rjms 不在CRAN 上，我使用ActiveMQ package for R 中的说明从github 安装了它。

但是，我注意到了两件事。在安装Rjmsjars 时，我收到一条警告说No man pages found in package ‘Rjmsjars’。我认为这可能无关紧要，但我想包括在内以防万一。

library(devtools)
install_github("cran/Rjmsjars")
install_github("smschauhan/Rjms/src/main/resources/Rjms")

加载Rjms 后，我尝试使用以下代码初始化记录器：

library(Rjmsjars)
library(Rjms)
logger <- initialize.logger('tcp://app1.xxx.xxxxx.net:61616','Q','test')

但是，当我尝试这样做时，我收到以下错误：

Error in .jnew("org/math/r/activemq/logger/Producer", url, type, name) : 
      java.lang.ClassNotFoundException

由于错误消息不是很清楚，我不确定如何解决。有什么想法吗？

【问题讨论】：

另外，有没有公开的 ActiveMQ 记录器，所以我可以为大家设置一个可重现的示例？

标签： r activemq message-queue

【解决方案1】：

我最终通过 wget tarballs 而不是通过 github 安装了这些软件包，并且没有遇到同样的错误。

从命令行：

wget http://cran.r-project.org/src/contrib/Archive/Rjmsjars/Rjmsjars_0.0.1.tar.gz
wget http://cran.r-project.org/src/contrib/Archive/Rjms/Rjms_0.0.5.tar.gz

然后在 R 交互终端中：

install.packages('~/Rjmsjars_0.0.1.tar.gz', repos = NULL, type ="source")
install.packages('~/Rjms_0.0.5.tar.gz', repos = NULL, type ="source")

加载包时，我能够初始化记录器并发送消息，而不会出现 Java 异常：

library(Rjms)
logger <- initialize.logger('tcp://xxx.xx:61616', 'Q', "test")
send.status<-to.logger(logger, "{xxx: xxx, xxx: .xx}")
send.status
[1] TRUE

【讨论】：