Module: NatsStreamingListener

Defined in:

lib/nats_streaming_listener/nats_message.pb.rb,
lib/nats_streaming_listener.rb,
lib/nats_streaming_listener/version.rb,
lib/nats_streaming_listener/streaming_client.rb,
lib/nats_streaming_listener/streaming_subscriber.rb

Overview

Message class offered to be used with protobuf serialization

Defined Under Namespace

Classes: StreamingClient, StreamingSubscriber

Constant Summary

VERSION =

"0.1.1"

MESSAGE_CLASS =

'NatsStreamingListener.NatsMessage'

NatsMessage =

Google::Protobuf::DescriptorPool.generated_pool
.lookup(MESSAGE_CLASS)
.msgclass