1
1
package io .dropwizard .discovery ;
2
2
3
- import io .dropwizard .Configuration ;
4
- import io .dropwizard .ConfiguredBundle ;
3
+ import io .dropwizard .core .Configuration ;
4
+ import io .dropwizard .core .ConfiguredBundle ;
5
+ import io .dropwizard .core .setup .Bootstrap ;
6
+ import io .dropwizard .core .setup .Environment ;
5
7
import io .dropwizard .discovery .client .DiscoveryClient ;
6
8
import io .dropwizard .discovery .core .CuratorAdvertisementListener ;
7
9
import io .dropwizard .discovery .core .CuratorAdvertiser ;
8
10
import io .dropwizard .discovery .core .CuratorFactory ;
9
11
import io .dropwizard .discovery .core .JacksonInstanceSerializer ;
10
12
import io .dropwizard .discovery .manage .CuratorAdvertiserManager ;
11
13
import io .dropwizard .discovery .manage .ServiceDiscoveryManager ;
12
- import io .dropwizard .setup .Bootstrap ;
13
- import io .dropwizard .setup .Environment ;
14
- import javax .annotation .Nonnull ;
14
+ import org .checkerframework .checker .nullness .qual .NonNull ;
15
15
import org .apache .curator .framework .CuratorFramework ;
16
16
import org .apache .curator .x .discovery .DownInstancePolicy ;
17
17
import org .apache .curator .x .discovery .ProviderStrategy ;
@@ -31,13 +31,13 @@ public abstract class AbstractDiscoveryBundle<T extends Configuration, V>
31
31
public abstract Class <V > getPayloadClass ();
32
32
33
33
@ Override
34
- public void initialize (@ Nonnull final Bootstrap <?> bootstrap ) {
34
+ public void initialize (@ NonNull final Bootstrap <?> bootstrap ) {
35
35
mapper = bootstrap .getObjectMapper ();
36
36
}
37
37
38
38
@ Override
39
- public void run (@ Nonnull final T configuration ,
40
- @ Nonnull final Environment environment ) throws Exception {
39
+ public void run (@ NonNull final T configuration ,
40
+ @ NonNull final Environment environment ) throws Exception {
41
41
42
42
final DiscoveryFactory discoveryConfig = getDiscoveryFactory (configuration );
43
43
// Allow disabling all discovery functionality
@@ -77,21 +77,21 @@ public void run(@Nonnull final T configuration,
77
77
* Return a new {@link DiscoveryClient} instance that uses a
78
78
* {@link RoundRobinStrategy} when selecting a instance to return and the
79
79
* default {@link DownInstancePolicy}.
80
- *
80
+ *
81
81
* @param serviceName
82
82
* name of the service to monitor
83
83
* @return {@link DiscoveryClient}
84
84
*/
85
85
public DiscoveryClient <V > newDiscoveryClient (
86
- @ Nonnull final String serviceName ) {
86
+ @ NonNull final String serviceName ) {
87
87
return newDiscoveryClient (serviceName , new RoundRobinStrategy <V >());
88
88
}
89
89
90
90
/**
91
91
* Return a new {@link DiscoveryClient} instance uses a default
92
92
* {@link DownInstancePolicy} and the provided {@link ProviderStrategy} for
93
93
* selecting an instance.
94
- *
94
+ *
95
95
* @param serviceName
96
96
* name of the service to monitor
97
97
* @param providerStrategy
@@ -100,8 +100,8 @@ public DiscoveryClient<V> newDiscoveryClient(
100
100
* @return {@link DiscoveryClient}
101
101
*/
102
102
public DiscoveryClient <V > newDiscoveryClient (
103
- @ Nonnull final String serviceName ,
104
- @ Nonnull final ProviderStrategy <V > providerStrategy ) {
103
+ @ NonNull final String serviceName ,
104
+ @ NonNull final ProviderStrategy <V > providerStrategy ) {
105
105
return new DiscoveryClient <V >(serviceName , discovery ,
106
106
new DownInstancePolicy (), providerStrategy );
107
107
}
0 commit comments