Skip to main content


Eclipse Community Forums
Forum Search:

Search      Help    Register    Login    Home
Home » Eclipse Projects » Kura » publishing application(publishing bundle to target device)
publishing application [message #1775280] Fri, 27 October 2017 07:34 Go to next message
chandhu dangudubiyyam is currently offline chandhu dangudubiyyamFriend
Messages: 18
Registered: October 2017
Junior Member
hi,

successfully deployed a bundle to target device but it is not published. i followed the kura documentation to publish but its not working. is there any one who faced or facing this problem.

thanks & regards,
chandhu.

[Updated on: Fri, 27 October 2017 07:39]

Report message to a moderator

Re: publishing application [message #1775287 is a reply to message #1775280] Fri, 27 October 2017 08:21 Go to previous messageGo to next message
Matteo Maiero is currently offline Matteo MaieroFriend
Messages: 262
Registered: July 2015
Location: Italy
Senior Member
Hi,
what you mean that is not published? Not displayed in the web ui?

Have you checked for errors in the kura.log and kura-console.log?
Did you have a look at the osgi console?

Thanks.
Best regards,
Matteo
Re: publishing application [message #1775418 is a reply to message #1775287] Mon, 30 October 2017 07:09 Go to previous messageGo to next message
chandhu dangudubiyyam is currently offline chandhu dangudubiyyamFriend
Messages: 18
Registered: October 2017
Junior Member
hi,

there are no errors in console. what my problem is my bundle is published through local emulator and it displayed as service bundle in local web-ui. but in target device bundle is in active state but not displayed as service bundle in web-ui of target device.

thanks,
chandhu.
Re: publishing application [message #1775433 is a reply to message #1775418] Mon, 30 October 2017 08:46 Go to previous messageGo to next message
Matteo Maiero is currently offline Matteo MaieroFriend
Messages: 262
Registered: July 2015
Location: Italy
Senior Member
Hi,
does your code comply with what described at this page?

In particular take a look at the note saying:
Quote:

Note:
Starting from Kura 3.0, the configuration service will only track "relevant services" that, in their component description files, will provide the ConfigurableComponent or SelfConfigurableComponent interface. The old behavior can be restored by setting the "org.eclipse.kura.core.configuration.legacyServiceTracking" property to true.
Re: publishing application [message #1775438 is a reply to message #1775433] Mon, 30 October 2017 08:52 Go to previous messageGo to next message
chandhu dangudubiyyam is currently offline chandhu dangudubiyyamFriend
Messages: 18
Registered: October 2017
Junior Member
hi,
may be i think the problem is the version of kura, in target device is older version. in my pc kura version is 3.0.

thanks,
chandhu.
Re: publishing application [message #1775503 is a reply to message #1775433] Tue, 31 October 2017 06:13 Go to previous messageGo to next message
chandhu dangudubiyyam is currently offline chandhu dangudubiyyamFriend
Messages: 18
Registered: October 2017
Junior Member
hi matteo,

i am trying to publish demo heater to target device but its not displaying on target webui. kura version is 2.1.

thanks,
chandhu
Re: publishing application [message #1775506 is a reply to message #1775503] Tue, 31 October 2017 07:19 Go to previous messageGo to next message
Matteo Maiero is currently offline Matteo MaieroFriend
Messages: 262
Registered: July 2015
Location: Italy
Senior Member
Hi,
I need a little bit more context to help you. Are you building the heater from source or importing it from the Eclipse Marketplace?
Have you had a look at the log files? Are there any errors?
Have you had a look at the OSGi console?

Thanks.
Best regards,
Matteo
Re: publishing application [message #1775508 is a reply to message #1775506] Tue, 31 October 2017 07:36 Go to previous messageGo to next message
chandhu dangudubiyyam is currently offline chandhu dangudubiyyamFriend
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 #1775511 is a reply to message #1775508] Tue, 31 October 2017 08:45 Go to previous messageGo to next message
Matteo Maiero is currently offline Matteo MaieroFriend
Messages: 262
Registered: July 2015
Location: Italy
Senior Member
I believe that you are not connected to a cloud platform.
For this reason the messages produced are stacked in the local database waiting to be pushed. But now the database is full and it cannot accept more messages.

Best regards,
Matteo
Re: publishing application [message #1775601 is a reply to message #1775511] Thu, 02 November 2017 06:37 Go to previous messageGo to next message
chandhu dangudubiyyam is currently offline chandhu dangudubiyyamFriend
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 #1775602 is a reply to message #1775601] Thu, 02 November 2017 06:40 Go to previous messageGo to next message
chandhu dangudubiyyam is currently offline chandhu dangudubiyyamFriend
Messages: 18
Registered: October 2017
Junior Member
an the following is metatype xml code

-->
<MetaData xmlns="http://www.osgi.org/xmlns/metatype/v1.2.0" localization="en_us">
<OCD id="org.eclipse.kura.demo.motor.Motor"
name="Motor"
description=" Its configuration options will be passed down ">

<Icon resource="OSGI-INF/motor.png" size="32"/>

<AD id="mode"
name="mode"
type="String"
cardinality="0"
required="true"
default="Program"
description="Operating mode, If operatng mode is Vacation, set point is automatiaclly set to 6.0C.">
<Option label="Program" value="Program"/>
<Option label="Manual" value="Manual"/>
<Option label="Vacation" value="Vacation"/>
</AD>

<AD id="program.startTime"
name="program.startTime"
type="String"
cardinality="0"
required="false"
default="06:00"
description="Start time with the operating mode is Program."/>


<AD id="program.setPoint"
name="program.setPoint"
type="Integer"
cardinality="0"
required="false"
default="400"
min="300"
max="480"
description="voltage Set Point with the operating mode is Program."/>

<AD id="manual.setPoint"
name="manual.setPoint"
type="Integer"
cardinality="0"
required="false"
default="440"
min="400"
max="480"
description=" Set Point with the operating mode is Manual."/>

<AD id="voltage.initial"
name="voltage.initial"
type="Integer"
cardinality="0"
required="true"
default="440"
description="Initial value for the voltage metric."/>

<AD id="publish.rate"
name="publish.rate"
type="Integer"
cardinality="0"
required="true"
default="2"
min="1"
description="Default message publishing rate in seconds (min 1)."/>

<AD id="publish.semanticTopic"
name="publish.semanticTopic"
type="String"
cardinality="0"
required="true"
default="data"
description="Default semantic topic to publish the messages to."/>

<AD id="publish.retain"
name="publish.retain"
type="Boolean"
cardinality="0"
required="true"
default="false"
description="Default retaing flag for the published messages."/>
</OCD>

<Designate pid="org.eclipse.kura.demo.motor.Motor">
<Object ocdref="org.eclipse.kura.demo.motor.Motor"/>
</Designate>
</MetaData>


this demo motor is not able to publish, please help me if there any errors or any changes to do.

thanks,
chandhu
Re: publishing application [message #1775625 is a reply to message #1775602] Thu, 02 November 2017 10:20 Go to previous messageGo to next message
Matteo Maiero is currently offline Matteo MaieroFriend
Messages: 262
Registered: July 2015
Location: Italy
Senior Member
Hi,
just before digging in this code. Are you sure to be connected to a cloud platform? Referring to the previous logs you posted, you should not see any error related to "store capacity exceeded".
Best regards,
Matteo
Re: publishing application [message #1775640 is a reply to message #1775625] Thu, 02 November 2017 12:40 Go to previous messageGo to next message
chandhu dangudubiyyam is currently offline chandhu dangudubiyyamFriend
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
Re: publishing application [message #1775849 is a reply to message #1775640] Tue, 07 November 2017 09:02 Go to previous message
Matteo Maiero is currently offline Matteo MaieroFriend
Messages: 262
Registered: July 2015
Location: Italy
Senior Member
I believe there is something wrong with the overall consistency of the naming.
Could you please access to the OSGi console with telnet 127.0.0.1 5002 and report the result of the execution of the ss and ls commands?

Thanks.
Best regards,
Matteo
Previous Topic:Any PDF format user manual
Next Topic:Failed to build Eclipse Kura 3.1.0 for raspberry-pi-2-3
Goto Forum:
  


Current Time: Fri Sep 21 11:27:51 GMT 2018

Powered by FUDForum. Page generated in 0.02775 seconds
.:: Contact :: Home ::.

Powered by: FUDforum 3.0.2.
Copyright ©2001-2010 FUDforum Bulletin Board Software

Back to the top