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
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
