| | |
| | | */ |
| | | private String routingKeyName; |
| | | |
| | | /** |
| | | * AI返回结果队列 |
| | | */ |
| | | private String AIEvaluationResults; |
| | | |
| | | /** |
| | | * 骨龄评价统计 |
| | | */ |
| | | private String BoneAgeEvaluationData; |
| | | |
| | | /** |
| | | * 档案统计 |
| | | */ |
| | | private String ChildRecordData; |
| | | |
| | | /** |
| | | * 报告统计 |
| | | */ |
| | | private String ReportData; |
| | | |
| | | @Bean |
| | | public ConnectionFactory connectionFactory() { |
| | | CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host,port); |
| | |
| | | } |
| | | |
| | | @Bean |
| | | public Queue AIEvaluationResults() { |
| | | return new Queue(AIEvaluationResults); |
| | | } |
| | | |
| | | @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); |
| | | } |