用于R的ActiveMQ软件包 [英] ActiveMQ package for R

问题描述

我正在尝试使用R构建的模型将消息发送到activeMQ队列.快速浏览R将我指向 Rjms ；但是，当我在CRAN上检查软件包时，收到一条错误消息:软件包'Rjms'已从CRAN存储库中删除".进一步的谷歌搜索只是将我推回Rjms.

I'm trying to have a model I've built in R sent messages to an activeMQ queue. A quick googling of R points me to Rjms; however, when I check for the package on CRAN, I get an error saying "Package ‘Rjms’ was removed from the CRAN repository." Further googling just pushes me back to Rjms.

鉴于此，是否有R语言提供的ActiveMQ软件包?

Given this, is there an ActiveMQ package available in the R language?

推荐答案

我最终通过wget tarball(而不是通过github)安装软件包，因为在加载通过github安装的软件包时遇到了Java异常.

I ended up installing the packages via wget tarballs rather than via github, as I was encountering a Java exception when loading the packages installed via 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交互式终端中:

then within the R interactive terminal:

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异常:

When loading the package, I am indeed able to initialize a logger and send a message without a Java exception:

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

这篇关于用于R的ActiveMQ软件包的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！