Recycle MessagePublishContext when publish fails at broker (apache#871)

willome · Oct 31, 2017 · 9a85134 · 9a85134
1 parent 815bd70
commit 9a85134
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java
@@ -252,6 +252,7 @@ public void completed(Exception exception, long ledgerId, long entryId) {
                             exception.getMessage()));
                     producer.cnx.completedSendOperation(producer.isNonPersistentTopic);
                     producer.publishOperationCompleted();
+                    recycle();
                 });
             } else {
                 if (log.isDebugEnabled()) {