class STOMP::Client

Direct Known Subclasses

Defined in:

stomp/client.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(host : String) #

[View source]

Instance Method Detail

def abort(transaction, headers : HTTP::Headers = HTTP::Headers.new) #

[View source]
def ack(id, headers : HTTP::Headers = HTTP::Headers.new, transaction = nil) #

[View source]
def begin(transaction, headers : HTTP::Headers = HTTP::Headers.new) #

[View source]
def commit(transaction, headers : HTTP::Headers = HTTP::Headers.new) #

[View source]
def connect #

[View source]
def connected? : Bool #

[View source]
def disconnect(receipt, headers : HTTP::Headers = HTTP::Headers.new) #

[View source]
def heart_beat #

Client => Server beat time, Server => Client beat time


[View source]
def heart_beat_client : Tuple(Int32, Int32) | Nil #

[View source]
def heart_beat_server : Tuple(Int32, Int32) | Nil #

[View source]
def host : String #

[View source]
def nack(id, headers : HTTP::Headers = HTTP::Headers.new, transaction = nil) #

[View source]
def negotiate(stream) #

[View source]
def next_frame(stream) : Frame #

[View source]
def send(destination : String, headers : HTTP::Headers = HTTP::Headers.new, body : String = "", send_content_length : Bool = true) #

[View source]
def server : String | Nil #

[View source]
def session : String | Nil #

[View source]
def stomp(username : String | Nil = nil, password : String | Nil = nil, heart_beat : Tuple(Int32, Int32) | Nil = nil) #

[View source]
def subscribe(id, destination : String, headers : HTTP::Headers = HTTP::Headers.new, ack : AckMode = AckMode::Auto) #

[View source]
def unsubscribe(id, headers : HTTP::Headers = HTTP::Headers.new) #

[View source]
def version : Version #

[View source]