archfish/pulsar_sdk


A pure ruby client for Apache Pulsar

License: Apache-2.0

Language: Ruby

Keywords: apache-pulsar, pulsar, ruby, ruby-gem


A pure ruby client for Apache Pulsar

Example

examples中的例子

Dev

#!/bin/sh

PB_OUT="./lib/protobuf/"
PB_OUT_F='pulsar_api.pb.rb'

mkdir -p ${PB_OUT}

protoc -I ${PULSAR_GIT}/pulsar-common/src/main/proto/ --ruby_out ${PB_OUT} PulsarApi.proto
mv ${PB_OUT}PulsarApi_pb.rb ${PB_OUT}${PB_OUT_F}

# fix pulsar.proto.ProtocolVersion error: invalid name `v0' for constant
if [ $(uname) = 'Darwin' ]
then
    suffix='.pbbak'
fi

for i in $(seq 0 15)
do
    sed -i ${suffix} "s;value :v$i, $i;value :V$i, $i;g" ${PB_OUT}${PB_OUT_F}
done

rm -f ${PB_OUT}${PB_OUT_F}.pbbak

protoc -I ${PULSAR_GIT}/pulsar-common/src/main/proto/ --ruby_out ${PB_OUT} PulsarMarkers.proto
mv ${PB_OUT}PulsarMarkers_pb.rb ${PB_OUT}pulsar_markers.pb.rb

Future

  • Connection establishment
  • Producer
  • Consumer
    • Flow control
    • Ack
    • Message Redelivery
  • Keep alive
    • handle ping command
    • send ping command
  • Service discovery
    • Topic lookup
    • Partitioned topics discovery
  • Log Optimization
  • Connection pool
  • Unit Test
  • Thread safe

Project Statistics

Sourcerank 3
Repository Size 25.4 KB
Stars 2
Forks 0
Watchers 1
Open issues 0
Dependencies 3
Contributors 1
Tags 0
Created
Last updated
Last pushed

Top Contributors See all

hailang.wei

Something wrong with this page? Make a suggestion

Last synced: 2019-11-20 06:32:24 UTC

Login to resync this repository