Hi Elilmatha, As Sumedha mentioned, the code has swallowed the exception in the MqttInjectHandler class. Please debug the code and check what is the exception occurring here.
Thanks, Chanaka On Thu, Apr 30, 2015 at 9:52 AM, Elilmatha Sivanesan <[email protected]> wrote: > Hi Sumedha, > > The code is found in the following PR [1] > > [1] https://github.com/wso2-dev/carbon-mediation/pull/105 > <https://www.google.com/url?q=https%3A%2F%2Fgithub.com%2Fwso2-dev%2Fcarbon-mediation%2Fpull%2F105&sa=D&sntz=1&usg=AFQjCNFDtsM-KxUMKqcXiFDfOQmAY-YGdQ> > > Thank you. > > On Thu, Apr 30, 2015 at 9:45 AM, Sumedha Rubasinghe <[email protected]> > wrote: > >> I cannot find source for >> org.wso2.carbon.inbound.endpoint.protocol.mqtt.MQTTInjectHandler. >> >> But you need to put a debug point in the bellow block. We seem to have >> swallowed the exception here. :( >> >> catch (Exception e) { >> log.error("Error while processing the MQTT Message"); >> } >> >> On Thu, Apr 30, 2015 at 9:05 AM, Elilmatha Sivanesan <[email protected]> >> wrote: >> >>> 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 >>> >>> >> >> >> -- >> /sumedha >> m: +94 773017743 >> b : bit.ly/sumedha >> > > > > -- > *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 > > -- -- Chanaka Fernando Senior Technical Lead WSO2, Inc.; http://wso2.com lean.enterprise.middleware mobile: +94 773337238 Blog : http://soatutorials.blogspot.com LinkedIn:http://www.linkedin.com/pub/chanaka-fernando/19/a20/5b0 Twitter:https://twitter.com/chanakaudaya Wordpress:http://chanakaudaya.wordpress.com
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
