From 8db398e50a631012d3dfb26a797b82a3409b15e0 Mon Sep 17 00:00:00 2001 From: "KADASTER-NL\\kostet" Date: Wed, 16 May 2018 13:09:38 +0200 Subject: [PATCH] When the unsubscribe was succesfull there is no data being returned from nats. In older versions there was data and the code did depend on that. For now a simple fix. Issue mentioned in: https://github.com/nats-io/java-nats-streaming/issues/86 --- src/main/java/io/nats/streaming/SubscriptionImpl.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/main/java/io/nats/streaming/SubscriptionImpl.java b/src/main/java/io/nats/streaming/SubscriptionImpl.java index a0887e9..6f13d52 100644 --- a/src/main/java/io/nats/streaming/SubscriptionImpl.java +++ b/src/main/java/io/nats/streaming/SubscriptionImpl.java @@ -182,9 +182,11 @@ public void close(boolean unsubscribe) throws IOException { throw new IOException(e); } - SubscriptionResponse response = SubscriptionResponse.parseFrom(reply.getData()); - if (!response.getError().isEmpty()) { - throw new IOException(PFX + response.getError()); + if(reply.getData() != null) { + SubscriptionResponse response = SubscriptionResponse.parseFrom(reply.getData()); + if (!response.getError().isEmpty()) { + throw new IOException(PFX + response.getError()); + } } }