code: @Override
      protected Endpoint createEndpoint(String uri, String remain, Map<String, Object> parameters) throws Exception {
          KuraCloudEndpoint kuraCloudEndpoint = new KuraCloudEndpoint(uri, this, cloudService);
  
          String[] res = remain.split("/");
          if (res.length != 2) {
              throw new IllegalArgumentException("Wrong kura-cloud URI format. Should be: kura-cloud:app/topic");
          }
          parameters.put(KuraCloudConstants.APPLICATION_ID, res[0]);
          parameters.put(KuraCloudConstants.TOPIC, res[1]);
  
          setProperties(kuraCloudEndpoint, parameters);
  
          return kuraCloudEndpoint;
      }
docs: Operations