@Bean
    open fun exchange(): TopicExchange {
        return TopicExchange("amq.topic")
    }

@RabbitListener(queues = [Amqp.BODY_WEIGHT_NEW])
    open fun record(entity: Collection<BodyWeight>) {
        log.trace("saving: {}", entity)
    }

    @Bean
    open fun weight(): Queue {
        return Queue(Amqp.BODY_WEIGHT_NEW)
    }

    @Bean
    open fun bindWeight(): Binding {
        return BindingBuilder.bind(weight()).to(exchange).with(Amqp.BODY_WEIGHT_NEW)
    }