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-12 19:21:41 +08:00
parent 8502792aad
commit 146b81ee5e
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/org/redkale/mq/MessageAgent.java
View File

@@ -137,8 +137,9 @@ public abstract class MessageAgent {
if (this.sncpProducer == null) {
synchronized (sncpProducerLock) {
if (this.sncpProducer == null) {
this.sncpProducer = createProducer("SncpProducer");
this.sncpProducer.startup().join();
MessageProducer producer = createProducer("SncpProducer");
producer.startup().join();
this.sncpProducer = producer;
}
}
}
@@ -149,8 +150,9 @@ public abstract class MessageAgent {
if (this.httpProducer == null) {
synchronized (httpProducerLock) {
if (this.httpProducer == null) {
this.httpProducer = createProducer("HttpProducer");
this.httpProducer.startup().join();
MessageProducer producer = createProducer("HttpProducer");
producer.startup().join();
this.httpProducer = producer;
}
}
}