R client for Apache Pulsar
For more details about Apache Pulsar, click here
library(devtools)
install_github("bbonnin/rpulsar")
producer <- Pulsar$new("localhost:8080", "persistent/public/default/my-topic")
producer$send("hello")
# Function invoked for each new message
# Do not forget to return TRUE to ack the message !!!
onMsg = function(payload) {
cat("Received string:", rawToChar(payload), "\n")
TRUE
}
consumer <- Pulsar$new("localhost:8080", "persistent/public/default/my-topic/my-sub",
onMessageFct = onMsg)
install.packages("devtools")
library(devtools)
devtools::install_github("klutometis/roxygen")
library(roxygen2)
devtools::load_all()
producer <- Pulsar$new("localhost:8080", "persistent/public/default/my-topic")
producer$send("hello")
onMsg = function(payload) {
cat("Received string:", rawToChar(payload), "\n")
TRUE
}
consumer <- Pulsar$new("localhost:8080", "persistent/public/default/my-topic/my-sub",
onMessageFct = onMsg)
}
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.