A STOMP 1.0 and 1.1 compatible client.

stomp.py is used as a reference for the implementation.

author

- Hongxin Liang

See also

- http://stomp.github.io/index.html

- https://github.com/jasonrbriggs/stomp.py

license

- Apache License Version 2.0

 setup(+Connection) is semidet

Set up the actual socket connection and start receiving thread.

 teardown(+Connection) is semidet

Tear down the socket connection, stop receiving thread and heartbeat thread (if applicable).

 connect(+Connectio, +Host, +Headers) is semidet

Send a CONNECT frame. Protocol version and heartbeat negotiation will be handled. STOMP frame is not used for backward compatibility. See here.

 send(+Connection, +Destination, +Headers) is semidet

 send(+Connection, +Destination, +Headers, +Body) is semidet

Send a SEND frame. If content-type is not provided, text/plain will be used. content-length will be filled in automatically. See here.

 send_json(+Connection, +Destination, +Headers, +JSON) is semidet

Send a SEND frame. JSON can be either a JSON term or a dict. content-type is filled in automatically as application/json and content-length will be filled in automatically as well. See here.

 subscribe(+Connection, +Destination, +Id, +Headers) is semidet

Send a SUBSCRIBE frame. See here.

 unsubscribe(+Connection, +Id) is semidet

Send an UNSUBSCRIBE frame. See here.

 ack(+Connection, +MessageId, +Headers) is semidet

Send an ACK frame. See here.

 nack(+Connection, +MessageId, +Headers) is semidet

Send a NACK frame. See here.

 begin(+Connection, +Transaction) is semidet

Send a BEGIN frame. See here.

 commit(+Connection, +Transaction) is semidet

Send a COMMIT frame. See here.

 abort(+Connection, +Transaction) is semidet

Send a ABORT frame. See here.

 disconnect(+Connection, +Headers) is semidet

Send a DISCONNECT frame. See here.

Undocumented predicates

The following predicates are exported, but not or incorrectly documented.

 connection(Arg1, Arg2)

 connection(Arg1, Arg2, Arg3)

 send(Arg1, Arg2, Arg3, Arg4)