Module: Pulsar

Defined in:

lib/pulsar.rb,
lib/pulsar/client.rb,
lib/pulsar/errors.rb,
lib/pulsar/message.rb,
lib/pulsar/version.rb,
lib/pulsar/consumer.rb,
lib/pulsar/internal.rb,
lib/pulsar/producer.rb,
lib/pulsar/message_id.rb,
lib/pulsar/internal/promise.rb,
lib/pulsar/proto/PulsarApi_pb.rb,
lib/pulsar/internal/connection.rb,
lib/pulsar/internal/frame_codec.rb,
lib/pulsar/internal/bounded_queue.rb,
lib/pulsar/internal/consumer_impl.rb,
lib/pulsar/internal/producer_impl.rb,
lib/pulsar/internal/tcp_transport.rb,
lib/pulsar/internal/lookup_service.rb,
lib/pulsar/internal/thread_runtime.rb,
lib/pulsar/internal/command_factory.rb,
lib/pulsar/internal/broker_error_mapper.rb

Overview

Root namespace for the pure Ruby Apache Pulsar client.

Defined Under Namespace

Modules: Internal, Proto Classes: AuthenticationError, AuthorizationError, BrokerError, Client, ClosedError, ConfigurationError, ConnectionError, Consumer, ConsumerBusyError, Error, Message, MessageId, Producer, ProducerBusyError, ProtocolError, TimeoutError, TopicNotFoundError, UnsupportedFeatureError

Constant Summary

VERSION =

'0.1.0.pre'