I'm working on MQTT inbound, for that I followed the following steps
- build the product esb from source. - build the carbon mediation (with MQTT inbound) and insert the jar to esb zip patch folder - changed the needed axis2.xml for MQTT transport in esb zip - included the folllowing inbound sequence into synapse configs/inbound-endpoints folder of esb <?xml version="1.0" encoding="UTF-8"?> <inboundEndpoint xmlns="http://ws.apache.org/ns/synapse"; name="test1" sequence="df" onError="ff" protocol="mqtt" suspend="false"> <parameters> <parameter name="sequential">true</parameter> <parameter name="interval">10</parameter> <parameter name="mqtt.connection.factory">mqttConFactory</parameter> <parameter name="mqtt.server.host.name">localhost</parameter> <parameter name="mqtt.server.port">1883</parameter> <parameter name="mqtt.topic.name">esb.test2</parameter> <parameter name="mqtt.subscription.qos">0</parameter> <parameter name="mqtt.session.clean">false</parameter> <parameter name="mqtt.ssl.enable">false</parameter> <parameter name="mqtt.subscription.username">elil</parameter> <parameter name="mqtt.subscription.password">e123</parameter> <parameter name="mqtt.temporary.store.directory">my</parameter> <parameter name="mqtt.blocking.sender">false</parameter> </parameters> </inboundEndpoint> - installed mosquito message broker and published a message. - start the esb server and got the follwing in the console [2015-04-30 08:38:59,705] INFO - InboundEndpoint Initializing Inbound Endpoint: test1 [2015-04-30 08:38:59,709] INFO - MqttListener MQTT inbound endpoint: test1 initializing ... [2015-04-30 08:38:59,725] INFO - MqttAsyncCallback Connecting to brocker with client ID elilmatha.1430363339712 [2015-04-30 08:38:59,744] INFO - MqttAsyncCallback Connected [2015-04-30 08:38:59,745] INFO - MqttAsyncCallback Subscribing to topic "esb.test2" qos 0 [2015-04-30 08:38:59,746] INFO - MqttAsyncCallback Subscribe Completed [2015-04-30 08:38:59,749] INFO - ServerManager Server ready for processing... [2015-04-30 08:38:59,759] ERROR - MqttInjectHandler Error while processing the MQTT Message [2015-04-30 08:39:00,344] INFO - PassThroughHttpSSLListener Starting Pass-through HTTPS Listener... [2015-04-30 08:39:00,357] INFO - PassThroughListeningIOReactorManager Pass-through HTTPS Listener started on 0.0.0.0:8245 [2015-04-30 08:39:00,357] INFO - PassThroughHttpListener Starting Pass-through HTTP Listener... [2015-04-30 08:39:00,359] INFO - PassThroughListeningIOReactorManager Pass-through HTTP Listener started on 0.0.0.0:8282 [2015-04-30 08:39:00,364] INFO - NioSelectorPool Using a shared selector for servlet write/read [2015-04-30 08:39:00,685] INFO - NioSelectorPool Using a shared selector for servlet write/read [2015-04-30 08:39:00,747] INFO - TaskServiceImpl Task service starting in STANDALONE mode... [2015-04-30 08:39:00,766] INFO - NTaskTaskManager Initialized task manager. Tenant [-1234] [2015-04-30 08:39:00,773] INFO - RegistryEventingServiceComponent Successfully Initialized Eventing on Registry [2015-04-30 08:39:00,810] INFO - JMXServerManager JMX Service URL : service:jmx:rmi://localhost:11113/jndi/rmi://localhost:10001/jmxrmi [2015-04-30 08:39:00,811] INFO - StartupFinalizerServiceComponent Server : WSO2 Enterprise Service Bus-4.9.0 [2015-04-30 08:39:00,812] INFO - StartupFinalizerServiceComponent WSO2 Carbon started in 19 sec [2015-04-30 08:39:01,027] INFO - CarbonUIServiceComponent Mgt Console URL : https://10.100.5.172:9445/carbon/ [2015-04-30 08:39:21,813] ERROR - MqttInjectHandler Error while processing the MQTT Message What am I missing over here? Can any one suggest with the proper way to proceed on passing the message. -- *S.Elilmatha* Associate Software Engineer, WSO2 Inc.; http://wso2.com lean.enterprise.middleware Mobile 0779842221.
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
