public class CloudletServiceKura extends Cloudlet implements ConfigurableComponent{
	private static final Logger logger = LoggerFactory.getLogger(CloudletServiceKura.class);
	public static final String appId = "CONF-V1";
	private Map<String, Object> properties;
	
	private CloudService  cloudService;

	public static final String RESOURCE_CONFIGURATIONS = "configurations";	

	public CloudletServiceKura() {
		super(appId);			
	}
	
	
	@Override
	public void setCloudService(CloudService cloudService) {
		if (this.cloudService == null) {
			super.setCloudService(this.cloudService = cloudService);
		}
	}
	
	@Override
	public void unsetCloudService(CloudService cloudService) {
		if (this.cloudService == cloudService) 
			super.setCloudService(this.cloudService = null);
	}
	
	protected void activate(ComponentContext componentContext, Map<String, Object> props) {
		logger.info("Activating \" {} ...", appId );
		this.properties = props;
		for (String s : properties.keySet()) {
			logger.info("Activate - "+s+": "+props.get(s));
		}		
		super.setCloudService(cloudService);
		super.activate(componentContext);
		logger.info("Activating \" {} \" done", appId);
	}
	
	protected void deactivate(ComponentContext componentContext) 
	{
		if (getCloudApplicationClient() != null) {
			super.deactivate(componentContext);
		}
	}
	
	public void updated(Map<String, Object> props) {
		this.properties = props;		
		logger.info("Updating \" {} \"...", appId);
		for (String s : properties.keySet()) {
			logger.info("Update - "+s+": "+properties.get(s));
		}
		logger.info("Updating \" {} \" done", appId);	
	}

	@Override
	protected void doGet(CloudletTopic reqTopic, KuraRequestPayload reqPayload,
			KuraResponsePayload respPayload) throws KuraException {
		
		String [] resources = reqTopic.getResources();
			
		if (resources == null || resources.length == 0) {
			logger.error("Bad request topic: {}", reqTopic.toString()); 
			logger.error("Expected one resource but found {}", resources !=null ? resources.length: "none");
			respPayload.setResponseCode(KuraResponsePayload.RESPONSE_CODE_BAD_REQUEST);
			return;
		}
			
		logger.info("Get request received from topic \"{}\"", resources[0]);
		
		if (resources[0].equals(RESOURCE_CONFIGURATIONS)) {
			//doGetConfigurations(reqTopic, reqPayload, respPayload);
		} else {
			logger.error("Bad request topic: {}", reqTopic.toString());
			logger.error("Cannot find resource with name: {}", resources[0]);
			respPayload.setResponseCode(KuraResponsePayload.RESPONSE_CODE_NOTFOUND);
			return;
		}
	}
	
	@Override
	public void onConnectionEstablished() {
		logger.info("Cloud Client: Connection has been established");
		try {
			this.getCloudApplicationClient().subscribe("#", 0);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	@Override
	public void onControlMessageArrived(String deviceId, String appTopic, KuraPayload msg, int qos, boolean retain) {
		super.onControlMessageArrived(deviceId, appTopic, msg, qos, retain);
	}
	
	@Override
	public void onMessageArrived(String deviceId, String appTopic, KuraPayload msg, int qos, boolean retain) {
		if (msg.getBody() == null)
			return;	
		logger.info("message \"{}\" arrived on topic \"{}\"", new String(msg.getBody()), appTopic);
	}
}

$EDC/kura/local/CONF-V1/GET/configurations
Request ID: REQUEST_EAGIGLBGK817NDH7C86QONJE76
Requester Client ID: CLIENT_JJJAODSAPV7AHI3UG1CO0EH1HP

$EDC/kura/CLIENT_JJJAODSAPV7AHI3UG1CO0EH1HP/CONF-V1/REPLY/REQUEST_EAGIGLBGK817NDH7C86QONJE76