Skip to content

Commit 889abe8

Browse files
acogoluegnesacogoluegnes
committed
Remove wildcard imports
1 parent c0bf1a9 commit 889abe8

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

61 files changed

+453
-138
lines changed

‎pom.xml‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -505,6 +505,7 @@
505505
<style>GOOGLE</style>
506506
</googleJavaFormat>
507507
<removeUnusedImports />
508+
<forbidWildcardImports />
508509
</java>
509510
<!-- <ratchetFrom>origin/main</ratchetFrom>-->
510511
<licenseHeader> <!-- specify either content or file, but not both -->

‎src/main/java/com/rabbitmq/client/amqp/BackOffDelayPolicy.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,8 @@
1717
// [email protected].
1818
package com.rabbitmq.client.amqp;
1919

20+
import static com.rabbitmq.client.amqp.BackOffDelayPolicy.fixedWithInitialDelay;
21+
2022
import java.time.Duration;
2123

2224
/**

‎src/main/java/com/rabbitmq/client/amqp/ConsumerBuilder.java‎

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import java.math.BigDecimal;
2121
import java.time.Instant;
2222
import java.util.UUID;
23-
import org.apache.qpid.protonj2.types.*;
2423

2524
/** API to configure and create a {@link Consumer}. */
2625
public interface ConsumerBuilder {

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

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,18 @@
5151
import com.rabbitmq.client.amqp.metrics.MetricsCollector;
5252
import com.rabbitmq.client.amqp.oauth2.CredentialsManager;
5353
import java.time.Duration;
54-
import java.util.*;
55-
import java.util.concurrent.*;
54+
import java.util.ArrayList;
55+
import java.util.LinkedHashMap;
56+
import java.util.List;
57+
import java.util.Map;
58+
import java.util.Objects;
59+
import java.util.concurrent.CompletableFuture;
60+
import java.util.concurrent.CopyOnWriteArrayList;
61+
import java.util.concurrent.Executor;
62+
import java.util.concurrent.ExecutorService;
63+
import java.util.concurrent.Executors;
64+
import java.util.concurrent.ScheduledExecutorService;
65+
import java.util.concurrent.TimeUnit;
5666
import java.util.concurrent.atomic.AtomicBoolean;
5767
import java.util.concurrent.atomic.AtomicLong;
5868
import java.util.concurrent.atomic.AtomicReference;

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

Lines changed: 24 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -20,24 +20,42 @@
2020
import static com.rabbitmq.client.amqp.Resource.State.CLOSED;
2121
import static com.rabbitmq.client.amqp.Resource.State.CLOSING;
2222
import static com.rabbitmq.client.amqp.Resource.State.OPEN;
23-
import static com.rabbitmq.client.amqp.impl.AmqpConsumerBuilder.*;
24-
import static com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition.*;
23+
import static com.rabbitmq.client.amqp.impl.AmqpConsumerBuilder.NO_OP_SUBSCRIPTION_LISTENER;
24+
import static com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition.ACCEPTED;
25+
import static com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition.DISCARDED;
26+
import static com.rabbitmq.client.amqp.metrics.MetricsCollector.ConsumeDisposition.REQUEUED;
2527
import static java.time.Duration.ofSeconds;
2628
import static java.util.Optional.ofNullable;
2729

2830
import com.rabbitmq.client.amqp.AmqpException;
2931
import com.rabbitmq.client.amqp.BackOffDelayPolicy;
3032
import com.rabbitmq.client.amqp.Consumer;
3133
import com.rabbitmq.client.amqp.ConsumerBuilder;
34+
import com.rabbitmq.client.amqp.ConsumerBuilder.StreamOptions;
35+
import com.rabbitmq.client.amqp.ConsumerBuilder.SubscriptionListener;
3236
import com.rabbitmq.client.amqp.metrics.MetricsCollector;
33-
import java.util.*;
34-
import java.util.concurrent.*;
37+
import java.util.ArrayList;
38+
import java.util.Collections;
39+
import java.util.LinkedHashMap;
40+
import java.util.List;
41+
import java.util.Map;
42+
import java.util.concurrent.CountDownLatch;
43+
import java.util.concurrent.RejectedExecutionException;
44+
import java.util.concurrent.TimeUnit;
3545
import java.util.concurrent.atomic.AtomicBoolean;
3646
import java.util.concurrent.atomic.AtomicLong;
3747
import java.util.concurrent.atomic.AtomicReference;
3848
import java.util.stream.IntStream;
39-
import org.apache.qpid.protonj2.client.*;
40-
import org.apache.qpid.protonj2.client.exceptions.*;
49+
import org.apache.qpid.protonj2.client.Delivery;
50+
import org.apache.qpid.protonj2.client.DeliveryMode;
51+
import org.apache.qpid.protonj2.client.DeliveryState;
52+
import org.apache.qpid.protonj2.client.DurabilityMode;
53+
import org.apache.qpid.protonj2.client.ExpiryPolicy;
54+
import org.apache.qpid.protonj2.client.ReceiverOptions;
55+
import org.apache.qpid.protonj2.client.Session;
56+
import org.apache.qpid.protonj2.client.exceptions.ClientException;
57+
import org.apache.qpid.protonj2.client.exceptions.ClientIOException;
58+
import org.apache.qpid.protonj2.client.exceptions.ClientIllegalStateException;
4159
import org.apache.qpid.protonj2.client.impl.ClientConversionSupport;
4260
import org.apache.qpid.protonj2.client.impl.ClientReceiver;
4361
import org.apache.qpid.protonj2.client.util.DeliveryQueue;

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

Lines changed: 19 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,8 +24,25 @@
2424
import com.rabbitmq.client.amqp.Resource;
2525
import java.math.BigDecimal;
2626
import java.time.Instant;
27-
import java.util.*;
28-
import org.apache.qpid.protonj2.types.*;
27+
import java.util.ArrayList;
28+
import java.util.Arrays;
29+
import java.util.Date;
30+
import java.util.LinkedHashMap;
31+
import java.util.List;
32+
import java.util.Locale;
33+
import java.util.Map;
34+
import java.util.UUID;
35+
import org.apache.qpid.protonj2.types.Binary;
36+
import org.apache.qpid.protonj2.types.Decimal128;
37+
import org.apache.qpid.protonj2.types.Decimal32;
38+
import org.apache.qpid.protonj2.types.Decimal64;
39+
import org.apache.qpid.protonj2.types.DescribedType;
40+
import org.apache.qpid.protonj2.types.Symbol;
41+
import org.apache.qpid.protonj2.types.UnknownDescribedType;
42+
import org.apache.qpid.protonj2.types.UnsignedByte;
43+
import org.apache.qpid.protonj2.types.UnsignedInteger;
44+
import org.apache.qpid.protonj2.types.UnsignedLong;
45+
import org.apache.qpid.protonj2.types.UnsignedShort;
2946

3047
class AmqpConsumerBuilder implements ConsumerBuilder {
3148

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

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,18 @@
2222
import com.rabbitmq.client.amqp.ObservationCollector;
2323
import com.rabbitmq.client.amqp.metrics.MetricsCollector;
2424
import com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector;
25-
import java.util.concurrent.*;
25+
import java.util.concurrent.Executor;
26+
import java.util.concurrent.ExecutorService;
27+
import java.util.concurrent.Executors;
28+
import java.util.concurrent.LinkedBlockingQueue;
29+
import java.util.concurrent.ScheduledExecutorService;
30+
import java.util.concurrent.ScheduledFuture;
31+
import java.util.concurrent.ThreadPoolExecutor;
32+
import java.util.concurrent.TimeUnit;
2633
import java.util.concurrent.atomic.AtomicBoolean;
2734
import java.util.concurrent.atomic.AtomicLong;
28-
import org.apache.qpid.protonj2.client.*;
35+
import org.apache.qpid.protonj2.client.Client;
36+
import org.apache.qpid.protonj2.client.ClientOptions;
2937
import org.slf4j.Logger;
3038
import org.slf4j.LoggerFactory;
3139

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

Lines changed: 23 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,15 +17,27 @@
1717
// [email protected].
1818
package com.rabbitmq.client.amqp.impl;
1919

20-
import static com.rabbitmq.client.amqp.impl.AmqpManagement.State.*;
20+
import static com.rabbitmq.client.amqp.impl.AmqpManagement.State.CLOSED;
21+
import static com.rabbitmq.client.amqp.impl.AmqpManagement.State.CREATED;
22+
import static com.rabbitmq.client.amqp.impl.AmqpManagement.State.OPEN;
23+
import static com.rabbitmq.client.amqp.impl.AmqpManagement.State.UNAVAILABLE;
2124
import static java.util.concurrent.TimeUnit.MILLISECONDS;
2225

2326
import com.rabbitmq.client.amqp.AmqpException;
2427
import com.rabbitmq.client.amqp.Management;
2528
import java.nio.charset.StandardCharsets;
2629
import java.time.Duration;
27-
import java.util.*;
28-
import java.util.concurrent.*;
30+
import java.util.Collections;
31+
import java.util.Iterator;
32+
import java.util.List;
33+
import java.util.Locale;
34+
import java.util.Map;
35+
import java.util.Optional;
36+
import java.util.UUID;
37+
import java.util.concurrent.ConcurrentHashMap;
38+
import java.util.concurrent.ConcurrentMap;
39+
import java.util.concurrent.CountDownLatch;
40+
import java.util.concurrent.Future;
2941
import java.util.concurrent.atomic.AtomicBoolean;
3042
import java.util.concurrent.atomic.AtomicLong;
3143
import java.util.concurrent.atomic.AtomicReference;
@@ -34,7 +46,14 @@
3446
import java.util.function.Supplier;
3547
import java.util.stream.Collectors;
3648
import java.util.stream.IntStream;
37-
import org.apache.qpid.protonj2.client.*;
49+
import org.apache.qpid.protonj2.client.Delivery;
50+
import org.apache.qpid.protonj2.client.DeliveryMode;
51+
import org.apache.qpid.protonj2.client.Message;
52+
import org.apache.qpid.protonj2.client.Receiver;
53+
import org.apache.qpid.protonj2.client.ReceiverOptions;
54+
import org.apache.qpid.protonj2.client.Sender;
55+
import org.apache.qpid.protonj2.client.SenderOptions;
56+
import org.apache.qpid.protonj2.client.Session;
3857
import org.apache.qpid.protonj2.client.exceptions.ClientConnectionRemotelyClosedException;
3958
import org.apache.qpid.protonj2.client.exceptions.ClientException;
4059
import org.apache.qpid.protonj2.client.exceptions.ClientLinkRemotelyClosedException;

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

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,15 @@
2727
import java.util.UUID;
2828
import java.util.function.BiConsumer;
2929
import org.apache.qpid.protonj2.client.exceptions.ClientException;
30-
import org.apache.qpid.protonj2.types.*;
30+
import org.apache.qpid.protonj2.types.Binary;
31+
import org.apache.qpid.protonj2.types.Decimal128;
32+
import org.apache.qpid.protonj2.types.Decimal32;
33+
import org.apache.qpid.protonj2.types.Decimal64;
34+
import org.apache.qpid.protonj2.types.Symbol;
35+
import org.apache.qpid.protonj2.types.UnsignedByte;
36+
import org.apache.qpid.protonj2.types.UnsignedInteger;
37+
import org.apache.qpid.protonj2.types.UnsignedLong;
38+
import org.apache.qpid.protonj2.types.UnsignedShort;
3139

3240
final class AmqpMessage implements Message {
3341

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

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,12 +25,18 @@
2525
import com.rabbitmq.client.amqp.Publisher;
2626
import com.rabbitmq.client.amqp.metrics.MetricsCollector;
2727
import java.time.Duration;
28-
import java.util.concurrent.*;
28+
import java.util.concurrent.ExecutorService;
2929
import java.util.concurrent.atomic.AtomicBoolean;
3030
import java.util.concurrent.atomic.AtomicLong;
3131
import java.util.function.Consumer;
3232
import java.util.function.Function;
33-
import org.apache.qpid.protonj2.client.*;
33+
import org.apache.qpid.protonj2.client.ConnectionOptions;
34+
import org.apache.qpid.protonj2.client.DeliveryMode;
35+
import org.apache.qpid.protonj2.client.DeliveryState;
36+
import org.apache.qpid.protonj2.client.Sender;
37+
import org.apache.qpid.protonj2.client.SenderOptions;
38+
import org.apache.qpid.protonj2.client.Session;
39+
import org.apache.qpid.protonj2.client.Tracker;
3440
import org.apache.qpid.protonj2.client.exceptions.ClientException;
3541
import org.apache.qpid.protonj2.client.exceptions.ClientIllegalStateException;
3642
import org.slf4j.Logger;

0 commit comments

Comments
 (0)