Hi all,
I used BeagleBone Black and install Kura on it as gateway,
I can successfully receive the payload from the kura.demo.heater example bundle
but I can't receive the message sent from my paho client,this is my error message
2014-12-26 14:37:45,029 [MQTT Call: HelloBBB] DEBUG o.e.k.c.c.CloudServiceImpl - Message arrived on topic: beaglebone/HelloBBB/heater/GGWWP
2014-12-26 14:37:45,032 [MQTT Call: HelloBBB] ERROR o.e.k.c.d.DataServiceListeners - Unexpected Throwable
java.lang.NoClassDefFoundError: Could not initialize class org.eclipse.kura.core.message.protobuf.KuraPayloadProto
at org.eclipse.kura.core.message.protobuf.KuraPayloadProto$KuraPayload.getDescriptor(KuraPayloadProto.java:69)
at org.eclipse.kura.core.message.protobuf.KuraPayloadProto$KuraPayload$Builder.getDescriptorForType(KuraPayloadProto.java:2149)
at com.google.protobuf.AbstractMessage$Builder.mergeFieldFrom(AbstractMessage.java:339)
at com.google.protobuf.GeneratedMessage$ExtendableBuilder.parseUnknownField(GeneratedMessage.java:976)
at org.eclipse.kura.core.message.protobuf.KuraPayloadProto$KuraPayload$Builder.mergeFrom(KuraPayloadProto.java:2294)
at org.eclipse.kura.core.message.protobuf.KuraPayloadProto$KuraPayload$Builder.mergeFrom(KuraPayloadProto.java:1)
at com.google.protobuf.AbstractMessage$Builder.mergeFrom(AbstractMessage.java:300)
at com.google.protobuf.AbstractMessage$Builder.mergeFrom(AbstractMessage.java:238)
at com.google.protobuf.AbstractMessageLite$Builder.mergeFrom(AbstractMessageLite.java:162)
at com.google.protobuf.AbstractMessage$Builder.mergeFrom(AbstractMessage.java:716)
at com.google.protobuf.AbstractMessage$Builder.mergeFrom(AbstractMessage.java:238)
at com.google.protobuf.AbstractMessageLite$Builder.mergeFrom(AbstractMessageLite.java:153)
at com.google.protobuf.AbstractMessage$Builder.mergeFrom(AbstractMessage.java:709)
at org.eclipse.kura.core.message.protobuf.KuraPayloadProto$KuraPayload.parseFrom(KuraPayloadProto.java:2024)
at org.eclipse.kura.core.cloud.CloudPayloadProtoBufDecoderImpl.buildFromByteArray(CloudPayloadProtoBufDecoderImpl.java:63)
at org.eclipse.kura.core.cloud.CloudServiceImpl.onMessageArrived(CloudServiceImpl.java:411)
at org.eclipse.kura.core.data.DataServiceListeners.onMessageArrived(DataServiceListeners.java:98)
at org.eclipse.kura.core.data.DataServiceImpl.onMessageArrived(DataServiceImpl.java:332)
at org.eclipse.kura.core.data.transport.mqtt.DataTransportListeners.onMessageArrived(DataTransportListeners.java:132)
at org.eclipse.kura.core.data.transport.mqtt.MqttDataTransport.messageArrived(MqttDataTransport.java:558)
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.handleMessage(CommsCallback.java:349)
at org.eclipse.paho.client.mqttv3.internal.CommsCallback.run(CommsCallback.java:162)
at java.lang.Thread.run(Thread.java:745)
and this is my piece of code
public Heater() {super();m_random = new Random();m_worker = Executors.newSingleThreadScheduledExecutor();}protected void activate(ComponentContext componentContext, Map<String,Object> properties) {s_logger.info("Activating Heater...");m_properties = properties;for (String s : properties.keySet()) {s_logger.info("Activate - "+s+": "+properties.get(s));}// get the mqtt client for this applicationtry {// Acquire a Cloud Application Client for this Application s_logger.info("Getting CloudClient for {}...", APP_ID);m_cloudClient = m_cloudService.newCloudClient(APP_ID); m_cloudClient.addCloudClientListener(this);m_cloudClient.subscribe("GGWWP", 0); //doUpdate(false); i remove this to avoid sending message}catch (Exception e) {s_logger.error("Error during component activation", e);throw new ComponentException(e);}s_logger.info("Activating Heater... Done.");}Thanks a lot !!!!