Skip to content

Commit f4e8383

Browse files
acogoluegnesacogoluegnes
committed
Remove some wildcard imports
1 parent 7123f45 commit f4e8383

30 files changed

+195
-36
lines changed

‎src/main/java/com/rabbitmq/client/amqp/impl/AmqpConnectionBuilder.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,13 @@
1717
// [email protected].
1818
package com.rabbitmq.client.amqp.impl;
1919

20-
import com.rabbitmq.client.amqp.*;
20+
import com.rabbitmq.client.amqp.AddressSelector;
21+
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
22+
import com.rabbitmq.client.amqp.Connection;
23+
import com.rabbitmq.client.amqp.ConnectionBuilder;
24+
import com.rabbitmq.client.amqp.CredentialsProvider;
25+
import com.rabbitmq.client.amqp.OAuth2Settings;
26+
import com.rabbitmq.client.amqp.Resource;
2127
import com.rabbitmq.client.amqp.oauth2.CredentialsManager;
2228
import java.time.Duration;
2329
import java.util.ArrayList;

‎src/main/java/com/rabbitmq/client/amqp/impl/AmqpEnvironmentBuilder.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,11 @@
1717
// [email protected].
1818
package com.rabbitmq.client.amqp.impl;
1919

20-
import com.rabbitmq.client.amqp.*;
20+
import com.rabbitmq.client.amqp.ConnectionBuilder;
21+
import com.rabbitmq.client.amqp.ConnectionSettings;
22+
import com.rabbitmq.client.amqp.Environment;
23+
import com.rabbitmq.client.amqp.EnvironmentBuilder;
24+
import com.rabbitmq.client.amqp.ObservationCollector;
2125
import com.rabbitmq.client.amqp.metrics.MetricsCollector;
2226
import com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector;
2327
import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;

‎src/main/java/com/rabbitmq/client/amqp/impl/AmqpRpcClient.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,12 @@
1717
// [email protected].
1818
package com.rabbitmq.client.amqp.impl;
1919

20-
import com.rabbitmq.client.amqp.*;
20+
import com.rabbitmq.client.amqp.AmqpException;
21+
import com.rabbitmq.client.amqp.Consumer;
22+
import com.rabbitmq.client.amqp.Management;
23+
import com.rabbitmq.client.amqp.Message;
24+
import com.rabbitmq.client.amqp.Publisher;
25+
import com.rabbitmq.client.amqp.RpcClient;
2126
import java.time.Duration;
2227
import java.util.Iterator;
2328
import java.util.Map;

‎src/main/java/com/rabbitmq/client/amqp/impl/AmqpRpcServer.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,11 @@
1717
// [email protected].
1818
package com.rabbitmq.client.amqp.impl;
1919

20-
import com.rabbitmq.client.amqp.*;
20+
import com.rabbitmq.client.amqp.AmqpException;
21+
import com.rabbitmq.client.amqp.Consumer;
22+
import com.rabbitmq.client.amqp.Message;
23+
import com.rabbitmq.client.amqp.Publisher;
24+
import com.rabbitmq.client.amqp.RpcServer;
2125
import java.time.Duration;
2226
import java.util.List;
2327
import java.util.concurrent.atomic.AtomicBoolean;

‎src/main/java/com/rabbitmq/client/amqp/impl/DefaultConnectionSettings.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,14 @@
2020
import static java.util.Arrays.stream;
2121
import static java.util.stream.Collectors.*;
2222

23-
import com.rabbitmq.client.amqp.*;
23+
import com.rabbitmq.client.amqp.Address;
24+
import com.rabbitmq.client.amqp.AddressSelector;
25+
import com.rabbitmq.client.amqp.AmqpException;
26+
import com.rabbitmq.client.amqp.ConnectionSettings;
27+
import com.rabbitmq.client.amqp.CredentialsProvider;
28+
import com.rabbitmq.client.amqp.DefaultUsernamePasswordCredentialsProvider;
29+
import com.rabbitmq.client.amqp.OAuth2Settings;
30+
import com.rabbitmq.client.amqp.UsernamePasswordCredentialsProvider;
2431
import com.rabbitmq.client.amqp.oauth2.TokenCredentialsManager;
2532
import java.io.IOException;
2633
import java.net.URI;

‎src/main/java/com/rabbitmq/client/amqp/impl/RpcSupport.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,11 @@
1717
// [email protected].
1818
package com.rabbitmq.client.amqp.impl;
1919

20-
import com.rabbitmq.client.amqp.*;
20+
import com.rabbitmq.client.amqp.Message;
21+
import com.rabbitmq.client.amqp.RpcClient;
22+
import com.rabbitmq.client.amqp.RpcClientBuilder;
23+
import com.rabbitmq.client.amqp.RpcServer;
24+
import com.rabbitmq.client.amqp.RpcServerBuilder;
2125
import java.time.Duration;
2226
import java.util.function.BiFunction;
2327
import java.util.function.Function;

‎src/main/java/com/rabbitmq/client/amqp/impl/Utils.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,11 @@
1717
// [email protected].
1818
package com.rabbitmq.client.amqp.impl;
1919

20-
import com.rabbitmq.client.amqp.*;
20+
import com.rabbitmq.client.amqp.Address;
21+
import com.rabbitmq.client.amqp.AmqpException;
22+
import com.rabbitmq.client.amqp.Consumer;
23+
import com.rabbitmq.client.amqp.Message;
24+
import com.rabbitmq.client.amqp.ObservationCollector;
2125
import java.lang.reflect.InvocationTargetException;
2226
import java.nio.charset.StandardCharsets;
2327
import java.security.MessageDigest;

‎src/main/qpid/org/apache/qpid/protonj2/client/ConnectionOptions.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -389,7 +389,7 @@ public ConnectionOptions idleTimeout(long idleTimeout) {
389389
* @return this {@link ConnectionOptions} instance.
390390
*/
391391
public ConnectionOptions idleTimeout(long timeout, TimeUnit units) {
392-
this.idleTimeout = UnsignedInteger.valueOf(units.toMillis(timeout)).longValue();;
392+
this.idleTimeout = UnsignedInteger.valueOf(units.toMillis(timeout)).longValue();
393393
return this;
394394
}
395395

‎src/main/qpid/org/apache/qpid/protonj2/client/impl/ClientStreamDelivery.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -382,7 +382,7 @@ private void tryReleaseReadBuffers() {
382382
// Split off all buffers that come before the portion the read offset
383383
// is located within and close them to ensure any pooled buffers are
384384
// returned to the pool and the rest are discarded.
385-
buffer.splitComponentsFloor(buffer.getReadOffset()).close();;
385+
buffer.splitComponentsFloor(buffer.getReadOffset()).close();
386386
} catch (Exception e) {
387387
}
388388
}

‎src/main/qpid/org/apache/qpid/protonj2/codec/decoders/primitives/AbstractMapTypeDecoder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ public <KeyType> void scanKeys(ProtonBuffer buffer, DecoderState state, Scanning
114114
buffer.advanceReadOffset(keySize);
115115
// No match on the key means we need to skip the value so we are positioned
116116
// on the next key or the buffer is consumed.
117-
decoder.readNextTypeDecoder(buffer, state).skipValue(buffer, state);;
117+
decoder.readNextTypeDecoder(buffer, state).skipValue(buffer, state);
118118
}
119119
}
120120

@@ -189,7 +189,7 @@ public <KeyType> void scanKeys(InputStream stream, StreamDecoderState state, Str
189189
ProtonStreamUtils.skipBytes(stream, keySize);
190190
// No match on the key means we need to skip the value so we are positioned
191191
// on the next key or the buffer is consumed.
192-
decoder.readNextTypeDecoder(stream, state).skipValue(stream, state);;
192+
decoder.readNextTypeDecoder(stream, state).skipValue(stream, state);
193193
}
194194
}
195195
} finally {

‎src/test/java/com/rabbitmq/client/amqp/docs/Api.java

Lines changed: 25 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,31 @@
2020
import com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder;
2121
import com.rabbitmq.client.amqp.metrics.MetricsCollector;
2222
import com.rabbitmq.client.amqp.metrics.MicrometerMetricsCollector;
23-
import com.rabbitmq.client.amqp.*;
23+
import com.rabbitmq.client.amqp.Address;
24+
import com.rabbitmq.client.amqp.AddressSelector;
25+
import com.rabbitmq.client.amqp.AmqpException;
26+
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
27+
import com.rabbitmq.client.amqp.Connection;
28+
import com.rabbitmq.client.amqp.ConnectionBuilder;
29+
import com.rabbitmq.client.amqp.ConnectionSettings;
30+
import com.rabbitmq.client.amqp.Consumer;
31+
import com.rabbitmq.client.amqp.ConsumerBuilder;
32+
import com.rabbitmq.client.amqp.CredentialsProvider;
33+
import com.rabbitmq.client.amqp.DefaultUsernamePasswordCredentialsProvider;
34+
import com.rabbitmq.client.amqp.Environment;
35+
import com.rabbitmq.client.amqp.EnvironmentBuilder;
36+
import com.rabbitmq.client.amqp.Management;
37+
import com.rabbitmq.client.amqp.Message;
38+
import com.rabbitmq.client.amqp.OAuth2Settings;
39+
import com.rabbitmq.client.amqp.ObservationCollector;
40+
import com.rabbitmq.client.amqp.Publisher;
41+
import com.rabbitmq.client.amqp.PublisherBuilder;
42+
import com.rabbitmq.client.amqp.Resource;
43+
import com.rabbitmq.client.amqp.RpcClient;
44+
import com.rabbitmq.client.amqp.RpcClientBuilder;
45+
import com.rabbitmq.client.amqp.RpcServer;
46+
import com.rabbitmq.client.amqp.RpcServerBuilder;
47+
import com.rabbitmq.client.amqp.UsernamePasswordCredentialsProvider;
2448
import com.rabbitmq.client.amqp.observation.micrometer.MicrometerObservationCollectorBuilder;
2549
import io.micrometer.observation.ObservationRegistry;
2650
import io.micrometer.prometheusmetrics.PrometheusConfig;

‎src/test/java/com/rabbitmq/client/amqp/docs/WebsiteDocumentation.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,14 @@
11
package com.rabbitmq.client.amqp.docs;
22

3-
import com.rabbitmq.client.amqp.*;
3+
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
4+
import com.rabbitmq.client.amqp.ByteCapacity;
5+
import com.rabbitmq.client.amqp.Connection;
6+
import com.rabbitmq.client.amqp.Consumer;
7+
import com.rabbitmq.client.amqp.ConsumerBuilder;
8+
import com.rabbitmq.client.amqp.Environment;
9+
import com.rabbitmq.client.amqp.Management;
10+
import com.rabbitmq.client.amqp.Message;
11+
import com.rabbitmq.client.amqp.Publisher;
412
import com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder;
513

614
import java.nio.charset.StandardCharsets;

‎src/test/java/com/rabbitmq/client/amqp/impl/AddressFormatTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,11 @@
2121
import static com.rabbitmq.client.amqp.Management.ExchangeType.FANOUT;
2222
import static org.assertj.core.api.Assertions.assertThatThrownBy;
2323

24-
import com.rabbitmq.client.amqp.*;
24+
import com.rabbitmq.client.amqp.Connection;
25+
import com.rabbitmq.client.amqp.Consumer;
26+
import com.rabbitmq.client.amqp.Management;
27+
import com.rabbitmq.client.amqp.Publisher;
28+
import com.rabbitmq.client.amqp.Resource;
2529
import java.util.concurrent.CountDownLatch;
2630
import org.junit.jupiter.api.*;
2731

‎src/test/java/com/rabbitmq/client/amqp/impl/AffinityTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,11 @@
1919

2020
import static org.assertj.core.api.Assertions.assertThat;
2121

22-
import com.rabbitmq.client.amqp.*;
22+
import com.rabbitmq.client.amqp.Connection;
23+
import com.rabbitmq.client.amqp.ConnectionBuilder;
24+
import com.rabbitmq.client.amqp.ConnectionSettings;
25+
import com.rabbitmq.client.amqp.Environment;
26+
import com.rabbitmq.client.amqp.Management;
2327
import java.util.function.Consumer;
2428
import org.junit.jupiter.api.BeforeEach;
2529
import org.junit.jupiter.api.Test;

‎src/test/java/com/rabbitmq/client/amqp/impl/AlarmsTest.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,10 @@
2020
import static com.rabbitmq.client.amqp.impl.TestUtils.*;
2121
import static java.util.stream.IntStream.range;
2222

23-
import com.rabbitmq.client.amqp.*;
23+
import com.rabbitmq.client.amqp.AmqpException;
24+
import com.rabbitmq.client.amqp.Connection;
25+
import com.rabbitmq.client.amqp.Consumer;
26+
import com.rabbitmq.client.amqp.Publisher;
2427
import java.time.Duration;
2528
import org.apache.qpid.protonj2.client.exceptions.ClientSendTimedOutException;
2629
import org.junit.jupiter.params.ParameterizedTest;

‎src/test/java/com/rabbitmq/client/amqp/impl/AmqpConnectionRecoveryTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,11 @@
2727
import static org.assertj.core.api.Assertions.assertThat;
2828
import static org.assertj.core.api.Assertions.assertThatThrownBy;
2929

30-
import com.rabbitmq.client.amqp.*;
30+
import com.rabbitmq.client.amqp.AmqpException;
31+
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
32+
import com.rabbitmq.client.amqp.Connection;
33+
import com.rabbitmq.client.amqp.Publisher;
34+
import com.rabbitmq.client.amqp.Resource;
3135
import com.rabbitmq.client.amqp.impl.TestUtils.DisabledIfRabbitMqCtlNotSet;
3236
import com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector;
3337
import java.util.*;

‎src/test/java/com/rabbitmq/client/amqp/impl/AmqpConsumerTest.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,14 @@
2525
import static com.rabbitmq.client.amqp.impl.TestUtils.*;
2626
import static org.assertj.core.api.Assertions.*;
2727

28-
import com.rabbitmq.client.amqp.*;
28+
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
29+
import com.rabbitmq.client.amqp.Connection;
30+
import com.rabbitmq.client.amqp.Consumer;
31+
import com.rabbitmq.client.amqp.ConsumerBuilder;
32+
import com.rabbitmq.client.amqp.Environment;
33+
import com.rabbitmq.client.amqp.Management;
34+
import com.rabbitmq.client.amqp.Publisher;
35+
import com.rabbitmq.client.amqp.Resource;
2936
import com.rabbitmq.client.amqp.impl.TestUtils.Sync;
3037
import java.time.Duration;
3138
import java.util.concurrent.atomic.AtomicInteger;

‎src/test/java/com/rabbitmq/client/amqp/impl/AmqpTest.java

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,13 @@
3333
import static java.util.stream.Stream.of;
3434
import static org.assertj.core.api.Assertions.*;
3535

36-
import com.rabbitmq.client.amqp.*;
36+
import com.rabbitmq.client.amqp.AmqpException;
37+
import com.rabbitmq.client.amqp.Connection;
38+
import com.rabbitmq.client.amqp.Environment;
39+
import com.rabbitmq.client.amqp.Management;
40+
import com.rabbitmq.client.amqp.Message;
41+
import com.rabbitmq.client.amqp.Publisher;
42+
import com.rabbitmq.client.amqp.Resource;
3743
import com.rabbitmq.client.amqp.impl.TestConditions.BrokerVersionAtLeast;
3844
import com.rabbitmq.client.amqp.impl.TestUtils.DisabledIfAddressV1Permitted;
3945
import com.rabbitmq.client.amqp.impl.TestUtils.Sync;
@@ -44,7 +50,6 @@
4450
import java.util.concurrent.atomic.AtomicInteger;
4551
import java.util.concurrent.atomic.AtomicReference;
4652
import java.util.function.BiConsumer;
47-
import java.util.function.Consumer;
4853
import java.util.stream.IntStream;
4954
import org.junit.jupiter.api.*;
5055
import org.junit.jupiter.params.ParameterizedTest;
@@ -62,7 +67,7 @@ private static String uuid() {
6267
}
6368

6469
private static Resource.StateListener closedListener(
65-
Sync sync, Consumer<Resource.Context> callback) {
70+
Sync sync, java.util.function.Consumer<Resource.Context> callback) {
6671
return context -> {
6772
if (context.currentState() == Resource.State.CLOSED) {
6873
callback.accept(context);
@@ -202,7 +207,7 @@ void binding(String prefix, boolean addBindingArguments, TestInfo info) {
202207
int messageCount = 1;
203208
Sync confirmSync = sync(messageCount * 2);
204209

205-
Consumer<Publisher> publish =
210+
java.util.function.Consumer<Publisher> publish =
206211
publisher ->
207212
publisher.publish(
208213
publisher.message("hello".getBytes(UTF_8)), acceptedCallback(confirmSync));
@@ -690,7 +695,7 @@ void redeclareExchangesWithDifferentArguments() {
690695
@Test
691696
void declareQueueWithUnsupportedArgument() {
692697
Management management = connection.management();
693-
List<Consumer<Management>> operations =
698+
List<java.util.function.Consumer<Management>> operations =
694699
List.of(
695700
m -> m.queue(name).type(CLASSIC).argument("x-max-age", "1000s").declare(),
696701
m -> m.queue(name).type(QUORUM).argument("x-max-age", "1000s").declare(),

‎src/test/java/com/rabbitmq/client/amqp/impl/ClusterTest.java

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,17 @@
3030
import static org.assertj.core.api.Assertions.assertThat;
3131
import static org.assertj.core.api.Assertions.assertThatThrownBy;
3232

33-
import com.rabbitmq.client.amqp.*;
33+
import com.rabbitmq.client.amqp.Address;
34+
import com.rabbitmq.client.amqp.AddressSelector;
35+
import com.rabbitmq.client.amqp.AmqpException;
3436
import com.rabbitmq.client.amqp.AmqpException.AmqpResourceClosedException;
37+
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
38+
import com.rabbitmq.client.amqp.Connection;
39+
import com.rabbitmq.client.amqp.ConsumerBuilder;
40+
import com.rabbitmq.client.amqp.Environment;
41+
import com.rabbitmq.client.amqp.Management;
42+
import com.rabbitmq.client.amqp.Publisher;
43+
import com.rabbitmq.client.amqp.Resource;
3544
import com.rabbitmq.client.amqp.impl.TestUtils.Sync;
3645
import java.util.List;
3746
import java.util.Set;
@@ -587,7 +596,7 @@ Management.QueueInfo queueInfo() {
587596
return this.management.queueInfo(q);
588597
}
589598

590-
AmqpConnection connection(Consumer<AmqpConnectionBuilder> operation) {
599+
AmqpConnection connection(java.util.function.Consumer<AmqpConnectionBuilder> operation) {
591600
AmqpConnectionBuilder builder = (AmqpConnectionBuilder) environment.connectionBuilder();
592601
builder
593602
.recovery()

‎src/test/java/com/rabbitmq/client/amqp/impl/ConsumerOutcomeTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,11 @@
2424
import static com.rabbitmq.client.amqp.impl.TestUtils.waitAtMost;
2525
import static org.assertj.core.api.Assertions.assertThat;
2626

27-
import com.rabbitmq.client.amqp.*;
27+
import com.rabbitmq.client.amqp.Connection;
28+
import com.rabbitmq.client.amqp.Consumer;
29+
import com.rabbitmq.client.amqp.Management;
30+
import com.rabbitmq.client.amqp.Message;
31+
import com.rabbitmq.client.amqp.Publisher;
2832
import java.util.*;
2933
import java.util.concurrent.ArrayBlockingQueue;
3034
import java.util.concurrent.atomic.AtomicInteger;

‎src/test/java/com/rabbitmq/client/amqp/impl/ManagementTest.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,11 @@
2525
import static org.assertj.core.api.Assertions.assertThat;
2626
import static org.assertj.core.api.Assertions.assertThatThrownBy;
2727

28-
import com.rabbitmq.client.amqp.*;
28+
import com.rabbitmq.client.amqp.AmqpException;
29+
import com.rabbitmq.client.amqp.Connection;
30+
import com.rabbitmq.client.amqp.Environment;
31+
import com.rabbitmq.client.amqp.Management;
32+
import com.rabbitmq.client.amqp.Publisher;
2933
import com.rabbitmq.client.amqp.impl.TestConditions.BrokerVersionAtLeast;
3034
import com.rabbitmq.client.amqp.impl.TestUtils.Sync;
3135
import java.time.Duration;

‎src/test/java/com/rabbitmq/client/amqp/impl/MetricsCollectorTest.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,12 @@
2323
import static org.mockito.ArgumentMatchers.any;
2424
import static org.mockito.Mockito.*;
2525

26-
import com.rabbitmq.client.amqp.*;
26+
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
27+
import com.rabbitmq.client.amqp.Connection;
28+
import com.rabbitmq.client.amqp.Consumer;
29+
import com.rabbitmq.client.amqp.Environment;
30+
import com.rabbitmq.client.amqp.Publisher;
31+
import com.rabbitmq.client.amqp.Resource;
2732
import com.rabbitmq.client.amqp.metrics.MetricsCollector;
2833
import java.time.Duration;
2934
import java.util.UUID;

‎src/test/java/com/rabbitmq/client/amqp/impl/Oauth2Test.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,12 @@
3333
import static org.assertj.core.api.Assertions.assertThat;
3434
import static org.assertj.core.api.Assertions.assertThatThrownBy;
3535

36-
import com.rabbitmq.client.amqp.*;
36+
import com.rabbitmq.client.amqp.AmqpException;
37+
import com.rabbitmq.client.amqp.Connection;
38+
import com.rabbitmq.client.amqp.ConnectionBuilder;
39+
import com.rabbitmq.client.amqp.Environment;
40+
import com.rabbitmq.client.amqp.OAuth2Settings;
41+
import com.rabbitmq.client.amqp.Publisher;
3742
import com.rabbitmq.client.amqp.impl.AmqpEnvironmentBuilder.EnvironmentConnectionSettings;
3843
import com.rabbitmq.client.amqp.impl.DefaultConnectionSettings.DefaultOAuth2Settings;
3944
import com.rabbitmq.client.amqp.impl.TestConditions.BrokerVersionAtLeast;

‎src/test/java/com/rabbitmq/client/amqp/impl/RecoveryClusterTest.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,12 @@
2828
import static org.assertj.core.api.Assertions.assertThat;
2929

3030
import com.google.common.util.concurrent.RateLimiter;
31-
import com.rabbitmq.client.amqp.*;
31+
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
32+
import com.rabbitmq.client.amqp.Environment;
33+
import com.rabbitmq.client.amqp.Management;
34+
import com.rabbitmq.client.amqp.Publisher;
35+
import com.rabbitmq.client.amqp.PublisherBuilder;
36+
import com.rabbitmq.client.amqp.Resource;
3237
import java.nio.charset.StandardCharsets;
3338
import java.time.Duration;
3439
import java.time.Instant;

0 commit comments

Comments
 (0)