+ public MQProducer() {\r
+\r
+ }\r
+\r
+ public void init() {\r
+\r
+ String brokerURL =\r
+ "tcp://" + mqConfigProvider.get().brokerIp + ":" + mqConfigProvider.get().brokerPort;\r
+ connectionFactory = new ActiveMQConnectionFactory(mqConfigProvider.get().brokerUsername,\r
+ mqConfigProvider.get().brokerPassword, brokerURL);\r
+ }\r
+\r