[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",
repos="http://R-Forge.R-project.org").

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:

while(aqWaitForData()){

     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>

Cheers,
Ulrich

References:
[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
E:ustaudinger_at_activequant.com

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


	[[alternative HTML version deleted]]

_______________________________________________
R-packages mailing list
R-packages_at_r-project.org
https://stat.ethz.ch/mailman/listinfo/r-packages
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