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
