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()); + } } }