demessaging.messaging package

DASF Methods to connect to the Message Broker.

Submodules

• demessaging.messaging.connection module
  • WebsocketConnection
    • WebsocketConnection.create_websocketapp()
    • WebsocketConnection.generate_response_topic()
    • WebsocketConnection.on_close()
    • WebsocketConnection.on_message()
    • WebsocketConnection.on_ping()
    • WebsocketConnection.on_pong()
    • WebsocketConnection.open_socket()
  • get_random_letters()
• demessaging.messaging.constants module
  • MessageType
    • MessageType.API_INFO
    • MessageType.INFO
    • MessageType.LOG
    • MessageType.PING
    • MessageType.PONG
    • MessageType.PROGRESS
    • MessageType.REQUEST
    • MessageType.RESPONSE
  • PropertyKeys
    • PropertyKeys.FRAGMENT
    • PropertyKeys.MESSAGE_TYPE
    • PropertyKeys.NUM_FRAGMENTS
    • PropertyKeys.REQUEST_CONTEXT
    • PropertyKeys.REQUEST_MESSAGEID
    • PropertyKeys.RESPONSE_TOPIC
    • PropertyKeys.SOURCE_TOPIC
    • PropertyKeys.STATUS
  • Status
    • Status.ERROR
    • Status.RUNNING
    • Status.SUCCESS
  • generate_enum_doc()
• demessaging.messaging.consumer module
  • MessageConsumer
    • MessageConsumer.RECONNECT_TIMEOUT_SLEEP
    • MessageConsumer.SOCKET_PING_INTERVAL
    • MessageConsumer.acknowledge()
    • MessageConsumer.close_websocket_app()
    • MessageConsumer.disconnect()
    • MessageConsumer.extract_context()
    • MessageConsumer.extract_message_type()
    • MessageConsumer.extract_response_topic()
    • MessageConsumer.handle_api_info()
    • MessageConsumer.handle_info()
    • MessageConsumer.handle_pong()
    • MessageConsumer.handle_request_via_queue()
    • MessageConsumer.is_valid_request()
    • MessageConsumer.is_valid_value()
    • MessageConsumer.on_message()
    • MessageConsumer.on_producer_message()
    • MessageConsumer.open_producer_app()
    • MessageConsumer.producer_locks
    • MessageConsumer.producer_threads
    • MessageConsumer.producer_timer
    • MessageConsumer.producers
    • MessageConsumer.request_semaphore
    • MessageConsumer.reset_close_timer()
    • MessageConsumer.send_error()
    • MessageConsumer.send_pong()
    • MessageConsumer.send_response()
    • MessageConsumer.setup_subscription()
    • MessageConsumer.wait_for_request()
    • MessageConsumer.wait_for_websocket_connection()
• demessaging.messaging.producer module
  • MessageProducer
    • MessageProducer.RECONNECT_TIMEOUT_SLEEP
    • MessageProducer.SOCKET_PING_INTERVAL
    • MessageProducer.connect()
    • MessageProducer.disconnect()
    • MessageProducer.in_app
    • MessageProducer.is_connected
    • MessageProducer.on_in_message()
    • MessageProducer.on_out_message()
    • MessageProducer.out_app
    • MessageProducer.response_topic
    • MessageProducer.send_request()
    • MessageProducer.setup_subscription()
    • MessageProducer.subscription_name
    • MessageProducer.wait_for_connection()