forked from kidgrow-microservices-platform

luliqiang
2020-08-14 bf1563dbb4a19380daa610eeb7d49fc4b47282e0
Merge branch 'dev' of http://192.168.2.240:7070/r/kidgrow-microservices-platform into dev
2 files modified
35 ■■■■■ changed files
kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/resources/application.yml 3 ●●●●● patch | view | raw | blame | history
kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java 32 ●●●●● patch | view | raw | blame | history
kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/resources/application.yml
@@ -31,6 +31,9 @@
    routingKeyName: ${kidgrow.rabbitmq.routingKeyName}
    virtual-host: ${kidgrow.rabbitmq.virtual-host}
    AIEvaluationResults: AIEvaluationResults_${spring.profiles.active}
    BoneAgeEvaluationData: BoneAgeEvaluationData_${spring.profiles.active}
    ChildRecordData: ChildRecordData_${spring.profiles.active}
    ReportData: ReportData_${spring.profiles.active}
    #开启重试机制
    listener:
      simple:
kidgrow-commons/kidgrow-rabbitmq-spring-boot-starter/src/main/java/com/kidgrow/rabbitmq/config/RabbitConfig.java
@@ -65,6 +65,21 @@
     */
    private String AIEvaluationResults;
    /**
     * 骨龄评价统计
     */
    private String BoneAgeEvaluationData;
    /**
     * 档案统计
     */
    private String ChildRecordData;
    /**
     * 报告统计
     */
    private String ReportData;
    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host,port);
@@ -147,6 +162,23 @@
    }
    @Bean
    public Queue BoneAgeEvaluationData() {
        return new Queue(BoneAgeEvaluationData);
    }
    @Bean
    public Queue ChildRecordData() {
        return new Queue(ChildRecordData);
    }
    @Bean
    public Queue ReportData() {
        return new Queue(ReportData);
    }
    @Bean
    Binding bindingExchangeAIEvaluation(TopicExchange exchange) {
        return BindingBuilder.bind(AIEvaluation()).to(exchange).with(routingKeyName);
    }