1 files changed, 127 insertions, 0 deletions
diff --git a/src/main/java/org/openecomp/rest/RestClientEndpoint.java b/src/main/java/org/openecomp/rest/RestClientEndpoint.java
new file mode 100644
index 0000000..1b59704
--- /dev/null
+++ b/src/main/java/org/openecomp/rest/RestClientEndpoint.java
@@ -0,0 +1,127 @@
+/**
+ * ============LICENSE_START=======================================================
+ * DataRouter
+ * ================================================================================
+ * Copyright © 2017 AT&T Intellectual Property.
+ * Copyright © 2017 Amdocs
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License ati
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ *
+ * ECOMP and OpenECOMP are trademarks
+ * and service marks of AT&T Intellectual Property.
+ */
+package org.openecomp.rest;
+
+import org.apache.camel.Consumer;
+import org.apache.camel.Processor;
+import org.apache.camel.Producer;
+import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
+import org.apache.camel.spi.UriEndpoint;
+import org.apache.camel.spi.UriParam;
+import org.apache.camel.spi.UriPath;
+
+import java.util.Map;
+
+
+/**
+ * Represents a RestClient endpoint.
+ */
+@UriEndpoint(scheme = "ecomp-rest", syntax = "ecomp-rest:op",
+    consumerClass = RestClientConsumer.class, label = "RestClient2", title = "")
+public class RestClientEndpoint extends DefaultEndpoint {
+
+  public static final String CONTEXT_PARAM_CLIENT_CERT = "ecomp-client-cert";
+  public static final String CONTEXT_PARAM_KEYSTORE = "ecomp-keystore";
+  public static final String CONTEXT_PARAM_KEYSTORE_PWD = "ecomp-keystore-password";
+
+  public static final String IN_HEADER_URL = "ecomp-url";
+
+  public static final String OUT_HEADER_RESPONSE_CODE = "ecomp-response-code";
+  public static final String OUT_HEADER_RESPONSE_MSG = "ecomp-response-message";
+
+  @UriPath
+  @Metadata(required = "true")
+  private String op;
+
+  @UriParam
+  private String ecompClientCert;
+
+  @UriParam
+  private String ecompKeystore;
+
+  @UriParam
+  private String ecompKeystorePassword;
+
+
+  public RestClientEndpoint() {}
+
+  public RestClientEndpoint(String uri, RestClientComponent component) {
+    super(uri, component);
+  }
+
+  public RestClientEndpoint(String endpointUri) {
+    super(endpointUri);
+  }
+
+  @Override
+  protected void setProperties(Object bean, Map<String, Object> parameters) throws Exception {
+    super.setProperties(bean, parameters);
+  }
+
+  public Producer createProducer() throws Exception {
+    return new RestClientProducer(this);
+  }
+
+  public Consumer createConsumer(Processor processor) throws Exception {
+    return new RestClientConsumer(this, processor);
+  }
+
+  public boolean isSingleton() {
+    return true;
+  }
+
+  public String getOp() {
+    return op;
+  }
+
+  public void setOp(String op) {
+    this.op = op;
+  }
+
+  public String getEcompClientCert() {
+    return ecompClientCert;
+  }
+
+  public void setEcompClientCert(String ecompClientCert) {
+    this.ecompClientCert = ecompClientCert;
+  }
+
+  public String getEcompKeystore() {
+    return ecompKeystore;
+  }
+
+  public void setEcompKeystore(String ecompKeystore) {
+    this.ecompKeystore = ecompKeystore;
+  }
+
+  public String getEcompKeystorePassword() {
+    return ecompKeystorePassword;
+  }
+
+  public void setEcompKeystorePassword(String ecompKeystorePassword) {
+    this.ecompKeystorePassword = ecompKeystorePassword;
+  }
+}