dasf.messaging package

DASF Methods to connect to the Message Broker.

Submodules

• dasf.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()
• dasf.messaging.constants module
  • MessageType
    • MessageType.API_INFO
    • MessageType.INFO
    • MessageType.LOG
    • MessageType.PING
    • MessageType.PONG
    • MessageType.PROGRESS
    • MessageType.REQUEST
    • MessageType.RESPONSE
  • ModuleRequest
    • ModuleRequest.context
    • ModuleRequest.model_config
    • ModuleRequest.payload
    • ModuleRequest.properties
  • ModuleResponse
    • ModuleResponse.messageId
    • ModuleResponse.model_config
    • ModuleResponse.payload
    • ModuleResponse.properties
    • ModuleResponse.publishTime
  • PropertyKeys
    • PropertyKeys.FRAGMENT
    • PropertyKeys.MESSAGE_TYPE
    • PropertyKeys.NUM_FRAGMENTS
    • PropertyKeys.REQUEST_CONTEXT
    • PropertyKeys.REQUEST_MESSAGEID
    • PropertyKeys.RESPONSE_TOPIC
    • PropertyKeys.SOURCE_TOPIC
    • PropertyKeys.STATUS
  • RequestProperties
    • RequestProperties.messageType
    • RequestProperties.model_config
    • RequestProperties.requestContext
    • RequestProperties.response_topic
  • RequestPropertiesBase
    • RequestPropertiesBase.messageType
    • RequestPropertiesBase.model_config
    • RequestPropertiesBase.requestContext
  • ResponseProperties
    • ResponseProperties.api_info
    • ResponseProperties.fragment
    • ResponseProperties.info
    • ResponseProperties.messageType
    • ResponseProperties.model_config
    • ResponseProperties.num_fragments
    • ResponseProperties.requestContext
    • ResponseProperties.requestMessageId
    • ResponseProperties.response_topic
    • ResponseProperties.source_topic
    • ResponseProperties.status
  • Status
    • Status.ERROR
    • Status.RUNNING
    • Status.SUCCESS
  • generate_enum_doc()
• dasf.messaging.consumer module
  • MessageConsumer
    • MessageConsumer.RECONNECT_TIMEOUT_SLEEP
    • MessageConsumer.SOCKET_PING_INTERVAL
    • MessageConsumer.acknowledge()
    • MessageConsumer.close_websocket_app()
    • MessageConsumer.disconnect()
    • MessageConsumer.handle_api_info()
    • MessageConsumer.handle_info()
    • MessageConsumer.handle_pong()
    • MessageConsumer.handle_request_via_queue()
    • 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()
• dasf.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()