Message Bus Request Handler

class q2_sdk.core.http_handlers.message_bus_handler.Q2MessageBusRequestHandler(application, request, **kwargs)

Bases: Q2BaseRequestHandler

RequestHandler that handles messages posted from the Kafka message bus

initialize(route='')

property current_msg_type

Extracts the message type from the current message request

async handle(message)

This is the hook where you can put your handling logic

async handle_error()

This is the hook where you can put your error handling logic

async send_message(message)

Put a message onto the bus (into sdk queue)

Return type:

Response