Home » Eclipse Projects » Kura » publishing application(publishing bundle to target device)
| publishing application [message #1775280] |
Fri, 27 October 2017 03:34  |
Eclipse User |
|
|
|
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 03:39] by Moderator |
|
| | | | | | |
| Re: publishing application [message #1775508 is a reply to message #1775506] |
Tue, 31 October 2017 03:36  |
| Eclipse User |
|
|
|
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 02:37 |
| Eclipse User |
|
|
|
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 08:40 |
| Eclipse User |
|
|
|
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 04:02 |
| Eclipse User |
|
|
|
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
|
|
|
Goto Forum:
Current Time: Wed Jul 23 08:29:53 EDT 2025
Powered by FUDForum. Page generated in 0.39978 seconds |
Home