Fixing a NullPointerException in RequestResponseLink (#359)

Azure · May 29, 2019 · ac91c74 · ac91c74
1 parent b1ba2c8
commit ac91c74
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/azure-servicebus/azure-servicebus.pom b/azure-servicebus/azure-servicebus.pom
@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.microsoft.azure</groupId>
     <artifactId>azure-servicebus</artifactId>
-    <version>1.2.13</version>
+    <version>1.2.14</version>
     <licenses>
         <license>
             <name>The MIT License (MIT)</name>

diff --git a/...rvicebus/src/main/java/com/microsoft/azure/servicebus/primitives/RequestResponseLink.java b/...rvicebus/src/main/java/com/microsoft/azure/servicebus/primitives/RequestResponseLink.java
@@ -433,8 +433,8 @@ public CompletableFuture<Message> requestAysnc(Message requestMessage, Duration
 		this.amqpSender.sendRequest(requestId, false);
 
 		// Check and recreate links if necessary
-        if(!((this.amqpSender.sendLink.getLocalState() == EndpointState.ACTIVE && this.amqpSender.sendLink.getRemoteState() == EndpointState.ACTIVE)
-                && (this.amqpReceiver.receiveLink.getLocalState() == EndpointState.ACTIVE && this.amqpReceiver.receiveLink.getRemoteState() == EndpointState.ACTIVE)))
+        if(!((this.amqpSender.sendLink != null && this.amqpSender.sendLink.getLocalState() == EndpointState.ACTIVE && this.amqpSender.sendLink.getRemoteState() == EndpointState.ACTIVE)
+                && (this.amqpReceiver.receiveLink != null && this.amqpReceiver.receiveLink.getLocalState() == EndpointState.ACTIVE && this.amqpReceiver.receiveLink.getRemoteState() == EndpointState.ACTIVE)))
         {
             this.ensureUniqueLinkRecreation();
         }

diff --git 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.13</client-current-version>		
+		<client-current-version>1.2.14</client-current-version>		
 	</properties>
 
 	<modules>