diff --git a/src/dorkbox/network/handshake/ClientHandshakeDriver.kt b/src/dorkbox/network/handshake/ClientHandshakeDriver.kt
index d62ae31c..4ddc7e8f 100644
--- a/src/dorkbox/network/handshake/ClientHandshakeDriver.kt
+++ b/src/dorkbox/network/handshake/ClientHandshakeDriver.kt
@@ -206,7 +206,7 @@ internal class ClientHandshakeDriver(
             // this check is in the "reconnect" logic
 
             // can throw an exception! We catch it in the calling class
-            val publication = aeronDriver.addExclusivePublication(publicationUri, streamIdPub, logInfo, true)
+            val publication = aeronDriver.addPublication(publicationUri, streamIdPub, logInfo, true)
 
             // can throw an exception! We catch it in the calling class
             // we actually have to wait for it to connect before we continue
@@ -272,7 +272,7 @@ internal class ClientHandshakeDriver(
 
 
             // can throw an exception! We catch it in the calling class
-            val publication = aeronDriver.addExclusivePublication(publicationUri, streamIdPub, logInfo, false)
+            val publication = aeronDriver.addPublication(publicationUri, streamIdPub, logInfo, false)
 
             // can throw an exception! We catch it in the calling class
             // we actually have to wait for it to connect before we continue
diff --git a/src/dorkbox/network/handshake/ServerHandshakePollers.kt b/src/dorkbox/network/handshake/ServerHandshakePollers.kt
index fb78c1c0..9ccfb0c8 100644
--- a/src/dorkbox/network/handshake/ServerHandshakePollers.kt
+++ b/src/dorkbox/network/handshake/ServerHandshakePollers.kt
@@ -136,7 +136,7 @@ internal object ServerHandshakePollers {
 
                     // this will always connect to the CLIENT handshake subscription!
                     val publication = try {
-                        driver.addExclusivePublication(publicationUri, message.streamId, logInfo, true)
+                        driver.addPublication(publicationUri, message.streamId, logInfo, true)
                     }
                     catch (e: Exception) {
                         // we should immediately remove the logbuffer for this! Aeron will **EVENTUALLY** remove the logbuffer, but if errors
@@ -394,7 +394,7 @@ internal object ServerHandshakePollers {
 
                     // this will always connect to the CLIENT handshake subscription!
                     val publication = try {
-                        driver.addExclusivePublication(publicationUri, message.streamId, logInfo, false)
+                        driver.addPublication(publicationUri, message.streamId, logInfo, false)
                     } catch (e: Exception) {
                         // we should immediately remove the logbuffer for this! Aeron will **EVENTUALLY** remove the logbuffer, but if errors
                         // and connections occur too quickly (within the cleanup/linger period), we can run out of memory!