|
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