diff --git a/joyqueue-client/joyqueue-client-core/src/main/java/io/openmessaging/joyqueue/support/MessageAccessPointHolder.java b/joyqueue-client/joyqueue-client-core/src/main/java/io/openmessaging/joyqueue/support/MessageAccessPointHolder.java index c8024fe30..2ef99f5fe 100644 --- a/joyqueue-client/joyqueue-client-core/src/main/java/io/openmessaging/joyqueue/support/MessageAccessPointHolder.java +++ b/joyqueue-client/joyqueue-client-core/src/main/java/io/openmessaging/joyqueue/support/MessageAccessPointHolder.java @@ -19,7 +19,7 @@ /** * MessageAccessPointHolder - * + * * author: gaohaoxiang * date: 2019/5/14 */ @@ -42,6 +42,7 @@ public void stopProducer() { maybeStop(); } + /** start producer */ public void startProducer() { producers++; } @@ -61,4 +62,4 @@ protected void maybeStop() { } messageAccessPoint.stop(); } -} \ No newline at end of file +}