Hi Elilmantha, Have you enabled "debug" mode for the code and tried? If not can you try that way.
So we can see where exactly the error occurred. Regards ------------------------------------- *Shabir Mohamed* *Software Engineer* WSO2 Inc.; http://wso2.com Email: [email protected] <[email protected]> Mobile: +94 77 3516019 | +94 71 6583393 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 > >
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
