code: async def post_publish(request):
      
      args = await request.json()
      try:
          await get_publisher(request.app).publish(
              args['exchange'],
              args['routing'],
              args['message']
          )
          return web.Response()
  
      except Exception as ex:
          warnings.warn(f'Unable to publish {args}: {ex}')
          return web.Response(body='Event bus connection refused', status=500)
docs: ---
      tags:
      - Events
      summary: Publish event.
      description: Publish a new event message to the event bus.
      operationId: events.publish
      produces:
      - text/plain
      parameters:
      -
          in: body
          name: body
          description: Event message
          required: true
          schema:
              type: object
              properties:
                  exchange:
                      type: string
                  routing:
                      type: string
                  message:
                      type: object