Hi, ESB listens bunch of messages when I send one message fromMQTT broker to ESB. Here I'm handling MQTT through axis2 transport. Please find the log below.
[2015-06-05 16:01:40,128] WARN - AsyncCallback Executing fault handler due to exception encountered true[2015-06-05 16:01:40,224] INFO - MqttPublisherCallback message delivered .. : org.eclipse.paho.client.mqttv3.MqttDeliveryToken@5cae8c0f true[2015-06-05 16:01:40,230] INFO - MqttPublisherCallback message delivered .. : org.eclipse.paho.client.mqttv3.MqttDeliveryToken@142ff9fa true[2015-06-05 16:01:40,236] INFO - MqttPublisherCallback message delivered .. : org.eclipse.paho.client.mqttv3.MqttDeliveryToken@618ece5 true[2015-06-05 16:01:40,242] INFO - MqttPublisherCallback message delivered .. : org.eclipse.paho.client.mqttv3.MqttDeliveryToken@316ab910 true[2015-06-05 16:01:40,246] INFO - MqttPublisherCallback message delivered .. : org.eclipse.paho.client.mqttv3.MqttDeliveryToken@40fd6cd8 true[2015-06-05 16:01:40,251] INFO - MqttPublisherCallback message delivered .. : org.eclipse.paho.client.mqttv3.MqttDeliveryToken@79360f8e rue[2015-06-05 16:01:40,252] ERROR - MqttConnectionFactory Error while creating the MQTT client... MqttException (0) at org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence.getFiles(MqttDefaultFilePersistence.java:239) at org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence.keys(MqttDefaultFilePersistence.java:225) at org.eclipse.paho.client.mqttv3.internal.ClientState.restoreState(ClientState.java:268) at org.eclipse.paho.client.mqttv3.internal.ClientState.<init>(ClientState.java:133) at org.eclipse.paho.client.mqttv3.internal.ClientComms.<init>(ClientComms.java:79) at org.eclipse.paho.client.mqttv3.MqttAsyncClient.<init>(MqttAsyncClient.java:267) at org.eclipse.paho.client.mqttv3.MqttClient.<init>(MqttClient.java:222) at org.apache.axis2.transport.mqtt.MqttConnectionFactory.createMqttClient(MqttConnectionFactory.java:108) at org.apache.axis2.transport.mqtt.MqttConnectionFactory.getMqttClient(MqttConnectionFactory.java:69) at org.apache.axis2.transport.mqtt.MqttSender.sendMessage(MqttSender.java:84) at org.apache.axis2.transport.base.AbstractTransportSender.invoke(AbstractTransportSender.java:112) at org.apache.axis2.engine.AxisEngine$TransportNonBlockingInvocationWorker.run(AxisEngine.java:626) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) at java.lang.Thread.run(Thread.java:695) -- Regards S.Sriashalya, WSO2 *Inc*. lean . enterprise . middleware
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
