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 18:10:00 +08:00
parent 3d9447327a
commit 8502792aad
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -42,6 +42,10 @@ public abstract class MessageAgent {
protected MessageProducer sncpProducer; protected MessageProducer sncpProducer;
protected final Object httpProducerLock = new Object();
protected final Object sncpProducerLock = new Object();
protected HttpMessageClient httpMessageClient; protected HttpMessageClient httpMessageClient;
protected SncpMessageClient sncpMessageClient; protected SncpMessageClient sncpMessageClient;
@@ -131,7 +135,7 @@ public abstract class MessageAgent {
//获取指定topic的生产处理器 //获取指定topic的生产处理器
public MessageProducer getSncpProducer() { public MessageProducer getSncpProducer() {
if (this.sncpProducer == null) { if (this.sncpProducer == null) {
synchronized (this) { synchronized (sncpProducerLock) {
if (this.sncpProducer == null) { if (this.sncpProducer == null) {
this.sncpProducer = createProducer("SncpProducer"); this.sncpProducer = createProducer("SncpProducer");
this.sncpProducer.startup().join(); this.sncpProducer.startup().join();
@@ -143,7 +147,7 @@ public abstract class MessageAgent {
public MessageProducer getHttpProducer() { public MessageProducer getHttpProducer() {
if (this.httpProducer == null) { if (this.httpProducer == null) {
synchronized (this) { synchronized (httpProducerLock) {
if (this.httpProducer == null) { if (this.httpProducer == null) {
this.httpProducer = createProducer("HttpProducer"); this.httpProducer = createProducer("HttpProducer");
this.httpProducer.startup().join(); this.httpProducer.startup().join();