Remove some wildcard imports

Author: acogoluegnes

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

@@ -17,7 +17,13 @@
 // [email protected].
 package com.rabbitmq.client.amqp.impl;
 
-import com.rabbitmq.client.amqp.*;
+import com.rabbitmq.client.amqp.AddressSelector;
+import com.rabbitmq.client.amqp.BackOffDelayPolicy;
+import com.rabbitmq.client.amqp.Connection;
+import com.rabbitmq.client.amqp.ConnectionBuilder;
+import com.rabbitmq.client.amqp.CredentialsProvider;
+import com.rabbitmq.client.amqp.OAuth2Settings;
+import com.rabbitmq.client.amqp.Resource;
 import com.rabbitmq.client.amqp.oauth2.CredentialsManager;
 import java.time.Duration;
 import java.util.ArrayList;

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

@@ -17,7 +17,11 @@
 // [email protected].
 package com.rabbitmq.client.amqp.impl;
 
-import com.rabbitmq.client.amqp.*;
+import com.rabbitmq.client.amqp.ConnectionBuilder;
+import com.rabbitmq.client.amqp.ConnectionSettings;
+import com.rabbitmq.client.amqp.Environment;
+import com.rabbitmq.client.amqp.EnvironmentBuilder;
+import com.rabbitmq.client.amqp.ObservationCollector;
 import com.rabbitmq.client.amqp.metrics.MetricsCollector;
 import com.rabbitmq.client.amqp.metrics.NoOpMetricsCollector;
 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;

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

@@ -17,7 +17,12 @@
 // [email protected].
 package com.rabbitmq.client.amqp.impl;
 
-import com.rabbitmq.client.amqp.*;
+import com.rabbitmq.client.amqp.AmqpException;
+import com.rabbitmq.client.amqp.Consumer;
+import com.rabbitmq.client.amqp.Management;
+import com.rabbitmq.client.amqp.Message;
+import com.rabbitmq.client.amqp.Publisher;
+import com.rabbitmq.client.amqp.RpcClient;
 import java.time.Duration;
 import java.util.Iterator;
 import java.util.Map;

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

@@ -17,7 +17,11 @@
 // [email protected].
 package com.rabbitmq.client.amqp.impl;
 
-import com.rabbitmq.client.amqp.*;
+import com.rabbitmq.client.amqp.AmqpException;
+import com.rabbitmq.client.amqp.Consumer;
+import com.rabbitmq.client.amqp.Message;
+import com.rabbitmq.client.amqp.Publisher;
+import com.rabbitmq.client.amqp.RpcServer;
 import java.time.Duration;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicBoolean;

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

@@ -20,7 +20,14 @@
 import static java.util.Arrays.stream;
 import static java.util.stream.Collectors.*;
 
-import com.rabbitmq.client.amqp.*;
+import com.rabbitmq.client.amqp.Address;
+import com.rabbitmq.client.amqp.AddressSelector;
+import com.rabbitmq.client.amqp.AmqpException;
+import com.rabbitmq.client.amqp.ConnectionSettings;
+import com.rabbitmq.client.amqp.CredentialsProvider;
+import com.rabbitmq.client.amqp.DefaultUsernamePasswordCredentialsProvider;
+import com.rabbitmq.client.amqp.OAuth2Settings;
+import com.rabbitmq.client.amqp.UsernamePasswordCredentialsProvider;
 import com.rabbitmq.client.amqp.oauth2.TokenCredentialsManager;
 import java.io.IOException;
 import java.net.URI;

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

@@ -17,7 +17,11 @@
 // [email protected].
 package com.rabbitmq.client.amqp.impl;
 
-import com.rabbitmq.client.amqp.*;
+import com.rabbitmq.client.amqp.Message;
+import com.rabbitmq.client.amqp.RpcClient;
+import com.rabbitmq.client.amqp.RpcClientBuilder;
+import com.rabbitmq.client.amqp.RpcServer;
+import com.rabbitmq.client.amqp.RpcServerBuilder;
 import java.time.Duration;
 import java.util.function.BiFunction;
 import java.util.function.Function;

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

@@ -17,7 +17,11 @@
 // [email protected].
 package com.rabbitmq.client.amqp.impl;
 
-import com.rabbitmq.client.amqp.*;
+import com.rabbitmq.client.amqp.Address;
+import com.rabbitmq.client.amqp.AmqpException;
+import com.rabbitmq.client.amqp.Consumer;
+import com.rabbitmq.client.amqp.Message;
+import com.rabbitmq.client.amqp.ObservationCollector;
 import java.lang.reflect.InvocationTargetException;
 import java.nio.charset.StandardCharsets;
 import java.security.MessageDigest;

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

@@ -389,7 +389,7 @@ public ConnectionOptions idleTimeout(long idleTimeout) {
      * @return this {@link ConnectionOptions} instance.
      */
     public ConnectionOptions idleTimeout(long timeout, TimeUnit units) {
-        this.idleTimeout = UnsignedInteger.valueOf(units.toMillis(timeout)).longValue();;
+        this.idleTimeout = UnsignedInteger.valueOf(units.toMillis(timeout)).longValue();
         return this;
     }
 

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

@@ -382,7 +382,7 @@ private void tryReleaseReadBuffers() {
                     // Split off all buffers that come before the portion the read offset
                     // is located within and close them to ensure any pooled buffers are
                     // returned to the pool and the rest are discarded.
-                    buffer.splitComponentsFloor(buffer.getReadOffset()).close();;
+                    buffer.splitComponentsFloor(buffer.getReadOffset()).close();
                 } catch (Exception e) {
                 }
             }

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

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