stomp

• stomp package
  • Subpackages
    • stomp.adapter package
      • Submodules
      • stomp.adapter.multicast module
      • Module contents
  • Submodules
  • stomp.colours module
  • stomp.connect module
    • BaseConnection
      • BaseConnection.disconnect()
      • BaseConnection.get_listener()
      • BaseConnection.get_ssl()
      • BaseConnection.is_connected()
      • BaseConnection.remove_listener()
      • BaseConnection.set_listener()
      • BaseConnection.set_receipt()
      • BaseConnection.set_ssl()
    • StompConnection10
      • StompConnection10.connect()
      • StompConnection10.disconnect()
    • StompConnection11
      • StompConnection11.connect()
      • StompConnection11.disconnect()
    • StompConnection12
      • StompConnection12.connect()
      • StompConnection12.disconnect()
      • StompConnection12.is_eol()
  • stomp.constants module
  • stomp.exception module
    • ConnectFailedException
    • ConnectionClosedException
    • InterruptedException
    • NotConnectedException
    • StompException
  • stomp.listener module
    • ConnectionListener
      • ConnectionListener.on_before_message()
      • ConnectionListener.on_connected()
      • ConnectionListener.on_connecting()
      • ConnectionListener.on_disconnected()
      • ConnectionListener.on_disconnecting()
      • ConnectionListener.on_error()
      • ConnectionListener.on_heartbeat()
      • ConnectionListener.on_heartbeat_timeout()
      • ConnectionListener.on_message()
      • ConnectionListener.on_receipt()
      • ConnectionListener.on_receiver_loop_completed()
      • ConnectionListener.on_send()
    • HeartbeatListener
      • HeartbeatListener.on_connected()
      • HeartbeatListener.on_disconnected()
      • HeartbeatListener.on_disconnecting()
      • HeartbeatListener.on_error()
      • HeartbeatListener.on_heartbeat()
      • HeartbeatListener.on_message()
      • HeartbeatListener.on_receipt()
      • HeartbeatListener.on_send()
    • PrintingListener
      • PrintingListener.on_before_message()
      • PrintingListener.on_connected()
      • PrintingListener.on_connecting()
      • PrintingListener.on_disconnected()
      • PrintingListener.on_error()
      • PrintingListener.on_heartbeat()
      • PrintingListener.on_heartbeat_timeout()
      • PrintingListener.on_message()
      • PrintingListener.on_receipt()
      • PrintingListener.on_send()
    • Publisher
      • Publisher.get_listener()
      • Publisher.remove_listener()
      • Publisher.set_listener()
    • StatsListener
      • StatsListener.on_connecting()
      • StatsListener.on_disconnected()
      • StatsListener.on_error()
      • StatsListener.on_heartbeat()
      • StatsListener.on_heartbeat_timeout()
      • StatsListener.on_message()
      • StatsListener.on_send()
    • TestListener
      • TestListener.get_latest_message()
      • TestListener.on_before_message()
      • TestListener.on_connected()
      • TestListener.on_connecting()
      • TestListener.on_disconnected()
      • TestListener.on_error()
      • TestListener.on_heartbeat()
      • TestListener.on_heartbeat_timeout()
      • TestListener.on_message()
      • TestListener.on_receipt()
      • TestListener.on_receiver_loop_completed()
      • TestListener.on_send()
      • TestListener.wait_for_heartbeat()
      • TestListener.wait_for_message()
    • WaitingListener
      • WaitingListener.on_disconnected()
      • WaitingListener.on_receipt()
      • WaitingListener.wait_on_disconnected()
      • WaitingListener.wait_on_receipt()
  • stomp.protocol module
    • Protocol10
      • Protocol10.abort()
      • Protocol10.ack()
      • Protocol10.begin()
      • Protocol10.commit()
      • Protocol10.connect()
      • Protocol10.disconnect()
      • Protocol10.send()
      • Protocol10.send_frame()
      • Protocol10.subscribe()
      • Protocol10.unsubscribe()
    • Protocol11
      • Protocol11.abort()
      • Protocol11.ack()
      • Protocol11.begin()
      • Protocol11.commit()
      • Protocol11.connect()
      • Protocol11.disconnect()
      • Protocol11.nack()
      • Protocol11.send()
      • Protocol11.send_frame()
      • Protocol11.subscribe()
      • Protocol11.unsubscribe()
    • Protocol12
      • Protocol12.ack()
      • Protocol12.connect()
      • Protocol12.nack()
  • stomp.transport module
    • BaseTransport
      • BaseTransport.attempt_connection()
      • BaseTransport.cleanup()
      • BaseTransport.disconnect_socket()
      • BaseTransport.get_listener()
      • BaseTransport.is_connected()
      • BaseTransport.notify()
      • BaseTransport.override_threading()
      • BaseTransport.process_frame()
      • BaseTransport.receive()
      • BaseTransport.remove_listener()
      • BaseTransport.send()
      • BaseTransport.set_connected()
      • BaseTransport.set_listener()
      • BaseTransport.set_receipt()
      • BaseTransport.start()
      • BaseTransport.stop()
      • BaseTransport.transmit()
      • BaseTransport.wait_for_connection()
    • Transport
      • Transport.attempt_connection()
      • Transport.cleanup()
      • Transport.disconnect_socket()
      • Transport.get_ssl()
      • Transport.is_connected()
      • Transport.receive()
      • Transport.send()
      • Transport.set_ssl()
  • stomp.utils module
    • Frame
    • calculate_heartbeats()
    • clean_headers()
    • clean_lines()
    • convert_frame()
    • decode()
    • default_create_thread()
    • encode()
    • get_errno()
    • get_uuid()
    • is_eol_default()
    • is_localhost()
    • join()
    • length()
    • merge_headers()
    • pack()
    • parse_frame()
    • parse_headers()
  • Module contents