Home » Eclipse Projects » Kura » publishing application(publishing bundle to target device)
| | | | | | |
| Re: publishing application [message #1775508 is a reply to message #1775506] |
Tue, 31 October 2017 07:36   |
 chandhu dangudubiyyam
Messages: 18
Registered: October 2017 |
Junior Member |
|
|
after importing of kura workspace archive file some example projects are imported, demo heater is one of them and no errors in project.
following is the osgi console.
12:43:56,041 [Camel (camel-2) thread #8 - timer://xmltopic] WARN TimerConsumer:213 - Error processing exchange. Exchange[ID-chandhu-VirtualBox-46213-1509432692299-1-5362]. Caused by: [org.eclipse.kura.KuraStoreCapacityReachedException - "Error performing operation on store. Store capacity exceeded"]
org.eclipse.kura.KuraStoreCapacityReachedException: "Error performing operation on store. Store capacity exceeded"
at org.eclipse.kura.core.data.store.DbDataStore.store(DbDataStore.java:257)
at org.eclipse.kura.core.data.DataServiceImpl.publish(DataServiceImpl.java:533)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:139)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:125)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:118)
at org.eclipse.kura.camel.cloud.KuraCloudProducer.process(KuraCloudProducer.java:79)
at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:468)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.component.timer.TimerConsumer.sendTimerExchange(TimerConsumer.java:192)
at org.apache.camel.component.timer.TimerConsumer$1.run(TimerConsumer.java:76)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
12:43:56,041 [Camel (camel-2) thread #7 - timer://heartbeat] ERROR DefaultErrorHandler:204 - Failed delivery for (MessageId: ID-chandhu-VirtualBox-46213-1509432692299-1-5363 on ExchangeId: ID-chandhu-VirtualBox-46213-1509432692299-1-5364). Exhausted after delivery attempt: 1 caught: org.eclipse.kura.KuraStoreCapacityReachedException: "Error performing operation on store. Store capacity exceeded"
Message History
---------------------------------------------------------------------------------------------------------------------------------------
RouteId ProcessorId Processor Elapsed (ms)
[route5 ] [route5 ] [timer://heartbeat ] [ 2]
[route5 ] [process3 ] [Processor@0x4e376126 ] [ 0]
[route5 ] [convertBodyTo2 ] [convertBodyTo[org.eclipse.kura.message.KuraPayload] ] [ 0]
[route5 ] [temp-heartbeat ] [cloud:myapp/topic ] [ 2]
Stacktrace
---------------------------------------------------------------------------------------------------------------------------------------
org.eclipse.kura.KuraStoreCapacityReachedException: "Error performing operation on store. Store capacity exceeded"
at org.eclipse.kura.core.data.store.DbDataStore.store(DbDataStore.java:257)
at org.eclipse.kura.core.data.DataServiceImpl.publish(DataServiceImpl.java:533)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:139)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:125)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:118)
at org.eclipse.kura.camel.cloud.KuraCloudProducer.process(KuraCloudProducer.java:79)
at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:468)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.component.timer.TimerConsumer.sendTimerExchange(TimerConsumer.java:192)
at org.apache.camel.component.timer.TimerConsumer$1.run(TimerConsumer.java:76)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
12:43:56,042 [Camel (camel-2) thread #7 - timer://heartbeat] WARN TimerConsumer:213 - Error processing exchange. Exchange[ID-chandhu-VirtualBox-46213-1509432692299-1-5364]. Caused by: [org.eclipse.kura.KuraStoreCapacityReachedException - "Error performing operation on store. Store capacity exceeded"]
org.eclipse.kura.KuraStoreCapacityReachedException: "Error performing operation on store. Store capacity exceeded"
at org.eclipse.kura.core.data.store.DbDataStore.store(DbDataStore.java:257)
at org.eclipse.kura.core.data.DataServiceImpl.publish(DataServiceImpl.java:533)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:139)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:125)
at org.eclipse.kura.core.cloud.CloudClientImpl.publish(CloudClientImpl.java:118)
at org.eclipse.kura.camel.cloud.KuraCloudProducer.process(KuraCloudProducer.java:79)
at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:145)
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:468)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:121)
at org.apache.camel.processor.Pipeline.process(Pipeline.java:83)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.component.timer.TimerConsumer.sendTimerExchange(TimerConsumer.java:192)
at org.apache.camel.component.timer.TimerConsumer$1.run(TimerConsumer.java:76)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
12:43:57,038 [Camel (camel-2) thread #8 - timer://xmltopic] INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
12:43:57,039 [Camel (camel-2) thread #8 - timer://xmltopic] ERROR DbDataStore:256 - Store capacity exceeded
12:43:57,039 [Camel (camel-2) thread #7 - timer://heartbeat] INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
12:43:57,040 [Camel (camel-2) thread #8 - timer://xmltopic] ERROR DefaultErrorHandler:204 - Failed delivery for (MessageId: ID-chandhu-VirtualBox-46213-1509432692299-1-5365 on ExchangeId: ID-chandhu-VirtualBox-46213-1509432692299-1-5366). Exhausted after delivery attempt: 1 caught: org.eclipse.kura.KuraStoreCapacityReachedException: "Error performing operation on store. Store capacity exceeded"
Message History
|
|
| |
| Re: publishing application [message #1775601 is a reply to message #1775511] |
Thu, 02 November 2017 06:37 |
chandhu dangudubiyyam
Messages: 18
Registered: October 2017 |
Junior Member |
|
|
hi,
i just did small small changes in demo heater code,
the following is the code
/*******************************************************************************
* Copyright (c) 2011, 2016 Eurotech and/or its affiliates
*
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
* http://www.eclipse.org/legal/epl-v10.html
*
* Contributors:
* Eurotech
*******************************************************************************/
package org.eclipse.kura.demo.motor;
import java.util.Date;
import java.util.Map;
import java.util.Random;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import org.eclipse.kura.cloud.CloudClient;
import org.eclipse.kura.cloud.CloudClientListener;
import org.eclipse.kura.cloud.CloudService;
import org.eclipse.kura.configuration.ConfigurableComponent;
import org.eclipse.kura.message.KuraPayload;
import org.osgi.service.component.ComponentContext;
import org.osgi.service.component.ComponentException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class Motor implements ConfigurableComponent, CloudClientListener {
private static final Logger s_logger = LoggerFactory.getLogger(Motor.class);
// Cloud Application identifier
private static final String APP_ID = "Motor";
// Publishing Property Names
private static final String MODE_PROP_NAME = "mode";
private static final String MODE_PROP_PROGRAM = "Program";
private static final String MODE_PROP_MANUAL = "Manual";
private static final String MODE_PROP_VACATION = "Vacation";
private static final String PROGRAM_SETPOINT_NAME = "program.setPoint";
private static final String MANUAL_SETPOINT_NAME = "manual.setPoint";
private static final String VOL_INITIAL_PROP_NAME = "voltage.initial";
private static final String VOL_INCREMENT_PROP_NAME = "voltage.increment";
private static final String PUBLISH_RATE_PROP_NAME = "publish.rate";
private static final String PUBLISH_TOPIC_PROP_NAME = "publish.semanticTopic";
private static final String PUBLISH_QOS_PROP_NAME = "publish.qos";
private static final String PUBLISH_RETAIN_PROP_NAME = "publish.retain";
private CloudService m_cloudService;
private CloudClient m_cloudClient;
private final ScheduledExecutorService m_worker;
private ScheduledFuture<?> m_handle;
private float m_voltage;
private Map<String, Object> m_properties;
private final Random m_random;
// ----------------------------------------------------------------
//
// Dependencies
//
// ----------------------------------------------------------------
public Motor() {
super();
this.m_random = new Random();
this.m_worker = Executors.newSingleThreadScheduledExecutor();
}
public void setCloudService(CloudService cloudService) {
this.m_cloudService = cloudService;
}
public void unsetCloudService(CloudService cloudService) {
this.m_cloudService = null;
}
// ----------------------------------------------------------------
//
// Activation APIs
//
// ----------------------------------------------------------------
protected void activate(ComponentContext componentContext, Map<String, Object> properties) {
s_logger.info("Activating motor...");
this.m_properties = properties;
for (String s : properties.keySet()) {
s_logger.info("Activate - " + s + ": " + properties.get(s));
}
// get the mqtt client for this application
try {
// Acquire a Cloud Application Client for this Application
s_logger.info("Getting CloudClient for {}...", APP_ID);
this.m_cloudClient = this.m_cloudService.newCloudClient(APP_ID);
this.m_cloudClient.addCloudClientListener(this);
// Don't subscribe because these are handled by the default
// subscriptions and we don't want to get messages twice
doUpdate(false);
} catch (Exception e) {
s_logger.error("Error during component activation", e);
throw new ComponentException(e);
}
s_logger.info("Activating Motor... Done.");
}
protected void deactivate(ComponentContext componentContext) {
s_logger.debug("Deactivating Motor...");
// shutting down the worker and cleaning up the properties
this.m_worker.shutdown();
// Releasing the CloudApplicationClient
s_logger.info("Releasing CloudApplicationClient for {}...", APP_ID);
this.m_cloudClient.release();
s_logger.debug("Deactivating Motor... Done.");
}
public void updated(Map<String, Object> properties) {
s_logger.info("Updated Motor...");
// store the properties received
this.m_properties = properties;
for (String s : properties.keySet()) {
s_logger.info("Update - " + s + ": " + properties.get(s));
}
// try to kick off a new job
doUpdate(true);
s_logger.info("Updated Motor... Done.");
}
// ----------------------------------------------------------------
//
// Cloud Application Callback Methods
//
// ----------------------------------------------------------------
@Override
public void onControlMessageArrived(String deviceId, String appTopic, KuraPayload msg, int qos, boolean retain) {
// TODO Auto-generated method stub
}
@Override
public void onMessageArrived(String deviceId, String appTopic, KuraPayload msg, int qos, boolean retain) {
// TODO Auto-generated method stub
}
@Override
public void onConnectionLost() {
// TODO Auto-generated method stub
}
@Override
public void onConnectionEstablished() {
// TODO Auto-generated method stub
}
@Override
public void onMessageConfirmed(int messageId, String appTopic) {
// TODO Auto-generated method stub
}
@Override
public void onMessagePublished(int messageId, String appTopic) {
// TODO Auto-generated method stub
}
// ----------------------------------------------------------------
//
// Private Methods
//
// ----------------------------------------------------------------
/**
* Called after a new set of properties has been configured on the service
*/
private void doUpdate(boolean onUpdate) {
// cancel a current worker handle if one if active
if (this.m_handle != null) {
this.m_handle.cancel(true);
}
if (!this.m_properties.containsKey(VOL_INITIAL_PROP_NAME)
|| !this.m_properties.containsKey(PUBLISH_RATE_PROP_NAME)) {
s_logger.info(
"Update Heater - Ignore as properties do not contain TEMP_INITIAL_PROP_NAME and PUBLISH_RATE_PROP_NAME.");
return;
}
// reset to the initial value
if (!onUpdate) {
this.m_voltage = (Integer) this.m_properties.get(VOL_INITIAL_PROP_NAME);
}
// schedule a new worker based on the properties of the service
int pubrate = (Integer) this.m_properties.get(PUBLISH_RATE_PROP_NAME);
this.m_handle = this.m_worker.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
Thread.currentThread().setName(getClass().getSimpleName());
doPublish();
}
}, 0, pubrate, TimeUnit.SECONDS);
}
/**
* Called at the configured rate to publish the next temperature measurement.
*/
private void doPublish() {
// fetch the publishing configuration from the publishing properties
String topic = (String) this.m_properties.get(PUBLISH_TOPIC_PROP_NAME);
Integer qos = (Integer) this.m_properties.get(PUBLISH_QOS_PROP_NAME);
Boolean retain = (Boolean) this.m_properties.get(PUBLISH_RETAIN_PROP_NAME);
String mode = (String) this.m_properties.get(MODE_PROP_NAME);
// Increment the simulated value
int setPoint = 380;
int volIncr = (Integer) this.m_properties.get(VOL_INCREMENT_PROP_NAME);
if (MODE_PROP_PROGRAM.equals(mode)) {
setPoint = (Integer) this.m_properties.get(PROGRAM_SETPOINT_NAME);
} else if (MODE_PROP_MANUAL.equals(mode)) {
setPoint = (Integer) this.m_properties.get(MANUAL_SETPOINT_NAME);
} else if (MODE_PROP_VACATION.equals(mode)) {
setPoint =440;
}
if (this.m_voltage + volIncr < setPoint) {
this.m_voltage += volIncr;
} else {
this.m_voltage -= 4 * volIncr;
}
// Allocate a new payload
KuraPayload payload = new KuraPayload();
// Timestamp the message
payload.setTimestamp(new Date());
// Add as a metric to the payload
payload.addMetric("voltage", this.m_voltage);
payload.addMetric("torque", 30000);
payload.addMetric("HorsePower", 225);
payload.addMetric("ply_wheel_speed", 120);
payload.addMetric("vibraton_bearing", 0.75);
int code = this.m_random.nextInt();
if (this.m_random.nextInt() % 5 == 0) {
payload.addMetric("errorCode", code);
} else {
payload.addMetric("errorCode", 0);
}
// Publish the message
try {
this.m_cloudClient.publish(topic, payload, qos, retain);
s_logger.info("Published to {} message: {}", topic, payload);
} catch (Exception e) {
s_logger.error("Cannot publish topic: " + topic, e);
}
}
}
|
|
| | |
| Re: publishing application [message #1775640 is a reply to message #1775625] |
Thu, 02 November 2017 12:40 |
chandhu dangudubiyyam
Messages: 18
Registered: October 2017 |
Junior Member |
|
|
hi,
following is the eclipse console. and attached file is the webui.
18:07:44,633 INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange
18:07:44,636 INFO greaterThanTen:159 - Exchange
18:07:44,638 INFO MESSAGE_FROM_CLOUD:159 - Exchange
18:07:45,330 INFO MqttDataTransport:516 - Publishing message on topic: AltenCalsoftLabs-SG/Motor/myapp/topic with QoS: 0
18:07:45,357 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:45,358 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:45,358 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:45,359 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:45,632 INFO CloudServiceImpl:436 - Message arrived on topic: AltenCalsoftLabs-SG/Motor/myapp/topic
18:07:45,634 INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange
18:07:45,636 INFO lessThanTen:159 - Exchange
18:07:45,637 INFO MESSAGE_FROM_CLOUD:159 - Exchange
18:07:46,331 INFO MqttDataTransport:516 - Publishing message on topic: AltenCalsoftLabs-SG/Motor/myapp/topic with QoS: 0
18:07:46,358 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:46,360 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:46,361 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:46,363 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:46,631 INFO CloudServiceImpl:436 - Message arrived on topic: AltenCalsoftLabs-SG/Motor/myapp/topic
18:07:46,633 INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange
18:07:46,634 INFO lessThanTen:159 - Exchange
18:07:46,636 INFO MESSAGE_FROM_CLOUD:159 - Exchange
18:07:47,330 INFO MqttDataTransport:516 - Publishing message on topic: AltenCalsoftLabs-SG/Motor/myapp/xmltopic with QoS: 0
18:07:47,359 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:47,361 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:47,362 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:47,364 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:47,630 INFO CloudServiceImpl:436 - Message arrived on topic: AltenCalsoftLabs-SG/Motor/myapp/xmltopic
18:07:47,632 INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange
18:07:47,635 INFO greaterThanTen:159 - Exchange
18:07:47,636 INFO MESSAGE_FROM_CLOUD:159 - Exchange
18:07:48,332 INFO MqttDataTransport:516 - Publishing message on topic: AltenCalsoftLabs-SG/Motor/myapp/topic with QoS: 0
18:07:48,359 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:48,361 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:48,363 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:48,366 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:48,632 INFO CloudServiceImpl:436 - Message arrived on topic: AltenCalsoftLabs-SG/Motor/myapp/topic
18:07:48,634 INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange
18:07:48,636 INFO lessThanTen:159 - Exchange
18:07:48,637 INFO MESSAGE_FROM_CLOUD:159 - Exchange
18:07:49,334 INFO MqttDataTransport:516 - Publishing message on topic: AltenCalsoftLabs-SG/Motor/myapp/xmltopic with QoS: 0
18:07:49,359 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:49,361 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:49,364 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:49,368 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:49,633 INFO CloudServiceImpl:436 - Message arrived on topic: AltenCalsoftLabs-SG/Motor/myapp/xmltopic
18:07:49,635 INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange
18:07:49,636 INFO lessThanTen:159 - Exchange
18:07:49,636 INFO MESSAGE_FROM_CLOUD:159 - Exchange
18:07:50,330 INFO MqttDataTransport:516 - Publishing message on topic: AltenCalsoftLabs-SG/Motor/myapp/topic with QoS: 0
18:07:50,359 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:50,359 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:50,364 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:50,365 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:50,635 INFO CloudServiceImpl:436 - Message arrived on topic: AltenCalsoftLabs-SG/Motor/myapp/topic
18:07:50,637 INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange
18:07:50,639 INFO lessThanTen:159 - Exchange
18:07:50,641 INFO MESSAGE_FROM_CLOUD:159 - Exchange
18:07:51,330 INFO MqttDataTransport:516 - Publishing message on topic: AltenCalsoftLabs-SG/Motor/myapp/xmltopic with QoS: 0
18:07:51,359 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:51,361 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:51,366 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:51,368 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:51,630 INFO CloudServiceImpl:436 - Message arrived on topic: AltenCalsoftLabs-SG/Motor/myapp/xmltopic
18:07:51,633 INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange
18:07:51,636 INFO greaterThanTen:159 - Exchange
18:07:51,638 INFO MESSAGE_FROM_CLOUD:159 - Exchange
18:07:52,330 INFO MqttDataTransport:516 - Publishing message on topic: AltenCalsoftLabs-SG/Motor/myapp/topic with QoS: 0
18:07:52,359 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:52,361 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/xmltopic, priority: 5
18:07:52,366 INFO DataServiceImpl:531 - Storing message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:52,367 INFO DataServiceImpl:534 - Stored message on topic :#account-name/#client-id/myapp/topic, priority: 5
18:07:52,630 [MQTT Call: Motor] INFO CloudServiceImpl:436 - Message arrived on topic: AltenCalsoftLabs-SG/Motor/myapp/topic
18:07:52,632 [MQTT Call: Motor] INFO MESSAGE_SENT_TO_CLOUD:159 - Exchange[ExchangePattern: InOnly, BodyType: org.eclipse.kura.message.KuraPayload, Body: org.eclipse.kura.me
|
|
| |
Goto Forum:
Current Time: Tue Apr 16 06:17:24 GMT 2024
Powered by FUDForum. Page generated in 0.59224 seconds |
] 
Search
Help
Register
Login
Home
