diff --git a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageReceiver.java b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageReceiver.java
index 20942a3..bdf8891 100644
--- a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageReceiver.java
+++ b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageReceiver.java
@@ -108,7 +108,7 @@ class MessageReceiver extends InitializableEntity implements IMessageReceiver, I
                     if (TRACE_LOGGER.isInfoEnabled()) {
                         TRACE_LOGGER.info("Created MessagingFactory to namespace '{}'", this.namespaceEndpointURI.toString());
                     }
-                });
+                }, MessagingFactory.INTERNAL_THREAD_POOL);
             } else {
                 factoryFuture = CompletableFuture.completedFuture(null);
             }
diff --git a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageSender.java b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageSender.java
index 2cd0555..7b24dd2 100644
--- a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageSender.java
+++ b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/MessageSender.java
@@ -73,7 +73,7 @@ final class MessageSender extends InitializableEntity implements IMessageSender
                     if (TRACE_LOGGER.isInfoEnabled()) {
                         TRACE_LOGGER.info("Created MessagingFactory to namespace '{}'", this.namespaceEndpointURI.toString());
                     }
-                });
+                }, MessagingFactory.INTERNAL_THREAD_POOL);
             } else {
                 factoryFuture = CompletableFuture.completedFuture(null);
             }
diff --git a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/primitives/CoreMessageSender.java b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/primitives/CoreMessageSender.java
index a2b2b91..50356dc 100644
--- a/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/primitives/CoreMessageSender.java
+++ b/azure-servicebus/src/main/java/com/microsoft/azure/servicebus/primitives/CoreMessageSender.java
@@ -776,7 +776,7 @@ public class CoreMessageSender extends ClientEntity implements IAmqpSender, IErr
                         }
                     }
                     return null;
-                });
+                }, MessagingFactory.INTERNAL_THREAD_POOL);
             }
             
             return this.sendLinkReopenFuture;
diff --git a/pom.xml b/pom.xml
index 2e1832a..260cdae 100644
--- a/pom.xml
+++ b/pom.xml
@@ -13,7 +13,7 @@
 		<proton-j-version>0.31.0</proton-j-version>
 	  	<junit-version>4.12</junit-version>
 		<slf4j-version>1.7.0</slf4j-version>
-		<client-current-version>1.2.18</client-current-version>		
+		<client-current-version>1.2.19-SNAPSHOT</client-current-version><!--  Only to port any fixes from 3.1.x branch -->
 	</properties>
 	
 	<modules>