webstompy.transporter

All transporter objects (WebSocket et al.) to transport the STOMP messages.

webstompy.transporter.transporter

All transporter objects (WebSocket et al.) to transport the STOMP messages.

class webstompy.transporter.transporter.BaseTransporter

Bases: abc.ABC

Abstract transporter class to adapt to various connection types

alive()

Check transporter connection status

receive()

Receive a message from the transporter connection (blocking)

send(frame)

Send a message to the transporter connection

class webstompy.transporter.transporter.WebSocketPinger(socket)

Bases: threading.Thread

Helper class for WebSocketTransporter to to regular WebSocket pings as connection keepalive.

run()

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.

class webstompy.transporter.transporter.WebSocketTransporter(socket)

Bases: webstompy.transporter.transporter.BaseTransporter

webstompty transporter class through WebSockets

alive

Check transporter connection status

receive()

Receive a message from the transporter connection (blocking)

send(frame)

Send a message to the transporter connection