class STOMP::IOClient
- STOMP::IOClient
- STOMP::Client
- Reference
- Object
Defined in:
stomp/io_client.crConstructors
Instance Method Summary
- #close(receipt = "disconnect", headers : HTTP::Headers = HTTP::Headers.new, unceremoniously = false) : Nil
- #closed? : Bool
-
#on_close(&on_close : Bool -> )
Called when the connection is closed.
-
#on_connected(&on_connected : Frame -> )
Called when the client receives a message from a server.
- #on_error(&on_error : Frame -> )
-
#on_message(&on_message : Frame -> )
Called when the client receives a message from a server.
- #on_receipt(&on_receipt : Frame -> )
-
#run(*args, **named) : Nil
Continuously receives messages and calls previously set callbacks until the socket is closed.
- #send(message : Frame) : Nil
- #send_heart_beat : Nil
Instance methods inherited from class STOMP::Client
abort(transaction, headers : HTTP::Headers = HTTP::Headers.new)
abort,
ack(id, headers : HTTP::Headers = HTTP::Headers.new, transaction = nil)
ack,
begin(transaction, headers : HTTP::Headers = HTTP::Headers.new)
begin,
commit(transaction, headers : HTTP::Headers = HTTP::Headers.new)
commit,
connect
connect,
connected? : Bool
connected?,
disconnect(receipt, headers : HTTP::Headers = HTTP::Headers.new)
disconnect,
heart_beat
heart_beat,
heart_beat_client : Tuple(Int32, Int32) | Nil
heart_beat_client,
heart_beat_server : Tuple(Int32, Int32) | Nil
heart_beat_server,
host : String
host,
nack(id, headers : HTTP::Headers = HTTP::Headers.new, transaction = nil)
nack,
negotiate(stream)
negotiate,
next_frame(stream) : Frame
next_frame,
send(destination : String, headers : HTTP::Headers = HTTP::Headers.new, body : String = "", send_content_length : Bool = true)
send,
server : String | Nil
server,
session : String | Nil
session,
stomp(username : String | Nil = nil, password : String | Nil = nil, heart_beat : Tuple(Int32, Int32) | Nil = nil)
stomp,
subscribe(id, destination : String, headers : HTTP::Headers = HTTP::Headers.new, ack : AckMode = AckMode::Auto)
subscribe,
unsubscribe(id, headers : HTTP::Headers = HTTP::Headers.new)
unsubscribe,
version : Version
version
Constructor methods inherited from class STOMP::Client
new(host : String)
new
Constructor Detail
Instance Method Detail
def close(receipt = "disconnect", headers : HTTP::Headers = HTTP::Headers.new, unceremoniously = false) : Nil
#
def on_close(&on_close : Bool -> )
#
Called when the connection is closed. True when closed gracefully
Called when the client receives a message from a server.
Called when the client receives a message from a server.
def run(*args, **named) : Nil
#
Continuously receives messages and calls previously set callbacks until the socket is closed.