Displaying 2 results from an estimated 2 matches for "aqpol".
Did you mean:
apol
2012 Dec 05
0
AQ-R 0.2 // realtime messaging.
...vers [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()...
2012 Dec 05
0
AQ-R 0.2 // realtime messaging.
...vers [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()...