[R-pkgs] AQ-R 0.2 // realtime messaging.

From: Ulrich Staudinger <ustaudinger_at_activequant.com>
Date: Wed, 05 Dec 2012 14:09:42 +0100

Hi there,

I am glad to announce AQ-R 0.2 has been successfully built and is available via install.packages("aqr",

The most important new feature is real-time messaging from within R.

AQ-R 0.2 enables you to send and receive byte[] messages within R through a STOMP compliant messaging server, such as the ActiveQuant Master Server. There are various STOMP protocol compliant servers [1].

You can build arbitrarily complex messaging infrastructures, where messages flow between R instances or other-language messaging components.

The key functions are:
aqSubscribe(aChannel) - subscribe to messages in a channel aqWaitForData() - a blocking call that waits for data to arrive aqPoll() - fetches all messages from the internal buffer (not the STOMP server)
aqSend(channel, text) - send a message to a channel

This extension does buffer incoming data between consecutive aqPoll() calls.

The core loop for using this should look like:


     data = aqPoll()

Version 0.2 is beta. I have thoroughly tested it on Windows and on Linux. I am looking for more testers and feedback.

Demo video at [2].

<buzz>I hope it opens up an easy venue to build distributed calculators without the hassle of going through MPI or anything similar, in a truely cross-platform approach, making R a viable citizen in highly heterogenous message processing environments. </buzz>


[1] http://stomp.github.com/implementations.html#STOMP_1_0_Servers
[2] http://www.youtube.com/watch?v=h1gLgJOEWW0

Ulrich Staudinger, ActiveQuant GmbH

P: +41 79 702 05 95

Connect online:https://www.xing.com/profile/Ulrich_Staudinger

	[[alternative HTML version deleted]]

R-packages mailing list
Received on Thu 06 Dec 2012 - 00:56:54 EST

This archive was generated by hypermail 2.2.0 : Thu 06 Dec 2012 - 01:00:02 EST