class NATS::Client
- NATS::Client
- Reference
- Object
Defined in:
nats/client.crnats/client/connection.cr
nats/client/subscription.cr
nats/client/types.cr
Constructors
Instance Method Summary
- #close_connection : Void
- #connect(opts : Hash) : Void
- #connected? : Bool
- #connecting? : Bool
- #disconnected? : Bool
- #disconnecting? : Bool
- #process_error(message : String) : Void
- #process_info(info : String) : Void
- #process_msg(group : String, subscription_id : UInt64, reply : String, message : Bytes) : Void
- #process_ping : Void
- #process_pong : Void
- #publish(channel : String, message : String = EMPTY_MESSAGE, reply : String | Nil = nil) : Void
- #reconnecting? : Bool
- #server_info : Hash(String, Bool | String | UInt32)?
- #status : UInt8
- #subscribe(channel : String, id : UInt64 | Nil = nil, options : Subscription::OptionsHash = Subscription::OptionsHash.new, &callback : Subscription::CallbackProc) : UInt64
- #unsubscribe(id : UInt64) : Void
Constructor Detail
Instance Method Detail
def process_msg(group : String, subscription_id : UInt64, reply : String, message : Bytes) : Void
#
def publish(channel : String, message : String = EMPTY_MESSAGE, reply : String | Nil = nil) : Void
#
def subscribe(channel : String, id : UInt64 | Nil = nil, options : Subscription::OptionsHash = Subscription::OptionsHash.new, &callback : Subscription::CallbackProc) : UInt64
#