重构将创建逻辑放在P2PProducer的init方法

yangyoupeng
Commit 84b74ce87074eeeaf30161c7c0888afd365f3f6c 84b74ce8 1 parent d43d2a5d
Showing 1 changed file with 1 additions and 0 deletions
src/microservice-parent/microservice-msq/src/main/java/com/zhaoonline/message/queue/P2PProducer.java
--- a/src/microservice-parent/microservice-msq/src/main/java/com/zhaoonline/message/queue/P2PProducer.java
View file @84b74ce
+++ b/src/microservice-parent/microservice-msq/src/main/java/com/zhaoonline/message/queue/P2PProducer.java
View file @84b74ce
@@ -45,6 +45,7 @@ public class P2PProducer implements ProducerInt<MessageObject,Message>{
 
 	private void init(){
 		queue=mnsClient.getQueueRef(this.queueName);
+ 		createQueue();
 		startProducer();
 	}