Pulsar: Pulsar class

In bbonnin/rpulsar: Apache Pulsar Client

Description

Pulsar class

Usage

Pulsar

Arguments

connection	Pulsar host and port (format: "hostname:port")
topic	Full name of the topic including persistence, tenant, namespace and pub/sub name
onMessageFct	Function invoked when when receiving message

Format

An object of class R6ClassGenerator of length 24.

Value

a Pulsar connection object

Examples

## Not run: 
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)

## End(Not run)

bbonnin/rpulsar documentation built on May 4, 2019, 3:16 p.m.