diff --git a/samples/BasicConnect/src/main/java/basicconnect/BasicConnect.java b/samples/BasicConnect/src/main/java/basicconnect/BasicConnect.java
index 5297ce7db..4fdfe301c 100644
--- a/samples/BasicConnect/src/main/java/basicconnect/BasicConnect.java
+++ b/samples/BasicConnect/src/main/java/basicconnect/BasicConnect.java
@@ -84,6 +84,9 @@ public void onConnectionResumed(boolean sessionPresent) {
             // (see sampleConnectAndDisconnect for implementation)
             cmdUtils.sampleConnectAndDisconnect(connection);
 
+            // Close the connection now that we are completely done with it.
+            connection.close();
+
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             onApplicationFailure(ex);
         }
diff --git a/samples/BasicPubSub/src/main/java/pubsub/PubSub.java b/samples/BasicPubSub/src/main/java/pubsub/PubSub.java
index 189631155..cbc7ce367 100644
--- a/samples/BasicPubSub/src/main/java/pubsub/PubSub.java
+++ b/samples/BasicPubSub/src/main/java/pubsub/PubSub.java
@@ -127,6 +127,10 @@ public void onConnectionResumed(boolean sessionPresent) {
 
             CompletableFuture<Void> disconnected = connection.disconnect();
             disconnected.get();
+
+            // Close the connection now that we are completely done with it.
+            connection.close();
+
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             onApplicationFailure(ex);
         }
diff --git a/samples/CustomAuthorizerConnect/src/main/java/customauthorizerconnect/CustomAuthorizerConnect.java b/samples/CustomAuthorizerConnect/src/main/java/customauthorizerconnect/CustomAuthorizerConnect.java
index 3e912dd76..b4921c611 100644
--- a/samples/CustomAuthorizerConnect/src/main/java/customauthorizerconnect/CustomAuthorizerConnect.java
+++ b/samples/CustomAuthorizerConnect/src/main/java/customauthorizerconnect/CustomAuthorizerConnect.java
@@ -78,6 +78,9 @@ public void onConnectionResumed(boolean sessionPresent) {
             // (see sampleConnectAndDisconnect for implementation)
             cmdUtils.sampleConnectAndDisconnect(connection);
 
+            // Close the connection now that we are completely done with it.
+            connection.close();
+
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             onApplicationFailure(ex);
         }
diff --git a/samples/Identity/src/main/java/identity/FleetProvisioningSample.java b/samples/Identity/src/main/java/identity/FleetProvisioningSample.java
index ab690139a..ca30bbead 100644
--- a/samples/Identity/src/main/java/identity/FleetProvisioningSample.java
+++ b/samples/Identity/src/main/java/identity/FleetProvisioningSample.java
@@ -170,6 +170,10 @@ public void onConnectionResumed(boolean sessionPresent) {
 
             CompletableFuture<Void> disconnected = connection.disconnect();
             disconnected.get();
+
+            // Close the connection now that we are completely done with it.
+            connection.close();
+
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             System.out.println("Exception encountered: " + ex.toString());
         }
diff --git a/samples/Jobs/src/main/java/jobs/JobsSample.java b/samples/Jobs/src/main/java/jobs/JobsSample.java
index 0d65181d9..d0f5b8cef 100644
--- a/samples/Jobs/src/main/java/jobs/JobsSample.java
+++ b/samples/Jobs/src/main/java/jobs/JobsSample.java
@@ -278,6 +278,10 @@ public void onConnectionResumed(boolean sessionPresent) {
 
             CompletableFuture<Void> disconnected = connection.disconnect();
             disconnected.get();
+
+            // Close the connection now that we are completely done with it.
+            connection.close();
+
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             System.out.println("Exception encountered: " + ex.toString());
         }
diff --git a/samples/Pkcs11Connect/src/main/java/pkcs11connect/Pkcs11Connect.java b/samples/Pkcs11Connect/src/main/java/pkcs11connect/Pkcs11Connect.java
index 6781451a8..c99cf9a06 100644
--- a/samples/Pkcs11Connect/src/main/java/pkcs11connect/Pkcs11Connect.java
+++ b/samples/Pkcs11Connect/src/main/java/pkcs11connect/Pkcs11Connect.java
@@ -142,6 +142,9 @@ public void onConnectionResumed(boolean sessionPresent) {
                     CompletableFuture<Void> disconnected = connection.disconnect();
                     disconnected.get();
                     System.out.println("Disconnected.");
+
+                    // Close the connection now that we are completely done with it.
+                    connection.close();
                 }
             } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
                 onApplicationFailure(ex);
diff --git a/samples/RawConnect/src/main/java/rawconnect/RawConnect.java b/samples/RawConnect/src/main/java/rawconnect/RawConnect.java
index 98783a815..2a66f10aa 100644
--- a/samples/RawConnect/src/main/java/rawconnect/RawConnect.java
+++ b/samples/RawConnect/src/main/java/rawconnect/RawConnect.java
@@ -128,6 +128,9 @@ public void onConnectionResumed(boolean sessionPresent) {
                     // Connect and disconnect using the connection we created
                     // (see sampleConnectAndDisconnect for implementation)
                     cmdUtils.sampleConnectAndDisconnect(connection);
+
+                    // Close the connection now that we are completely done with it.
+                    connection.close();
                 }
             }
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
diff --git a/samples/Shadow/src/main/java/shadow/ShadowSample.java b/samples/Shadow/src/main/java/shadow/ShadowSample.java
index 981183e44..ab31beefe 100644
--- a/samples/Shadow/src/main/java/shadow/ShadowSample.java
+++ b/samples/Shadow/src/main/java/shadow/ShadowSample.java
@@ -291,6 +291,10 @@ public void onConnectionResumed(boolean sessionPresent) {
 
             CompletableFuture<Void> disconnected = connection.disconnect();
             disconnected.get();
+
+            // Close the connection now that we are completely done with it.
+            connection.close();
+
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             System.out.println("Exception encountered: " + ex.toString());
         }
diff --git a/samples/Utils/CommandLineUtils/utils/commandlineutils/CommandLineUtils.java b/samples/Utils/CommandLineUtils/utils/commandlineutils/CommandLineUtils.java
index 09856073c..a4eebbeb8 100644
--- a/samples/Utils/CommandLineUtils/utils/commandlineutils/CommandLineUtils.java
+++ b/samples/Utils/CommandLineUtils/utils/commandlineutils/CommandLineUtils.java
@@ -185,7 +185,10 @@ public MqttClientConnection buildPKCS11MQTTConnection(MqttClientConnectionEvents
             buildConnectionSetupCAFileDefaults(builder);
             buildConnectionSetupConnectionDefaults(builder, callbacks);
 
-            return builder.build();
+            MqttClientConnection conn = builder.build();
+            builder.close();
+            return conn;
+
         } catch (CrtRuntimeException ex) {
             return null;
         }
@@ -226,7 +229,9 @@ public MqttClientConnection buildWebsocketX509MQTTConnection(MqttClientConnectio
             X509CredentialsProvider provider = x509builder.build();
             builder.withWebsocketCredentialsProvider(provider);
 
-            return builder.build();
+            MqttClientConnection conn = builder.build();
+            builder.close();
+            return conn;
 
         } catch (CrtRuntimeException ex) {
             return null;
@@ -245,7 +250,9 @@ public MqttClientConnection buildWebsocketMQTTConnection(MqttClientConnectionEve
             builder.withWebsockets(true);
             builder.withWebsocketSigningRegion(getCommandRequired(m_cmd_signing_region, ""));
 
-            return builder.build();
+            MqttClientConnection conn = builder.build();
+            builder.close();
+            return conn;
 
         } catch (CrtRuntimeException ex) {
             return null;
@@ -261,7 +268,10 @@ public MqttClientConnection buildDirectMQTTConnection(MqttClientConnectionEvents
             buildConnectionSetupCAFileDefaults(builder);
             buildConnectionSetupConnectionDefaults(builder, callbacks);
             buildConnectionSetupProxyDefaults(builder);
-            return builder.build();
+
+            MqttClientConnection conn = builder.build();
+            builder.close();
+            return conn;
         }
         catch (CrtRuntimeException ex) {
             return null;
@@ -279,7 +289,10 @@ public MqttClientConnection buildDirectMQTTConnectionWithCustomAuthorizer(MqttCl
                 getCommandOrDefault(m_cmd_custom_auth_authorizer_name, null),
                 getCommandOrDefault(m_cmd_custom_auth_authorizer_signature, null),
                 getCommandOrDefault(m_cmd_custom_auth_password, null));
-            return builder.build();
+
+            MqttClientConnection conn = builder.build();
+            builder.close();
+            return conn;
         }
         catch (CrtRuntimeException | UnsupportedEncodingException ex) {
             return null;
diff --git a/samples/WebsocketConnect/src/main/java/websocketconnect/WebsocketConnect.java b/samples/WebsocketConnect/src/main/java/websocketconnect/WebsocketConnect.java
index f321d991e..d8e351f9a 100644
--- a/samples/WebsocketConnect/src/main/java/websocketconnect/WebsocketConnect.java
+++ b/samples/WebsocketConnect/src/main/java/websocketconnect/WebsocketConnect.java
@@ -77,6 +77,9 @@ public void onConnectionResumed(boolean sessionPresent) {
             // (see sampleConnectAndDisconnect for implementation)
             cmdUtils.sampleConnectAndDisconnect(connection);
 
+            // Close the connection now that we are completely done with it.
+            connection.close();
+
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             onApplicationFailure(ex);
         }
diff --git a/samples/WindowsCertConnect/src/main/java/windowscertconnect/WindowsCertConnect.java b/samples/WindowsCertConnect/src/main/java/windowscertconnect/WindowsCertConnect.java
index b933a6a67..2bae93619 100644
--- a/samples/WindowsCertConnect/src/main/java/windowscertconnect/WindowsCertConnect.java
+++ b/samples/WindowsCertConnect/src/main/java/windowscertconnect/WindowsCertConnect.java
@@ -91,6 +91,9 @@ public void onConnectionResumed(boolean sessionPresent) {
                 // Connect and disconnect using the connection we created
                 // (see sampleConnectAndDisconnect for implementation)
                 cmdUtils.sampleConnectAndDisconnect(connection);
+
+                // Close the connection now that we are completely done with it.
+                connection.close();
             }
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             onApplicationFailure(ex);
diff --git a/samples/X509CredentialsProviderConnect/src/main/java/x509credentialsproviderconnect/X509CredentialsProviderConnect.java b/samples/X509CredentialsProviderConnect/src/main/java/x509credentialsproviderconnect/X509CredentialsProviderConnect.java
index 7e69a28a9..b42495a09 100644
--- a/samples/X509CredentialsProviderConnect/src/main/java/x509credentialsproviderconnect/X509CredentialsProviderConnect.java
+++ b/samples/X509CredentialsProviderConnect/src/main/java/x509credentialsproviderconnect/X509CredentialsProviderConnect.java
@@ -77,6 +77,9 @@ public void onConnectionResumed(boolean sessionPresent) {
             // (see sampleConnectAndDisconnect for implementation)
             cmdUtils.sampleConnectAndDisconnect(connection);
 
+            // Close the connection now that we are completely done with it.
+            connection.close();
+
         } catch (CrtRuntimeException | InterruptedException | ExecutionException ex) {
             onApplicationFailure(ex);
         }