Displaying 2 results from an estimated 2 matches for "aqwaitfordata".
2012 Dec 05
0
AQ-R 0.2 // realtime messaging.
...t
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...
2012 Dec 05
0
AQ-R 0.2 // realtime messaging.
...t
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...