@Bean
  fun consumeAlertEvent(
      alertEventProcessor: AlertEventProcessor,
      objectMapper: ObjectMapper,
  ): Consumer<Message<String>> {
      return Consumer<Message<String>> { message ->
          alertEventProcessor.processEvent(
              objectMapper.readValue(
                  message.payload,
                  AlertableEventMessage::class.java,
              ),
          )
      }
  }

@Channel(
        bindings = ChannelBindings(amqp = ChannelBinding.AMQP(queue = ChannelBinding.AMQPQueue(name = "alerts"))),
        publish = Publish(message = AsyncApiMessage(AlertableEventMessage::class)),
        description = "Queue used to receive alerts.",
    )
    class ConsumeAlertEvent {
        @Bean
        fun consumeAlertEvent(
            alertEventProcessor: AlertEventProcessor,
            objectMapper: ObjectMapper,
        ): Consumer<Message<String>> {
            return Consumer<Message<String>> { message ->
                alertEventProcessor.processEvent(
                    objectMapper.readValue(
                        message.payload,
                        AlertableEventMessage::class.java,
                    ),
                )
            }
        }
    }