class

NATS::Client

Inherits Reference < Object

Constructors

Instance methods

close_connection
Source
connect(opts : Hash) : Void
Source
connected?
Source
connecting?
Source
disconnected?
Source
disconnecting?
Source
process_error(message : String) : Void
Source
process_info(info : String) : Void
Source
process_msg(group : String, subscription_id : UInt64, reply : String, message : Bytes) : Void
Source
process_ping
Source
process_pong
Source
publish(channel : String, message : String = EMPTY_MESSAGE, reply : String | Nil = nil) : Void
Source
reconnecting?
Source
server_info
Source
status
Source
subscribe(channel : String, id : UInt64 | Nil = nil, options : Subscription::OptionsHash = Subscription::OptionsHash.new, &callback : Subscription::CallbackProc) : UInt64
Source
unsubscribe(id : UInt64) : Void
Source

Nested types