20
20
import java .util .Map ;
21
21
import java .util .function .Function ;
22
22
23
- import io .micrometer .core .instrument .Meter ;
24
23
import io .micrometer .core .instrument .MeterRegistry ;
25
24
import io .micrometer .core .instrument .Tag ;
26
25
import io .micrometer .core .instrument .Tags ;
@@ -64,7 +63,7 @@ public class MetricsRetryListener implements RetryListener {
64
63
65
64
private final Map <RetryContext , Timer .Sample > retryContextToSample = new IdentityHashMap <>();
66
65
67
- private final Meter . MeterProvider < Timer > retryMeterProvider ;
66
+ private final Timer . Builder retryMeterProvider ;
68
67
69
68
private Tags customTags = Tags .empty ();
70
69
@@ -77,9 +76,7 @@ public class MetricsRetryListener implements RetryListener {
77
76
public MetricsRetryListener (MeterRegistry meterRegistry ) {
78
77
Assert .notNull (meterRegistry , "'meterRegistry' must not be null" );
79
78
this .meterRegistry = meterRegistry ;
80
- this .retryMeterProvider = Timer .builder (TIMER_NAME )
81
- .description ("Metrics for Spring RetryTemplate" )
82
- .withRegistry (this .meterRegistry );
79
+ this .retryMeterProvider = Timer .builder (TIMER_NAME ).description ("Metrics for Spring RetryTemplate" );
83
80
}
84
81
85
82
/**
@@ -122,7 +119,7 @@ public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T
122
119
.and (this .customTagsProvider .apply (context ))
123
120
.and ("exception" , throwable != null ? throwable .getClass ().getSimpleName () : "none" );
124
121
125
- sample .stop (this .retryMeterProvider .withTags (retryTags ));
122
+ sample .stop (this .retryMeterProvider .tags (retryTags ). register ( this . meterRegistry ));
126
123
}
127
124
128
125
}
0 commit comments