lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2020-06-04 09:39:38 +08:00
parent 45f2ce261e
commit 1d7a72f992
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/mq/MessageConsumer.java
View File

@@ -50,9 +50,9 @@ public abstract class MessageConsumer {
public abstract CompletableFuture<Void> startup();
protected boolean isClosed() {
public boolean isClosed() {
return closed;
}
protected abstract CompletableFuture<Void> shutdown();
public abstract CompletableFuture<Void> shutdown();
}

4
src/org/redkale/mq/MessageProducer.java
View File

@@ -27,9 +27,9 @@ public abstract class MessageProducer {
public abstract CompletableFuture<Void> startup();
protected boolean isClosed() {
public boolean isClosed() {
return closed;
}
protected abstract CompletableFuture<Void> shutdown();
public abstract CompletableFuture<Void> shutdown();
}