|
16 | 16 |
|
17 | 17 | package org.springframework.amqp.rabbit.listener; |
18 | 18 |
|
19 | | -import java.util.Collections; |
20 | 19 | import java.util.Map; |
21 | | -import java.util.Map.Entry; |
22 | 20 | import java.util.concurrent.ConcurrentHashMap; |
23 | 21 | import java.util.concurrent.ConcurrentMap; |
24 | 22 |
|
25 | 23 | import org.springframework.beans.factory.NoUniqueBeanDefinitionException; |
26 | | -import org.springframework.beans.factory.config.BeanDefinition; |
27 | | -import org.springframework.beans.factory.support.BeanDefinitionRegistry; |
28 | 24 | import org.springframework.context.ApplicationContext; |
29 | | -import org.springframework.context.ConfigurableApplicationContext; |
30 | 25 | import org.springframework.lang.Nullable; |
31 | 26 |
|
32 | 27 | import io.micrometer.core.instrument.MeterRegistry; |
@@ -71,37 +66,6 @@ final class MicrometerHolder { |
71 | 66 | } |
72 | 67 | } |
73 | 68 |
|
74 | | - private Map<String, MeterRegistry> filterRegistries(Map<String, MeterRegistry> registries, |
75 | | - ApplicationContext context) { |
76 | | - |
77 | | - if (registries.size() == 1) { |
78 | | - return registries; |
79 | | - } |
80 | | - MeterRegistry primary = null; |
81 | | - if (context instanceof ConfigurableApplicationContext) { |
82 | | - BeanDefinitionRegistry bdr = (BeanDefinitionRegistry) ((ConfigurableApplicationContext) context) |
83 | | - .getBeanFactory(); |
84 | | - for (Entry<String, MeterRegistry> entry : registries.entrySet()) { |
85 | | - BeanDefinition beanDefinition = bdr.getBeanDefinition(entry.getKey()); |
86 | | - if (beanDefinition.isPrimary()) { |
87 | | - if (primary != null) { |
88 | | - primary = null; |
89 | | - break; |
90 | | - } |
91 | | - else { |
92 | | - primary = entry.getValue(); |
93 | | - } |
94 | | - } |
95 | | - } |
96 | | - } |
97 | | - if (primary != null) { |
98 | | - return Collections.singletonMap("primary", primary); |
99 | | - } |
100 | | - else { |
101 | | - return registries; |
102 | | - } |
103 | | - } |
104 | | - |
105 | 69 | Object start() { |
106 | 70 | return Timer.start(this.registry); |
107 | 71 | } |
|
0 commit comments