Description Usage Arguments Details Value Author(s) References See Also Examples
Subscribe to one or more Redis message channels.
1 | redisSubscribe(channels, pattern=FALSE)
|
channels |
A character vector or list of channel names to subscribe to. |
pattern |
If TRUE, allow wildcard pattern matching in channel names, otherwise names indicate full channel names. |
(From the Redis.io documentation):
redisSubscribe
, redisUnsubscribe
and redisPublish
implement the Publish/Subscribe messaging paradigm where (citing Wikipedia)
senders (publishers) are not programmed to send their messages to specific
receivers (subscribers). Rather, published messages are characterized into
channels, without knowledge of what (if any) subscribers there may be.
Subscribers express interest in one or more channels, and only receive messages
that are of interest, without knowledge of what (if any) publishers there are.
Use the Redis function redisUnsubscribe
to unsubscribe from one or
more channels. Service incoming messanges on the channels with either
redisGetResponse
or redisMonitorChannels
.
Use of any other Redis after redisSubscribe
prior to calling
redisUnsubscribe
will result in an error.
A list conforming to the Redis subscribe response message. Each subscribed channel corresponds to three list elements, the header 'subscribe' followed by the channel name and a count indicating the total number of subscriptions.
B. W. Lewis
http://redis.io/commands
redisSubscribe
redisPublish
redisUnsubscribe
redisGetResponse
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 | ## Not run:
redisConnect()
# Define a callback function to process messages from channel 1:
channel1 <- function(x) {
cat("Message received from channel 1: ",x,"\n")
}
# Define a callback function to process messages from channel 2:
channel2 <- function(x) {
cat("Message received from channel 2: ",x,"\n")
}
redisSubscribe(c('channel1','channel2'))
# Monitor channels for at least 1 minute:
t1 <- proc.time()[[3]]
while(proc.time()[[3]] - t1 < 60)
{
redisMonitorChannels()
Sys.sleep(0.05)
}
redisUnsubscribe(c('channel1','channel2'))
## End(Not run)
|
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.