Relationship Type and Templates models

Enrichment Support for Relationship Types and Templates.

Relationship DSL support for ConnectTo connections ( RestClient, SshClient, MessageProducer, MessageConsume, Nats)

Moved datatype map from collection to complex type

Issue-ID: CCSDK-1054
Signed-off-by: Brinda Santh <bs2796@att.com>
Change-Id: I0f18db2cb52e1e93dfab04498b8298587cba2540

28 files changed, 1398 insertions, 191 deletions

diff --git a/ms/blueprintsprocessor/functions/resource-resolution/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/resource/resolution/utils/ResourceAssignmentUtilsTest.kt b/ms/blueprintsprocessor/functions/resource-resolution/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/resource/resolution/utils/ResourceAssignmentUtilsTest.kt
index a358f6a23..3c0af04ff 100644
--- a/ms/blueprintsprocessor/functions/resource-resolution/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/resource/resolution/utils/ResourceAssignmentUtilsTest.kt
+++ b/ms/blueprintsprocessor/functions/resource-resolution/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/functions/resource/resolution/utils/ResourceAssignmentUtilsTest.kt
@@ -204,16 +204,16 @@ class ResourceAssignmentUtilsTest {
             outcome,
             "unexpected outcome returned for list of String"
         )
-
-        outcome = prepareResponseNodeForTest(
-            "mapOfString", "map", "string",
-            inputMapToTestCollectionOfPrimitiveType
-        )
-        assertEquals(
-            expectedValueToTesCollectionOfPrimitiveType,
-            outcome,
-            "unexpected outcome returned for map of String"
-        )
+        // FIXME("Map is not collection type, It is known complex type")
+        // outcome = prepareResponseNodeForTest(
+        //     "mapOfString", "map", "string",
+        //     inputMapToTestCollectionOfPrimitiveType
+        // )
+        // assertEquals(
+        //     expectedValueToTesCollectionOfPrimitiveType,
+        //     outcome,
+        //     "unexpected outcome returned for map of String"
+        // )
     }
 
     @Test
@@ -360,7 +360,7 @@ class ResourceAssignmentUtilsTest {
     ): JsonNode {
 
         val resourceAssignment = when (sourceType) {
-            "list", "map" -> {
+            "list" -> {
                 prepareRADataDictionaryCollection(dictionary_source, sourceType, entrySchema)
             }
             "string" -> {
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/BluePrintConstants.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/BluePrintConstants.kt
index 5aaf6ccd9..f0e2c5b03 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/BluePrintConstants.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/BluePrintConstants.kt
@@ -111,6 +111,15 @@ object BluePrintConstants {
     const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO = "tosca.relationships.ConnectsTo"
     const val MODEL_TYPE_RELATIONSHIPS_ATTACH_TO = "tosca.relationships.AttachesTo"
     const val MODEL_TYPE_RELATIONSHIPS_ROUTES_TO = "tosca.relationships.RoutesTo"
+    // CDS Defined Relationship Types
+    const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_DB = "tosca.relationships.ConnectsTo.Db"
+    const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_REST_CLIENT = "tosca.relationships.ConnectsTo.RestClient"
+    const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_SSH_CLIENT = "tosca.relationships.ConnectsTo.SshClient"
+    const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_MESSAGE_PRODUCER = "tosca.relationships.ConnectsTo.MessageProducer"
+    const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_MESSAGE_CONSUMER = "tosca.relationships.ConnectsTo.MessageConsumer"
+    const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_GRPC_SERVER = "tosca.relationships.ConnectsTo.GrpcServer"
+    const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_GRPC_CLIENT = "tosca.relationships.ConnectsTo.GrpcClient"
+    const val MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_NATS = "tosca.relationships.ConnectsTo.Nats"
 
     const val MODEL_TYPE_NODE_WORKFLOW = "tosca.nodes.Workflow"
     const val MODEL_TYPE_NODE_COMPONENT = "tosca.nodes.Component"
@@ -200,6 +209,7 @@ object BluePrintConstants {
     const val PROPERTY_CURRENT_TIMEOUT = "current-timeout"
     const val PROPERTY_CURRENT_IMPLEMENTATION = "current-implementation"
     const val PROPERTY_EXECUTION_REQUEST = "execution-request"
+    const val PROPERTY_CONNECTION_CONFIG = "connection-config"
 
     const val DEFAULT_VERSION_NUMBER = "1.0.0"
     const val DEFAULT_STEP_OPERATION = "process"
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/BluePrintTypes.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/BluePrintTypes.kt
index 0e4279a3a..6deb6bc87 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/BluePrintTypes.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/BluePrintTypes.kt
@@ -121,6 +121,7 @@ object BluePrintTypes {
     fun validComplexTypes(): List<String> {
         val validTypes: MutableList<String> = arrayListOf()
         validTypes.add(BluePrintConstants.DATA_TYPE_JSON)
+        validTypes.add(BluePrintConstants.DATA_TYPE_MAP)
         return validTypes
     }
 
@@ -128,7 +129,6 @@ object BluePrintTypes {
     fun validCollectionTypes(): List<String> {
         val validTypes: MutableList<String> = arrayListOf()
         validTypes.add(BluePrintConstants.DATA_TYPE_LIST)
-        validTypes.add(BluePrintConstants.DATA_TYPE_MAP)
         return validTypes
     }
 
@@ -136,7 +136,7 @@ object BluePrintTypes {
     fun validPrimitiveOrCollectionPrimitive(propertyDefinition: PropertyDefinition): Boolean {
         val entrySchema = propertyDefinition.entrySchema?.type ?: BluePrintConstants.DATA_TYPE_NULL
         return BluePrintTypes.validPropertyTypes().contains(propertyDefinition.type) &&
-                BluePrintTypes.validPrimitiveTypes().contains(entrySchema)
+            BluePrintTypes.validPrimitiveTypes().contains(entrySchema)
     }
 
     @JvmStatic
@@ -158,6 +158,11 @@ object BluePrintTypes {
     }
 
     @JvmStatic
+    fun rootRelationshipTypes(): List<String> {
+        return listOf(BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_ROOT)
+    }
+
+    @JvmStatic
     fun rootDataTypes(): List<String> {
         return listOf(BluePrintConstants.MODEL_TYPE_DATATYPES_ROOT)
     }
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/data/BluePrintModel.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/data/BluePrintModel.kt
index 67a062347..e0333997d 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/data/BluePrintModel.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/data/BluePrintModel.kt
@@ -562,10 +562,12 @@ A Relationship Template specifies the occurrence of a manageable relationship be
  */
 
 class RelationshipTemplate {
-    var type: String? = null
+    @get:JsonIgnore
+    var id: String? = null
+    lateinit var type: String
     var description: String? = null
     var metadata: MutableMap<String, String>? = null
-    var properties: MutableMap<String, PropertyDefinition>? = null
+    var properties: MutableMap<String, JsonNode>? = null
     var attributes: MutableMap<String, JsonNode>? = null
     var interfaces: MutableMap<String, InterfaceDefinition>? = null
     var copy: String? = null
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintDSL.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintDSL.kt
index 9964687a6..c23e495fb 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintDSL.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintDSL.kt
@@ -166,7 +166,8 @@ fun getNodeTemplateOperationOutput(
     propertyId: String,
     jsonPath: String? = null
 ): JsonNode {
-    return """{"get_operation_output": ["$nodeTemplateName", "$interfaceName", "process","$propertyId","$jsonPath" ]}""".trimMargin().jsonAsJsonType()
+    return """{"get_operation_output": ["$nodeTemplateName", "$interfaceName", "process","$propertyId","$jsonPath" ]}""".trimMargin()
+        .jsonAsJsonType()
 }
 
 /** Blueprint Type Extensions */
@@ -246,6 +247,7 @@ fun BluePrintTypes.artifactTypeMappingResource(): ArtifactType {
     }
 }
 
+@Deprecated("CDS won't support", replaceWith = ReplaceWith("artifactTypeScriptKotlin"))
 fun BluePrintTypes.artifactTypeScriptJython(): ArtifactType {
     return artifactType(
         id = BluePrintConstants.MODEL_TYPE_ARTIFACT_SCRIPT_JYTHON,
@@ -268,6 +270,7 @@ fun BluePrintTypes.artifactTypeScriptKotlin(): ArtifactType {
     }
 }
 
+@Deprecated("CDS won't support, use implerative workflow definitions.")
 fun BluePrintTypes.artifactTypeDirectedGraph(): ArtifactType {
     return artifactType(
         id = BluePrintConstants.MODEL_TYPE_ARTIFACT_DIRECTED_GRAPH,
@@ -299,6 +302,7 @@ fun BluePrintTypes.relationshipTypeConnectsTo(): RelationshipType {
         derivedFrom = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_ROOT,
         description = "Relationship connects to"
     ) {
+        validTargetTypes(arrayListOf(BluePrintConstants.MODEL_TYPE_CAPABILITY_TYPE_ENDPOINT))
     }
 }
 
@@ -311,3 +315,13 @@ fun BluePrintTypes.relationshipTypeDependsOn(): RelationshipType {
     ) {
     }
 }
+
+fun BluePrintTypes.relationshipTypeHostedOn(): RelationshipType {
+    return relationshipType(
+        id = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_HOSTED_ON,
+        version = BluePrintConstants.DEFAULT_VERSION_NUMBER,
+        derivedFrom = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_ROOT,
+        description = "Relationship hosted on"
+    ) {
+    }
+}
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintServiceDSLBuilder.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintServiceDSLBuilder.kt
index ca4d56338..a3db88b6a 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintServiceDSLBuilder.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintServiceDSLBuilder.kt
@@ -81,77 +81,80 @@ class BluePrintServiceDSLBuilder(
     }
 
     fun dsl(id: String, json: JsonNode) {
-        if (dslDefinitions == null)
-            dslDefinitions = hashMapOf()
+        if (dslDefinitions == null) dslDefinitions = hashMapOf()
         dslDefinitions!![id] = json
     }
 
     fun dataTypes(dataTypes: MutableMap<String, DataType>) {
-        if (this.dataTypes == null)
-            this.dataTypes = hashMapOf()
+        if (this.dataTypes == null) this.dataTypes = hashMapOf()
 
         this.dataTypes!!.putAll(dataTypes)
     }
 
     fun artifactTypes(artifactTypes: MutableMap<String, ArtifactType>) {
-        if (this.artifactTypes == null)
-            this.artifactTypes = hashMapOf()
+        if (this.artifactTypes == null) this.artifactTypes = hashMapOf()
 
         this.artifactTypes!!.putAll(artifactTypes)
     }
 
     fun relationshipTypes(relationshipTypes: MutableMap<String, RelationshipType>) {
-        if (this.relationshipTypes == null)
-            this.relationshipTypes = hashMapOf()
+        if (this.relationshipTypes == null) this.relationshipTypes = hashMapOf()
 
         this.relationshipTypes!!.putAll(relationshipTypes)
     }
 
     fun policyTypes(policyTypes: MutableMap<String, PolicyType>) {
-        if (this.policyTypes == null)
-            this.policyTypes = hashMapOf()
+        if (this.policyTypes == null) this.policyTypes = hashMapOf()
 
         this.policyTypes!!.putAll(policyTypes)
     }
 
     fun nodeType(nodeTypes: MutableMap<String, NodeType>) {
-        if (this.nodeTypes == null)
-            this.nodeTypes = hashMapOf()
+        if (this.nodeTypes == null) this.nodeTypes = hashMapOf()
 
         this.nodeTypes!!.putAll(nodeTypes)
     }
 
     fun dataType(dataType: DataType) {
-        if (dataTypes == null)
-            dataTypes = hashMapOf()
+        if (dataTypes == null) dataTypes = hashMapOf()
         dataTypes!![dataType.id!!] = dataType
     }
 
     fun artifactType(artifactType: ArtifactType) {
-        if (artifactTypes == null)
-            artifactTypes = hashMapOf()
+        if (artifactTypes == null) artifactTypes = hashMapOf()
         artifactTypes!![artifactType.id!!] = artifactType
     }
 
     fun relationshipType(relationshipType: RelationshipType) {
-        if (relationshipTypes == null)
-            relationshipTypes = hashMapOf()
+        if (relationshipTypes == null) relationshipTypes = hashMapOf()
         relationshipTypes!![relationshipType.id!!] = relationshipType
     }
 
+    fun relationshipTypes(relationshipTypes: List<RelationshipType>) {
+        if (this.relationshipTypes == null) this.relationshipTypes = hashMapOf()
+        relationshipTypes.forEach { relationshipType ->
+            this.relationshipTypes!![relationshipType.id!!] = relationshipType
+        }
+    }
+
     fun policyType(policyType: PolicyType) {
-        if (policyTypes == null)
-            policyTypes = hashMapOf()
+        if (policyTypes == null) policyTypes = hashMapOf()
 
         policyTypes!![policyType.id!!] = policyType
     }
 
     fun nodeType(nodeType: NodeType) {
-        if (nodeTypes == null)
-            nodeTypes = hashMapOf()
+        if (nodeTypes == null) nodeTypes = hashMapOf()
         nodeTypes!![nodeType.id!!] = nodeType
     }
 
+    fun nodeTypes(nodeTypes: List<NodeType>) {
+        if (this.nodeTypes == null) this.nodeTypes = hashMapOf()
+        nodeTypes.forEach { nodeType ->
+            this.nodeTypes!![nodeType.id!!] = nodeType
+        }
+    }
+
     fun dataType(
         id: String,
         version: String,
@@ -159,8 +162,7 @@ class BluePrintServiceDSLBuilder(
         description: String,
         block: DataTypeBuilder.() -> Unit
     ) {
-        if (dataTypes == null)
-            dataTypes = hashMapOf()
+        if (dataTypes == null) dataTypes = hashMapOf()
         dataTypes!![id] = DataTypeBuilder(id, version, derivedFrom, description).apply(block).build()
     }
 
@@ -171,8 +173,7 @@ class BluePrintServiceDSLBuilder(
         description: String,
         block: ArtifactTypeBuilder.() -> Unit
     ) {
-        if (artifactTypes == null)
-            artifactTypes = hashMapOf()
+        if (artifactTypes == null) artifactTypes = hashMapOf()
         artifactTypes!![id] = ArtifactTypeBuilder(id, version, derivedFrom, description).apply(block).build()
     }
 
@@ -183,8 +184,7 @@ class BluePrintServiceDSLBuilder(
         description: String,
         block: RelationshipTypeBuilder.() -> Unit
     ) {
-        if (relationshipTypes == null)
-            relationshipTypes = hashMapOf()
+        if (relationshipTypes == null) relationshipTypes = hashMapOf()
         relationshipTypes!![id] = RelationshipTypeBuilder(id, version, derivedFrom, description).apply(block).build()
     }
 
@@ -195,8 +195,7 @@ class BluePrintServiceDSLBuilder(
         description: String,
         block: PolicyTypeBuilder.() -> Unit
     ) {
-        if (policyTypes == null)
-            policyTypes = hashMapOf()
+        if (policyTypes == null) policyTypes = hashMapOf()
         policyTypes!![id] = PolicyTypeBuilder(id, version, derivedFrom, description).apply(block).build()
     }
 
@@ -207,8 +206,7 @@ class BluePrintServiceDSLBuilder(
         description: String,
         block: NodeTypeBuilder.() -> Unit
     ) {
-        if (nodeTypes == null)
-            nodeTypes = hashMapOf()
+        if (nodeTypes == null) nodeTypes = hashMapOf()
         nodeTypes!![id] = NodeTypeBuilder(id, version, derivedFrom, description).apply(block).build()
     }
 
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintTemplateDSLBuilder.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintTemplateDSLBuilder.kt
index df4d2d849..216a0d16f 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintTemplateDSLBuilder.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintTemplateDSLBuilder.kt
@@ -25,40 +25,55 @@ import org.onap.ccsdk.cds.controllerblueprints.core.data.Implementation
 import org.onap.ccsdk.cds.controllerblueprints.core.data.InterfaceAssignment
 import org.onap.ccsdk.cds.controllerblueprints.core.data.NodeTemplate
 import org.onap.ccsdk.cds.controllerblueprints.core.data.OperationAssignment
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipTemplate
 import org.onap.ccsdk.cds.controllerblueprints.core.data.RequirementAssignment
 import org.onap.ccsdk.cds.controllerblueprints.core.data.TopologyTemplate
 import org.onap.ccsdk.cds.controllerblueprints.core.data.Workflow
 import kotlin.reflect.KClass
+import kotlin.reflect.KMutableProperty1
 import kotlin.reflect.full.createInstance
 import kotlin.reflect.jvm.reflect
 
-class TopologyTemplateBuilder {
+open class TopologyTemplateBuilder {
     private var topologyTemplate = TopologyTemplate()
     private var nodeTemplates: MutableMap<String, NodeTemplate>? = null
+    var relationshipTemplates: MutableMap<String, RelationshipTemplate>? = null
     private var workflows: MutableMap<String, Workflow>? = null
 
     fun nodeTemplate(id: String, type: String, description: String, block: NodeTemplateBuilder.() -> Unit) {
-        if (nodeTemplates == null)
-            nodeTemplates = hashMapOf()
+        if (nodeTemplates == null) nodeTemplates = hashMapOf()
         nodeTemplates!![id] = NodeTemplateBuilder(id, type, description).apply(block).build()
     }
 
     fun nodeTemplate(nodeTemplate: NodeTemplate) {
-        if (nodeTemplates == null)
-            nodeTemplates = hashMapOf()
+        if (nodeTemplates == null) nodeTemplates = hashMapOf()
         nodeTemplates!![nodeTemplate.id!!] = nodeTemplate
     }
 
+    fun relationshipTemplate(
+        id: String,
+        type: String,
+        description: String,
+        block: RelationshipTemplateBuilder.() -> Unit
+    ) {
+        if (relationshipTemplates == null) relationshipTemplates = hashMapOf()
+        relationshipTemplates!![id] = RelationshipTemplateBuilder(id, type, description).apply(block).build()
+    }
+
+    fun relationshipTemplate(relationshipTemplate: RelationshipTemplate) {
+        if (relationshipTemplates == null) relationshipTemplates = hashMapOf()
+        relationshipTemplates!![relationshipTemplate.id!!] = relationshipTemplate
+    }
+
     fun nodeTemplateOperation(
         nodeTemplateName: String,
         type: String,
         interfaceName: String,
         description: String,
         operationBlock: OperationAssignmentBuilder<PropertiesAssignmentBuilder,
-                PropertiesAssignmentBuilder>.() -> Unit
+            PropertiesAssignmentBuilder>.() -> Unit
     ) {
-        if (nodeTemplates == null)
-            nodeTemplates = hashMapOf()
+        if (nodeTemplates == null) nodeTemplates = hashMapOf()
 
         val nodeTemplateBuilder = NodeTemplateBuilder(nodeTemplateName, type, description)
         nodeTemplateBuilder.operation(interfaceName, "$description operation", operationBlock)
@@ -66,14 +81,12 @@ class TopologyTemplateBuilder {
     }
 
     fun workflow(id: String, description: String, block: WorkflowBuilder.() -> Unit) {
-        if (workflows == null)
-            workflows = hashMapOf()
+        if (workflows == null) workflows = hashMapOf()
         workflows!![id] = WorkflowBuilder(id, description).apply(block).build()
     }
 
     fun workflow(workflow: Workflow) {
-        if (workflows == null)
-            workflows = hashMapOf()
+        if (workflows == null) workflows = hashMapOf()
         workflows!![workflow.id!!] = workflow
     }
 
@@ -84,22 +97,22 @@ class TopologyTemplateBuilder {
         description: String,
         block: NodeTemplateBuilder.() -> Unit
     ) {
-        if (nodeTemplates == null)
-            nodeTemplates = hashMapOf()
+        if (nodeTemplates == null) nodeTemplates = hashMapOf()
 
-        if (workflows == null)
-            workflows = hashMapOf()
+        if (workflows == null) workflows = hashMapOf()
 
         val workflowBuilder = WorkflowBuilder(actionName, description)
         workflowBuilder.nodeTemplateStep(actionName, description)
         // Workflow name is NodeTemplate name
         workflows!![actionName] = workflowBuilder.build()
 
-        nodeTemplates!![actionName] = NodeTemplateBuilder(actionName, nodeTemplateType, description).apply(block).build()
+        nodeTemplates!![actionName] =
+            NodeTemplateBuilder(actionName, nodeTemplateType, description).apply(block).build()
     }
 
     fun build(): TopologyTemplate {
         topologyTemplate.nodeTemplates = nodeTemplates
+        topologyTemplate.relationshipTemplates = relationshipTemplates
         topologyTemplate.workflows = workflows
         return topologyTemplate
     }
@@ -111,26 +124,25 @@ open class NodeTemplateBuilder(
     private val description: String? = ""
 ) {
 
-    private var nodeTemplate: NodeTemplate = NodeTemplate()
-    private var properties: MutableMap<String, JsonNode>? = null
-    private var interfaces: MutableMap<String, InterfaceAssignment>? = null
-    private var artifacts: MutableMap<String, ArtifactDefinition>? = null
-    private var capabilities: MutableMap<String, CapabilityAssignment>? = null
-    private var requirements: MutableMap<String, RequirementAssignment>? = null
+    var nodeTemplate: NodeTemplate = NodeTemplate()
+    var properties: MutableMap<String, JsonNode>? = null
+    var interfaces: MutableMap<String, InterfaceAssignment>? = null
+    var artifacts: MutableMap<String, ArtifactDefinition>? = null
+    var capabilities: MutableMap<String, CapabilityAssignment>? = null
+    var requirements: MutableMap<String, RequirementAssignment>? = null
 
-    fun properties(properties: MutableMap<String, JsonNode>?) {
-        this.properties = properties
+    fun properties(properties: Map<String, JsonNode>) {
+        if (this.properties == null) this.properties = hashMapOf()
+        this.properties!!.putAll(properties)
     }
 
     fun properties(block: PropertiesAssignmentBuilder.() -> Unit) {
-        if (properties == null)
-            properties = hashMapOf()
+        if (properties == null) properties = hashMapOf()
         properties = PropertiesAssignmentBuilder().apply(block).build()
     }
 
     open fun <Prop : PropertiesAssignmentBuilder> typedProperties(block: Prop.() -> Unit) {
-        if (properties == null)
-            properties = hashMapOf()
+        if (properties == null) properties = hashMapOf()
         val instance: Prop = (block.reflect()?.parameters?.get(0)?.type?.classifier as KClass<Prop>).createInstance()
         properties = instance.apply(block).build()
     }
@@ -140,8 +152,7 @@ open class NodeTemplateBuilder(
         description: String = "",
         block: OperationAssignmentBuilder<In, Out>.() -> Unit
     ) {
-        if (interfaces == null)
-            interfaces = hashMapOf()
+        if (interfaces == null) interfaces = hashMapOf()
 
         val interfaceAssignment = InterfaceAssignment()
         val defaultOperationName = BluePrintConstants.DEFAULT_STEP_OPERATION
@@ -160,14 +171,12 @@ open class NodeTemplateBuilder(
     }
 
     fun artifact(id: String, type: String, file: String) {
-        if (artifacts == null)
-            artifacts = hashMapOf()
+        if (artifacts == null) artifacts = hashMapOf()
         artifacts!![id] = ArtifactDefinitionBuilder(id, type, file).build()
     }
 
     fun artifact(id: String, type: String, file: String, block: ArtifactDefinitionBuilder.() -> Unit) {
-        if (artifacts == null)
-            artifacts = hashMapOf()
+        if (artifacts == null) artifacts = hashMapOf()
         artifacts!![id] = ArtifactDefinitionBuilder(id, type, file).apply(block).build()
     }
 
@@ -176,26 +185,26 @@ open class NodeTemplateBuilder(
     }
 
     fun capability(id: String, block: CapabilityAssignmentBuilder.() -> Unit) {
-        if (capabilities == null)
-            capabilities = hashMapOf()
+        if (capabilities == null) capabilities = hashMapOf()
         capabilities!![id] = CapabilityAssignmentBuilder(id).apply(block).build()
     }
 
-    fun capabilities(capabilities: MutableMap<String, CapabilityAssignment>?) {
-        this.capabilities = capabilities
+    fun capabilities(capabilities: MutableMap<String, CapabilityAssignment>) {
+        if (this.capabilities == null) this.capabilities = hashMapOf()
+        this.capabilities!!.putAll(capabilities)
     }
 
     fun requirement(id: String, capability: String, node: String, relationship: String) {
-        if (requirements == null)
-            requirements = hashMapOf()
+        if (requirements == null) requirements = hashMapOf()
         requirements!![id] = RequirementAssignmentBuilder(id, capability, node, relationship).build()
     }
 
-    fun requirements(requirements: MutableMap<String, RequirementAssignment>?) {
-        this.requirements = requirements
+    fun requirements(requirements: MutableMap<String, RequirementAssignment>) {
+        if (this.requirements == null) this.requirements = hashMapOf()
+        this.requirements!!.putAll(requirements)
     }
 
-    fun build(): NodeTemplate {
+    open fun build(): NodeTemplate {
         nodeTemplate.id = id
         nodeTemplate.type = type
         nodeTemplate.description = description
@@ -208,6 +217,53 @@ open class NodeTemplateBuilder(
     }
 }
 
+open class RelationshipTemplateBuilder(
+    private val id: String,
+    private val type: String,
+    private val description: String? = ""
+) {
+    var relationshipTemplate: RelationshipTemplate = RelationshipTemplate()
+    var properties: MutableMap<String, JsonNode>? = null
+
+    fun properties(properties: Map<String, JsonNode>) {
+        if (this.properties == null) this.properties = hashMapOf()
+        this.properties!!.putAll(properties)
+    }
+
+    fun properties(block: PropertiesAssignmentBuilder.() -> Unit) {
+        if (properties == null) properties = hashMapOf()
+        properties = PropertiesAssignmentBuilder().apply(block).build()
+    }
+
+    fun property(id: String, value: Any) {
+        if (properties == null) properties = hashMapOf()
+        properties!![id] = value.asJsonType()
+    }
+
+    fun property(id: String, value: JsonNode) {
+        if (properties == null) properties = hashMapOf()
+        properties!![id] = value
+    }
+
+    fun copy(copy: String) {
+        relationshipTemplate.copy = copy
+    }
+
+    open fun <Prop : PropertiesAssignmentBuilder> typedProperties(block: Prop.() -> Unit) {
+        if (properties == null) properties = hashMapOf()
+        val instance: Prop = (block.reflect()?.parameters?.get(0)?.type?.classifier as KClass<Prop>).createInstance()
+        properties = instance.apply(block).build()
+    }
+
+    open fun build(): RelationshipTemplate {
+        relationshipTemplate.id = id
+        relationshipTemplate.type = type
+        relationshipTemplate.description = description
+        relationshipTemplate.properties = properties
+        return relationshipTemplate
+    }
+}
+
 class ArtifactDefinitionBuilder(private val id: String, private val type: String, private val file: String) {
 
     private var artifactDefinition: ArtifactDefinition = ArtifactDefinition()
@@ -242,18 +298,26 @@ open class CapabilityAssignmentBuilder(private val id: String) {
     var properties: MutableMap<String, JsonNode>? = null
 
     fun attributes(block: AttributesAssignmentBuilder.() -> Unit) {
-        if (attributes == null)
-            attributes = hashMapOf()
+        if (attributes == null) attributes = hashMapOf()
         attributes = AttributesAssignmentBuilder().apply(block).build()
     }
 
     fun properties(block: PropertiesAssignmentBuilder.() -> Unit) {
-        if (properties == null)
-            properties = hashMapOf()
+        if (properties == null) properties = hashMapOf()
         properties = PropertiesAssignmentBuilder().apply(block).build()
     }
 
-    fun build(): CapabilityAssignment {
+    fun property(id: String, value: Any) {
+        if (properties == null) properties = hashMapOf()
+        properties!![id] = value.asJsonType()
+    }
+
+    fun property(id: String, value: JsonNode) {
+        if (properties == null) properties = hashMapOf()
+        properties!![id] = value
+    }
+
+    open fun build(): CapabilityAssignment {
         capabilityAssignment.properties = properties
         capabilityAssignment.attributes = attributes
         return capabilityAssignment
@@ -386,6 +450,10 @@ open class PropertiesAssignmentBuilder {
         properties[id] = value
     }
 
+    fun property(kProperty: KMutableProperty1<*, *>, value: JsonNode) {
+        properties[kProperty.name] = value
+    }
+
     open fun build(): MutableMap<String, JsonNode> {
         return properties
     }
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/interfaces/BluePrintEnhancer.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/interfaces/BluePrintEnhancer.kt
index 80c91ca28..535021b34 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/interfaces/BluePrintEnhancer.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/interfaces/BluePrintEnhancer.kt
@@ -24,6 +24,8 @@ import org.onap.ccsdk.cds.controllerblueprints.core.data.NodeTemplate
 import org.onap.ccsdk.cds.controllerblueprints.core.data.NodeType
 import org.onap.ccsdk.cds.controllerblueprints.core.data.PolicyType
 import org.onap.ccsdk.cds.controllerblueprints.core.data.PropertyDefinition
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipTemplate
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipType
 import org.onap.ccsdk.cds.controllerblueprints.core.data.ServiceTemplate
 import org.onap.ccsdk.cds.controllerblueprints.core.data.TopologyTemplate
 import org.onap.ccsdk.cds.controllerblueprints.core.data.Workflow
@@ -44,6 +46,10 @@ interface BluePrintNodeTemplateEnhancer : BluePrintEnhancer<NodeTemplate>
 
 interface BluePrintNodeTypeEnhancer : BluePrintEnhancer<NodeType>
 
+interface BluePrintRelationshipTemplateEnhancer : BluePrintEnhancer<RelationshipTemplate>
+
+interface BluePrintRelationshipTypeEnhancer : BluePrintEnhancer<RelationshipType>
+
 interface BluePrintArtifactDefinitionEnhancer : BluePrintEnhancer<ArtifactDefinition>
 
 interface BluePrintPolicyTypeEnhancer : BluePrintEnhancer<PolicyType>
@@ -73,6 +79,10 @@ interface BluePrintTypeEnhancerService {
 
     fun getNodeTypeEnhancers(): List<BluePrintNodeTypeEnhancer>
 
+    fun getRelationshipTemplateEnhancers(): List<BluePrintRelationshipTemplateEnhancer>
+
+    fun getRelationshipTypeEnhancers(): List<BluePrintRelationshipTypeEnhancer>
+
     fun getArtifactDefinitionEnhancers(): List<BluePrintArtifactDefinitionEnhancer>
 
     fun getPolicyTypeEnhancers(): List<BluePrintPolicyTypeEnhancer>
@@ -81,12 +91,20 @@ interface BluePrintTypeEnhancerService {
 
     fun getAttributeDefinitionEnhancers(): List<BluePrintAttributeDefinitionEnhancer>
 
-    fun enhanceServiceTemplate(bluePrintRuntimeService: BluePrintRuntimeService<*>, name: String, serviceTemplate: ServiceTemplate) {
+    fun enhanceServiceTemplate(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        serviceTemplate: ServiceTemplate
+    ) {
         val enhancers = getServiceTemplateEnhancers()
         doEnhancement(bluePrintRuntimeService, name, serviceTemplate, enhancers)
     }
 
-    fun enhanceTopologyTemplate(bluePrintRuntimeService: BluePrintRuntimeService<*>, name: String, topologyTemplate: TopologyTemplate) {
+    fun enhanceTopologyTemplate(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        topologyTemplate: TopologyTemplate
+    ) {
         val enhancers = getTopologyTemplateEnhancers()
         doEnhancement(bluePrintRuntimeService, name, topologyTemplate, enhancers)
     }
@@ -96,7 +114,11 @@ interface BluePrintTypeEnhancerService {
         doEnhancement(bluePrintRuntimeService, name, workflow, enhancers)
     }
 
-    fun enhanceNodeTemplate(bluePrintRuntimeService: BluePrintRuntimeService<*>, name: String, nodeTemplate: NodeTemplate) {
+    fun enhanceNodeTemplate(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        nodeTemplate: NodeTemplate
+    ) {
         val enhancers = getNodeTemplateEnhancers()
         doEnhancement(bluePrintRuntimeService, name, nodeTemplate, enhancers)
     }
@@ -106,7 +128,29 @@ interface BluePrintTypeEnhancerService {
         doEnhancement(bluePrintRuntimeService, name, nodeType, enhancers)
     }
 
-    fun enhanceArtifactDefinition(bluePrintRuntimeService: BluePrintRuntimeService<*>, name: String, artifactDefinition: ArtifactDefinition) {
+    fun enhanceRelationshipTemplate(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        relationshipTemplate: RelationshipTemplate
+    ) {
+        val enhancers = getRelationshipTemplateEnhancers()
+        doEnhancement(bluePrintRuntimeService, name, relationshipTemplate, enhancers)
+    }
+
+    fun enhanceRelationshipType(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        relationshipType: RelationshipType
+    ) {
+        val enhancers = getRelationshipTypeEnhancers()
+        doEnhancement(bluePrintRuntimeService, name, relationshipType, enhancers)
+    }
+
+    fun enhanceArtifactDefinition(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        artifactDefinition: ArtifactDefinition
+    ) {
         val enhancers = getArtifactDefinitionEnhancers()
         doEnhancement(bluePrintRuntimeService, name, artifactDefinition, enhancers)
     }
@@ -116,24 +160,38 @@ interface BluePrintTypeEnhancerService {
         doEnhancement(bluePrintRuntimeService, name, policyType, enhancers)
     }
 
-    fun enhancePropertyDefinitions(bluePrintRuntimeService: BluePrintRuntimeService<*>, properties: MutableMap<String, PropertyDefinition>) {
+    fun enhancePropertyDefinitions(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        properties: MutableMap<String, PropertyDefinition>
+    ) {
         properties.forEach { propertyName, propertyDefinition ->
             enhancePropertyDefinition(bluePrintRuntimeService, propertyName, propertyDefinition)
         }
     }
 
-    fun enhancePropertyDefinition(bluePrintRuntimeService: BluePrintRuntimeService<*>, name: String, propertyDefinition: PropertyDefinition) {
+    fun enhancePropertyDefinition(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        propertyDefinition: PropertyDefinition
+    ) {
         val enhancers = getPropertyDefinitionEnhancers()
         doEnhancement(bluePrintRuntimeService, name, propertyDefinition, enhancers)
     }
 
-    fun enhanceAttributeDefinitions(bluePrintRuntimeService: BluePrintRuntimeService<*>, attributes: MutableMap<String, AttributeDefinition>) {
+    fun enhanceAttributeDefinitions(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        attributes: MutableMap<String, AttributeDefinition>
+    ) {
         attributes.forEach { attributeName, attributeDefinition ->
             enhanceAttributeDefinition(bluePrintRuntimeService, attributeName, attributeDefinition)
         }
     }
 
-    fun enhanceAttributeDefinition(bluePrintRuntimeService: BluePrintRuntimeService<*>, name: String, attributeDefinition: AttributeDefinition) {
+    fun enhanceAttributeDefinition(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        attributeDefinition: AttributeDefinition
+    ) {
         val enhancers = getAttributeDefinitionEnhancers()
         doEnhancement(bluePrintRuntimeService, name, attributeDefinition, enhancers)
     }
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/service/BluePrintContext.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/service/BluePrintContext.kt
index 47cd62ea1..52fdbb588 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/service/BluePrintContext.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/service/BluePrintContext.kt
@@ -35,6 +35,8 @@ import org.onap.ccsdk.cds.controllerblueprints.core.data.OperationAssignment
 import org.onap.ccsdk.cds.controllerblueprints.core.data.OperationDefinition
 import org.onap.ccsdk.cds.controllerblueprints.core.data.PolicyType
 import org.onap.ccsdk.cds.controllerblueprints.core.data.PropertyDefinition
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipTemplate
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipType
 import org.onap.ccsdk.cds.controllerblueprints.core.data.RequirementAssignment
 import org.onap.ccsdk.cds.controllerblueprints.core.data.ServiceTemplate
 import org.onap.ccsdk.cds.controllerblueprints.core.data.Step
@@ -117,7 +119,10 @@ class BluePrintContext(val serviceTemplate: ServiceTemplate) {
     }
 
     fun workflowStepFirstCallOperation(workFlowName: String, stepName: String): String {
-        return workflowStepByName(workFlowName, stepName).activities?.filter { it.callOperation != null }?.single()?.callOperation
+        return workflowStepByName(
+            workFlowName,
+            stepName
+        ).activities?.filter { it.callOperation != null }?.single()?.callOperation
             ?: throw BluePrintException("couldn't get first callOperation for WorkFlow($workFlowName) ")
     }
 
@@ -167,7 +172,11 @@ class BluePrintContext(val serviceTemplate: ServiceTemplate) {
             ?: throw BluePrintException("could't get node type($nodeTypeName)'s interface definition($interfaceName)")
     }
 
-    fun nodeTypeInterfaceOperation(nodeTypeName: String, interfaceName: String, operationName: String): OperationDefinition {
+    fun nodeTypeInterfaceOperation(
+        nodeTypeName: String,
+        interfaceName: String,
+        operationName: String
+    ): OperationDefinition {
         return nodeTypeInterface(nodeTypeName, interfaceName).operations?.get(operationName)
             ?: throw BluePrintException("could't get node type($nodeTypeName)'s interface definition($interfaceName) operation definition($operationName)")
     }
@@ -193,6 +202,12 @@ class BluePrintContext(val serviceTemplate: ServiceTemplate) {
         return nodeTypeInterfaceOperation(nodeTypeName, interfaceName, operationName).outputs
     }
 
+    // Relationship Type Methods
+    fun relationshipTypes(): MutableMap<String, RelationshipType>? = serviceTemplate.relationshipTypes
+
+    fun relationshipTypeByName(name: String): RelationshipType = relationshipTypes()?.get(name)
+        ?: throw BluePrintException("could't get relationship type for the name($name)")
+
     // Node Template Methods
     fun nodeTemplates(): MutableMap<String, NodeTemplate>? = serviceTemplate.topologyTemplate?.nodeTemplates
 
@@ -222,7 +237,9 @@ class BluePrintContext(val serviceTemplate: ServiceTemplate) {
     }
 
     fun nodeTemplateArtifactForArtifactType(nodeTemplateName: String, artifactType: String): ArtifactDefinition {
-        return nodeTemplateArtifacts(nodeTemplateName)?.filter { it.value.type == artifactType }?.map { it.value }?.get(0)
+        return nodeTemplateArtifacts(nodeTemplateName)?.filter { it.value.type == artifactType }?.map { it.value }?.get(
+            0
+        )
             ?: throw BluePrintException("could't get NodeTemplate($nodeTemplateName)'s Artifact Type($artifactType)")
     }
 
@@ -242,15 +259,23 @@ class BluePrintContext(val serviceTemplate: ServiceTemplate) {
     }
 
     fun nodeTemplateOperationImplementation(nodeTemplateName: String, interfaceName: String, operationName: String):
-            Implementation? {
+        Implementation? {
         return nodeTemplateInterfaceOperation(nodeTemplateName, interfaceName, operationName).implementation
     }
 
-    fun nodeTemplateInterfaceOperationInputs(nodeTemplateName: String, interfaceName: String, operationName: String): MutableMap<String, JsonNode>? {
+    fun nodeTemplateInterfaceOperationInputs(
+        nodeTemplateName: String,
+        interfaceName: String,
+        operationName: String
+    ): MutableMap<String, JsonNode>? {
         return nodeTemplateInterfaceOperation(nodeTemplateName, interfaceName, operationName).inputs
     }
 
-    fun nodeTemplateInterfaceOperationOutputs(nodeTemplateName: String, interfaceName: String, operationName: String): MutableMap<String, JsonNode>? {
+    fun nodeTemplateInterfaceOperationOutputs(
+        nodeTemplateName: String,
+        interfaceName: String,
+        operationName: String
+    ): MutableMap<String, JsonNode>? {
         return nodeTemplateInterfaceOperation(nodeTemplateName, interfaceName, operationName).outputs
     }
 
@@ -259,7 +284,11 @@ class BluePrintContext(val serviceTemplate: ServiceTemplate) {
             ?: throw BluePrintException("could't get NodeTemplate($nodeTemplateName)'s InterfaceAssignment($interfaceName)")
     }
 
-    fun nodeTemplateInterfaceOperation(nodeTemplateName: String, interfaceName: String, operationName: String): OperationAssignment {
+    fun nodeTemplateInterfaceOperation(
+        nodeTemplateName: String,
+        interfaceName: String,
+        operationName: String
+    ): OperationAssignment {
         return nodeTemplateInterface(nodeTemplateName, interfaceName).operations?.get(operationName)
             ?: throw BluePrintException("could't get NodeTemplate($nodeTemplateName)'s InterfaceAssignment($interfaceName) OperationAssignment($operationName)")
     }
@@ -275,8 +304,9 @@ class BluePrintContext(val serviceTemplate: ServiceTemplate) {
     }
 
     fun nodeTemplateRequirementNode(nodeTemplateName: String, requirementName: String): NodeTemplate {
-        val filteredNodeTemplateName: String = nodeTemplateByName(nodeTemplateName).requirements?.get(requirementName)?.node
-            ?: throw BluePrintException("could't NodeTemplate for NodeTemplate's($nodeTemplateName) requirement's ($requirementName) ")
+        val filteredNodeTemplateName: String =
+            nodeTemplateByName(nodeTemplateName).requirements?.get(requirementName)?.node
+                ?: throw BluePrintException("could't NodeTemplate for NodeTemplate's($nodeTemplateName) requirement's ($requirementName) ")
         return nodeTemplateByName(filteredNodeTemplateName)
     }
 
@@ -284,6 +314,17 @@ class BluePrintContext(val serviceTemplate: ServiceTemplate) {
         return nodeTemplateCapability(nodeTemplateName, capabilityName).properties?.get(propertyName)
     }
 
+    // Relationship Template Methods
+    fun relationshipTemplates(): MutableMap<String, RelationshipTemplate>? =
+        serviceTemplate.topologyTemplate?.relationshipTemplates
+
+    fun relationshipTemplateByName(name: String): RelationshipTemplate = relationshipTemplates()?.get(name)
+        ?: throw BluePrintException("could't get relationship template for the name($name)")
+
+    fun relationshipTemplateProperty(relationshipTemplateName: String, propertyName: String): Any? {
+        return nodeTemplateByName(relationshipTemplateName).properties?.get(propertyName)
+    }
+
     // Chained Functions
 
     fun nodeTypeChained(nodeTypeName: String): NodeType {
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/service/BluePrintRuntimeService.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/service/BluePrintRuntimeService.kt
index a7ed577dd..841cc5242 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/service/BluePrintRuntimeService.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/service/BluePrintRuntimeService.kt
@@ -76,15 +76,15 @@ interface BluePrintRuntimeService<T> {
     ): MutableMap<String, JsonNode>
 
     fun resolvePropertyDefinitions(name: String, propertyDefinitions: MutableMap<String, PropertyDefinition>):
-            MutableMap<String, JsonNode>
+        MutableMap<String, JsonNode>
 
     fun resolvePropertyAssignments(name: String, propertyAssignments: MutableMap<String, JsonNode>):
-            MutableMap<String, JsonNode>
+        MutableMap<String, JsonNode>
 
     fun resolveNodeTemplateProperties(nodeTemplateName: String): MutableMap<String, JsonNode>
 
     fun resolveNodeTemplateCapabilityProperties(nodeTemplateName: String, capabilityName: String): MutableMap<String,
-            JsonNode>
+        JsonNode>
 
     fun resolveNodeTemplateInterfaceOperationInputs(
         nodeTemplateName: String,
@@ -102,6 +102,8 @@ interface BluePrintRuntimeService<T> {
 
     fun resolveNodeTemplateArtifactDefinition(nodeTemplateName: String, artifactName: String): ArtifactDefinition
 
+    fun resolveRelationshipTemplateProperties(relationshipTemplateName: String): MutableMap<String, JsonNode>
+
     fun resolveDSLExpression(dslPropertyName: String): JsonNode
 
     fun setInputValue(propertyName: String, value: JsonNode)
@@ -262,7 +264,7 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
         propertyDefinitions: MutableMap<String, PropertyDefinition>,
         propertyAssignments: MutableMap<String, JsonNode>
     ):
-            MutableMap<String, JsonNode> {
+        MutableMap<String, JsonNode> {
 
         val propertyAssignmentValue: MutableMap<String, JsonNode> = hashMapOf()
 
@@ -284,6 +286,14 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
                 nodeTypeProperty.defaultValue?.let { resolvedValue = nodeTypeProperty.defaultValue!! }
             }
 
+            /** If property is Map type, then resolve the property value, It may have expressiong */
+            if (nodeTypeProperty.type == BluePrintConstants.DATA_TYPE_MAP &&
+                resolvedValue.returnNullIfMissing() != null
+            ) {
+                val mapResolvedValue = resolvePropertyAssignments(nodeTemplateName, resolvedValue.rootFieldsToMap())
+                resolvedValue = mapResolvedValue.asJsonNode()
+            }
+
             // Set for Return of method
             propertyAssignmentValue[nodeTypePropertyName] = resolvedValue
         }
@@ -291,7 +301,7 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
     }
 
     override fun resolvePropertyDefinitions(name: String, propertyDefinitions: MutableMap<String, PropertyDefinition>):
-            MutableMap<String, JsonNode> {
+        MutableMap<String, JsonNode> {
         val propertyAssignmentValue: MutableMap<String, JsonNode> = hashMapOf()
 
         propertyDefinitions.forEach { propertyName, propertyDefinition ->
@@ -306,7 +316,7 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
     }
 
     override fun resolvePropertyAssignments(name: String, propertyAssignments: MutableMap<String, JsonNode>):
-            MutableMap<String, JsonNode> {
+        MutableMap<String, JsonNode> {
         val propertyAssignmentValue: MutableMap<String, JsonNode> = hashMapOf()
 
         propertyAssignments.forEach { (propertyName, propertyExpression) ->
@@ -331,11 +341,15 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
         /**
          * Resolve the NodeTemplate Property Assignment Values.
          */
-        return resolveNodeTemplatePropertyAssignments(nodeTemplateName, nodeTypePropertiesDefinitions, propertyAssignments)
+        return resolveNodeTemplatePropertyAssignments(
+            nodeTemplateName,
+            nodeTypePropertiesDefinitions,
+            propertyAssignments
+        )
     }
 
     override fun resolveNodeTemplateCapabilityProperties(nodeTemplateName: String, capabilityName: String):
-            MutableMap<String, JsonNode> {
+        MutableMap<String, JsonNode> {
         log.info("resolveNodeTemplateCapabilityProperties for node template($nodeTemplateName) capability($capabilityName)")
         val nodeTemplate: NodeTemplate = bluePrintContext.nodeTemplateByName(nodeTemplateName)
 
@@ -357,7 +371,7 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
     ): MutableMap<String, JsonNode> {
         log.info(
             "resolveNodeTemplateInterfaceOperationInputs for node template ($nodeTemplateName), " +
-                    "interface name($interfaceName), operationName($operationName)"
+                "interface name($interfaceName), operationName($operationName)"
         )
 
         val propertyAssignments: MutableMap<String, JsonNode> =
@@ -375,7 +389,11 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
         /**
          * Resolve the Property Input Assignment Values.
          */
-        return resolveNodeTemplatePropertyAssignments(nodeTemplateName, nodeTypeInterfaceOperationInputs, propertyAssignments)
+        return resolveNodeTemplatePropertyAssignments(
+            nodeTemplateName,
+            nodeTypeInterfaceOperationInputs,
+            propertyAssignments
+        )
     }
 
     override fun resolveNodeTemplateInterfaceOperationOutputs(
@@ -385,7 +403,7 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
     ): MutableMap<String, JsonNode> {
         log.info(
             "resolveNodeTemplateInterfaceOperationOutputs for node template ($nodeTemplateName),interface name " +
-                    "($interfaceName), operationName($operationName)"
+                "($interfaceName), operationName($operationName)"
         )
 
         val propertyAssignments: MutableMap<String, JsonNode> =
@@ -401,7 +419,11 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
          * Resolve the Property Output Assignment Values.
          */
         val propertyAssignmentValue =
-            resolveNodeTemplatePropertyAssignments(nodeTemplateName, nodeTypeInterfaceOperationOutputs, propertyAssignments)
+            resolveNodeTemplatePropertyAssignments(
+                nodeTemplateName,
+                nodeTypeInterfaceOperationOutputs,
+                propertyAssignments
+            )
 
         // Store  operation output values into context
         propertyAssignmentValue.forEach { (key, value) ->
@@ -429,6 +451,28 @@ open class DefaultBluePrintRuntimeService(private var id: String, private var bl
             )
     }
 
+    override fun resolveRelationshipTemplateProperties(relationshipTemplateName: String): MutableMap<String, JsonNode> {
+        log.info("resolveRelationshipTemplateProperties for relationship template ({})", relationshipTemplateName)
+
+        val relationshipTemplate = bluePrintContext.relationshipTemplateByName(relationshipTemplateName)
+
+        val propertyAssignments = relationshipTemplate.properties!!
+
+        // Get the Relationship Type Definitions
+        val propertiesDefinitions = bluePrintContext.relationshipTypeByName(relationshipTemplate.type).properties
+            ?: throw BluePrintProcessorException("failed to get ${relationshipTemplate.type} properties.")
+
+        /**
+         * Resolve the RelationshipTemplate Property Assignment Values.
+         * TODO("Now it supports only input, node not SELF(propert, attribute, artifact) expressions, later it will support SELF expressions")
+         */
+        return resolveNodeTemplatePropertyAssignments(
+            "DSL",
+            propertiesDefinitions,
+            propertyAssignments
+        )
+    }
+
     /**
      * Read the DSL Property reference, If there is any expression, then resolve those expression and return as Json
      * Type
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/utils/JacksonUtils.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/utils/JacksonUtils.kt
index 945f300af..089a610c9 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/utils/JacksonUtils.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/utils/JacksonUtils.kt
@@ -225,7 +225,6 @@ class JacksonUtils {
         fun checkJsonNodeValueOfCollectionType(type: String, jsonNode: JsonNode): Boolean {
             return when (type.toLowerCase()) {
                 BluePrintConstants.DATA_TYPE_LIST -> jsonNode.isArray
-                BluePrintConstants.DATA_TYPE_MAP -> jsonNode.isContainerNode
                 else -> false
             }
         }
diff --git a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/test/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/utils/JacksonUtilsTest.kt b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/test/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/utils/JacksonUtilsTest.kt
index 5facad7ef..d78e62f28 100644
--- a/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/test/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/utils/JacksonUtilsTest.kt
+++ b/ms/blueprintsprocessor/modules/blueprints/blueprint-core/src/test/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/utils/JacksonUtilsTest.kt
@@ -66,8 +66,9 @@ class JacksonUtilsTest {
         assertTrue(JacksonUtils.checkJsonNodeValueOfType(BluePrintConstants.DATA_TYPE_BOOLEAN, booleanValue), "Failed to get as boolean value")
         val arrayStringValue = rootJson.get("arrayStringValue")
         assertTrue(JacksonUtils.checkJsonNodeValueOfType(BluePrintConstants.DATA_TYPE_LIST, arrayStringValue), "Failed to get as List value")
-        val mapValue = rootJson.get("mapValue")
-        assertTrue(JacksonUtils.checkJsonNodeValueOfType(BluePrintConstants.DATA_TYPE_MAP, mapValue), "Failed to get as Map value")
+        // FIX needed for ("complex type JSON & MAP")
+        // val mapValue = rootJson.get("mapValue")
+        // assertTrue(JacksonUtils.checkJsonNodeValueOfType(BluePrintConstants.DATA_TYPE_MAP, mapValue), "Failed to get as Map value")
 
         assertTrue(!JacksonUtils.checkJsonNodeValueOfType(BluePrintConstants.DATA_TYPE_LIST, stringValue), "Negative type failed")
     }
diff --git a/ms/blueprintsprocessor/modules/commons/db-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/db/DatabasePropertiesDSL.kt b/ms/blueprintsprocessor/modules/commons/db-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/db/DatabasePropertiesDSL.kt
new file mode 100644
index 000000000..036beb369
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/db-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/db/DatabasePropertiesDSL.kt
@@ -0,0 +1,17 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.db
diff --git a/ms/blueprintsprocessor/modules/commons/grpc-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/GrpcPropertiesDSL.kt b/ms/blueprintsprocessor/modules/commons/grpc-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/GrpcPropertiesDSL.kt
new file mode 100644
index 000000000..3a0e9c633
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/grpc-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/grpc/GrpcPropertiesDSL.kt
@@ -0,0 +1,17 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.grpc
diff --git a/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt b/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt
index 59e3606ea..005223d9b 100644
--- a/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt
+++ b/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/BluePrintMessageLibData.kt
@@ -20,7 +20,9 @@ package org.onap.ccsdk.cds.blueprintsprocessor.message
 import org.apache.kafka.streams.StreamsConfig
 
 /** Producer Properties **/
-open class MessageProducerProperties
+open class MessageProducerProperties {
+    lateinit var type: String
+}
 
 open class KafkaBasicAuthMessageProducerProperties : MessageProducerProperties() {
     lateinit var bootstrapServers: String
@@ -35,7 +37,9 @@ open class KafkaBasicAuthMessageProducerProperties : MessageProducerProperties()
 
 /** Consumer Properties **/
 
-open class MessageConsumerProperties
+open class MessageConsumerProperties {
+    lateinit var type: String
+}
 
 open class KafkaStreamsConsumerProperties : MessageConsumerProperties() {
     lateinit var bootstrapServers: String
diff --git a/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/MessagePropertiesDSL.kt b/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/MessagePropertiesDSL.kt
new file mode 100644
index 000000000..c6e923948
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/MessagePropertiesDSL.kt
@@ -0,0 +1,255 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.message
+
+import com.fasterxml.jackson.databind.JsonNode
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintConstants
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive
+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonType
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipType
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.PropertiesAssignmentBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.RelationshipTemplateBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.TopologyTemplateBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.relationshipType
+
+/** Relationships Types DSL for Message Producer */
+fun BluePrintTypes.relationshipTypeConnectsToMessageProducer(): RelationshipType {
+    return relationshipType(
+        id = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_MESSAGE_PRODUCER,
+        version = BluePrintConstants.DEFAULT_VERSION_NUMBER,
+        derivedFrom = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO,
+        description = "Relationship connects to through message producer."
+    ) {
+        property(
+            BluePrintConstants.PROPERTY_CONNECTION_CONFIG,
+            BluePrintConstants.DATA_TYPE_MAP,
+            true,
+            "Connection Config details."
+        )
+        validTargetTypes(arrayListOf(BluePrintConstants.MODEL_TYPE_CAPABILITY_TYPE_ENDPOINT))
+    }
+}
+
+fun BluePrintTypes.relationshipTypeConnectsToMessageConsumer(): RelationshipType {
+    return relationshipType(
+        id = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_MESSAGE_CONSUMER,
+        version = BluePrintConstants.DEFAULT_VERSION_NUMBER,
+        derivedFrom = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO,
+        description = "Relationship type connects to message consumer."
+    ) {
+        property(
+            BluePrintConstants.PROPERTY_CONNECTION_CONFIG,
+            BluePrintConstants.DATA_TYPE_MAP,
+            true,
+            "Connection Config details."
+        )
+        validTargetTypes(arrayListOf(BluePrintConstants.MODEL_TYPE_CAPABILITY_TYPE_ENDPOINT))
+    }
+}
+
+/** Relationships Templates DSL for Message Producer */
+fun TopologyTemplateBuilder.relationshipTemplateMessageProducer(
+    name: String,
+    description: String,
+    block: MessageProducerRelationshipTemplateBuilder.() -> Unit
+) {
+    if (relationshipTemplates == null) relationshipTemplates = hashMapOf()
+    val relationshipTemplate =
+        MessageProducerRelationshipTemplateBuilder(name, description).apply(block).build()
+    relationshipTemplates!![relationshipTemplate.id!!] = relationshipTemplate
+}
+
+class MessageProducerRelationshipTemplateBuilder(name: String, description: String) :
+    RelationshipTemplateBuilder(
+        name,
+        BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_MESSAGE_PRODUCER, description
+    ) {
+
+    fun kafkaBasicAuth(block: KafkaBasicAuthMessageProducerPropertiesAssignmentBuilder.() -> Unit) {
+        property(
+            BluePrintConstants.PROPERTY_CONNECTION_CONFIG,
+            BluePrintTypes.kafkaBasicAuthMessageProducerProperties(block)
+        )
+    }
+}
+
+fun BluePrintTypes.kafkaBasicAuthMessageProducerProperties(block: KafkaBasicAuthMessageProducerPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val assignments = KafkaBasicAuthMessageProducerPropertiesAssignmentBuilder().apply(block).build()
+    assignments[KafkaBasicAuthMessageProducerProperties::type.name] =
+        MessageLibConstants.TYPE_KAFKA_BASIC_AUTH.asJsonPrimitive()
+    return assignments.asJsonType()
+}
+
+open class MessageProducerPropertiesAssignmentBuilder : PropertiesAssignmentBuilder()
+
+class KafkaBasicAuthMessageProducerPropertiesAssignmentBuilder : MessageProducerPropertiesAssignmentBuilder() {
+
+    fun bootstrapServers(bootstrapServers: String) = bootstrapServers(bootstrapServers.asJsonPrimitive())
+
+    fun bootstrapServers(bootstrapServers: JsonNode) =
+        property(KafkaBasicAuthMessageProducerProperties::bootstrapServers, bootstrapServers)
+
+    fun topic(topic: String) = topic(topic.asJsonPrimitive())
+
+    fun topic(topic: JsonNode) =
+        property(KafkaBasicAuthMessageProducerProperties::topic, topic)
+
+    fun clientId(clientId: String) = bootstrapServers(clientId.asJsonPrimitive())
+
+    fun clientId(clientId: JsonNode) =
+        property(KafkaBasicAuthMessageProducerProperties::clientId, clientId)
+
+    fun acks(acks: String) = acks(acks.asJsonPrimitive())
+
+    fun acks(acks: JsonNode) = property(KafkaBasicAuthMessageProducerProperties::acks, acks)
+
+    fun retries(retries: Int) = retries(retries.asJsonPrimitive())
+
+    fun retries(retries: JsonNode) = property(KafkaBasicAuthMessageProducerProperties::retries, retries)
+
+    fun enableIdempotence(enableIdempotence: Boolean) = enableIdempotence(enableIdempotence.asJsonPrimitive())
+
+    fun enableIdempotence(enableIdempotence: JsonNode) =
+        property(KafkaBasicAuthMessageProducerProperties::enableIdempotence, enableIdempotence)
+}
+
+/** Relationships Templates DSL for Message Consumer */
+fun TopologyTemplateBuilder.relationshipTemplateMessageConsumer(
+    name: String,
+    description: String,
+    block: MessageConsumerRelationshipTemplateBuilder.() -> Unit
+) {
+    if (relationshipTemplates == null) relationshipTemplates = hashMapOf()
+    val relationshipTemplate =
+        MessageConsumerRelationshipTemplateBuilder(name, description).apply(block).build()
+    relationshipTemplates!![relationshipTemplate.id!!] = relationshipTemplate
+}
+
+class MessageConsumerRelationshipTemplateBuilder(name: String, description: String) :
+    RelationshipTemplateBuilder(
+        name,
+        BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_MESSAGE_CONSUMER, description
+    ) {
+
+    fun kafkaBasicAuth(block: KafkaBasicAuthMessageConsumerPropertiesAssignmentBuilder.() -> Unit) {
+        property(
+            BluePrintConstants.PROPERTY_CONNECTION_CONFIG,
+            BluePrintTypes.kafkaBasicAuthMessageConsumerProperties(block)
+        )
+    }
+
+    fun kafkaStreamsBasicAuth(block: KafkaStreamsBasicAuthConsumerPropertiesAssignmentBuilder.() -> Unit) {
+        property(
+            BluePrintConstants.PROPERTY_CONNECTION_CONFIG,
+            BluePrintTypes.kafkaStreamsBasicAuthConsumerProperties(block)
+        )
+    }
+}
+
+fun BluePrintTypes.kafkaBasicAuthMessageConsumerProperties(block: KafkaBasicAuthMessageConsumerPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val assignments = KafkaBasicAuthMessageConsumerPropertiesAssignmentBuilder().apply(block).build()
+    assignments[KafkaBasicAuthMessageConsumerProperties::type.name] =
+        MessageLibConstants.TYPE_KAFKA_BASIC_AUTH.asJsonPrimitive()
+    return assignments.asJsonType()
+}
+
+fun BluePrintTypes.kafkaStreamsBasicAuthConsumerProperties(block: KafkaStreamsBasicAuthConsumerPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val assignments = KafkaStreamsBasicAuthConsumerPropertiesAssignmentBuilder().apply(block).build()
+    assignments[KafkaStreamsBasicAuthConsumerProperties::type.name] =
+        MessageLibConstants.TYPE_KAFKA_STREAMS_BASIC_AUTH.asJsonPrimitive()
+    return assignments.asJsonType()
+}
+
+open class MessageConsumerPropertiesAssignmentBuilder : PropertiesAssignmentBuilder()
+
+open class KafkaMessageConsumerPropertiesAssignmentBuilder : MessageConsumerPropertiesAssignmentBuilder() {
+
+    fun bootstrapServers(bootstrapServers: String) = bootstrapServers(bootstrapServers.asJsonPrimitive())
+
+    fun bootstrapServers(bootstrapServers: JsonNode) =
+        property(KafkaMessageConsumerProperties::bootstrapServers, bootstrapServers)
+
+    fun groupId(groupId: String) = groupId(groupId.asJsonPrimitive())
+
+    fun groupId(groupId: JsonNode) =
+        property(KafkaMessageConsumerProperties::groupId, groupId)
+
+    fun clientId(clientId: String) = clientId(clientId.asJsonPrimitive())
+
+    fun clientId(clientId: JsonNode) =
+        property(KafkaMessageConsumerProperties::clientId, clientId)
+
+    fun topic(topic: String) = topic(topic.asJsonPrimitive())
+
+    fun topic(topic: JsonNode) =
+        property(KafkaMessageConsumerProperties::topic, topic)
+
+    fun autoCommit(autoCommit: Boolean) = autoCommit(autoCommit.asJsonPrimitive())
+
+    fun autoCommit(autoCommit: JsonNode) =
+        property(KafkaMessageConsumerProperties::autoCommit, autoCommit)
+
+    fun autoOffsetReset(autoOffsetReset: String) = autoOffsetReset(autoOffsetReset.asJsonPrimitive())
+
+    fun autoOffsetReset(autoOffsetReset: JsonNode) =
+        property(KafkaMessageConsumerProperties::autoOffsetReset, autoOffsetReset)
+
+    fun pollMillSec(pollMillSec: Int) = pollMillSec(pollMillSec.asJsonPrimitive())
+
+    fun pollMillSec(pollMillSec: JsonNode) =
+        property(KafkaMessageConsumerProperties::pollMillSec, pollMillSec)
+
+    fun pollRecords(pollRecords: Int) = pollRecords(pollRecords.asJsonPrimitive())
+
+    fun pollRecords(pollRecords: JsonNode) =
+        property(KafkaMessageConsumerProperties::pollRecords, pollRecords)
+}
+
+/** KafkaBasicAuthMessageConsumerProperties assignment builder */
+class KafkaBasicAuthMessageConsumerPropertiesAssignmentBuilder : KafkaMessageConsumerPropertiesAssignmentBuilder()
+
+/** KafkaStreamsConsumerProperties assignment builder */
+open class KafkaStreamsConsumerPropertiesAssignmentBuilder : MessageConsumerPropertiesAssignmentBuilder() {
+
+    fun bootstrapServers(bootstrapServers: String) = bootstrapServers(bootstrapServers.asJsonPrimitive())
+
+    fun bootstrapServers(bootstrapServers: JsonNode) =
+        property(KafkaStreamsConsumerProperties::bootstrapServers, bootstrapServers)
+
+    fun applicationId(applicationId: String) = bootstrapServers(applicationId.asJsonPrimitive())
+
+    fun applicationId(applicationId: JsonNode) =
+        property(KafkaStreamsConsumerProperties::applicationId, applicationId)
+
+    fun topic(topic: String) = topic(topic.asJsonPrimitive())
+
+    fun topic(topic: JsonNode) =
+        property(KafkaStreamsConsumerProperties::topic, topic)
+
+    fun autoOffsetReset(autoOffsetReset: String) = autoOffsetReset(autoOffsetReset.asJsonPrimitive())
+
+    fun autoOffsetReset(autoOffsetReset: JsonNode) =
+        property(KafkaStreamsConsumerProperties::autoOffsetReset, autoOffsetReset)
+
+    fun processingGuarantee(processingGuarantee: String) = processingGuarantee(processingGuarantee.asJsonPrimitive())
+
+    fun processingGuarantee(processingGuarantee: JsonNode) =
+        property(KafkaStreamsConsumerProperties::processingGuarantee, processingGuarantee)
+}
+
+class KafkaStreamsBasicAuthConsumerPropertiesAssignmentBuilder : KafkaStreamsConsumerPropertiesAssignmentBuilder()
diff --git a/ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/MessagePropertiesDSLTest.kt b/ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/MessagePropertiesDSLTest.kt
new file mode 100644
index 000000000..9ece90ffc
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/message-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/MessagePropertiesDSLTest.kt
@@ -0,0 +1,101 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.message
+
+import org.apache.kafka.streams.StreamsConfig
+import org.junit.Test
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.relationshipTypeConnectsTo
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.serviceTemplate
+import kotlin.test.assertEquals
+import kotlin.test.assertNotNull
+
+class MessagePropertiesDSLTest {
+
+    @Test
+    fun testMessageProducerDSL() {
+        val serviceTemplate = serviceTemplate("message-properties-test", "1.0.0", "xxx.@xx.com", "message") {
+            topologyTemplate {
+                relationshipTemplateMessageProducer("sample-basic-auth", "Message Producer") {
+                    kafkaBasicAuth {
+                        bootstrapServers("sample-bootstrapServers")
+                        clientId("sample-client-id")
+                        acks("all")
+                        retries(3)
+                        enableIdempotence(true)
+                        topic("sample-topic")
+                    }
+                }
+            }
+            relationshipTypes(
+                arrayListOf(
+                    BluePrintTypes.relationshipTypeConnectsToMessageProducer(),
+                    BluePrintTypes.relationshipTypeConnectsTo()
+                )
+            )
+        }
+        assertNotNull(serviceTemplate, "failed to create service template")
+        val relationshipTemplates = serviceTemplate.topologyTemplate?.relationshipTemplates
+        assertNotNull(relationshipTemplates, "failed to get relationship templates")
+        assertEquals(1, relationshipTemplates.size, "relationshipTemplates doesn't match")
+        assertNotNull(relationshipTemplates["sample-basic-auth"], "failed to get sample-basic-auth")
+        // println(serviceTemplate.asJsonString(true))
+    }
+
+    @Test
+    fun testMessageConsumerDSL() {
+        val serviceTemplate = serviceTemplate("message-properties-test", "1.0.0", "xxx.@xx.com", "message") {
+            topologyTemplate {
+                relationshipTemplateMessageConsumer("sample-basic-auth", "Message Consumer") {
+                    kafkaBasicAuth {
+                        bootstrapServers("sample-bootstrapServers")
+                        clientId("sample-client-id")
+                        groupId("sample-group-id")
+                        topic("sample-topic")
+                        autoCommit(false)
+                        autoOffsetReset("latest")
+                        pollMillSec(5000)
+                        pollRecords(20)
+                    }
+                }
+                relationshipTemplateMessageConsumer("sample-stream-basic-auth", "Message Consumer") {
+                    kafkaStreamsBasicAuth {
+                        bootstrapServers("sample-bootstrapServers")
+                        applicationId("sample-application-id")
+                        autoOffsetReset("latest")
+                        processingGuarantee(StreamsConfig.EXACTLY_ONCE)
+                        topic("sample-streaming-topic")
+                    }
+                }
+            }
+            relationshipTypes(
+                arrayListOf(
+                    BluePrintTypes.relationshipTypeConnectsToMessageConsumer(),
+                    BluePrintTypes.relationshipTypeConnectsTo()
+                )
+            )
+        }
+
+        assertNotNull(serviceTemplate, "failed to create service template")
+        val relationshipTemplates = serviceTemplate.topologyTemplate?.relationshipTemplates
+        assertNotNull(relationshipTemplates, "failed to get relationship templates")
+        assertEquals(2, relationshipTemplates.size, "relationshipTemplates doesn't match")
+        assertNotNull(relationshipTemplates["sample-basic-auth"], "failed to get sample-basic-auth")
+        assertNotNull(relationshipTemplates["sample-stream-basic-auth"], "failed to get sample-stream-basic-auth")
+        // println(serviceTemplate.asJsonString(true))
+    }
+}
diff --git a/ms/blueprintsprocessor/modules/commons/nats-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nats/NatsPropertiesDSL.kt b/ms/blueprintsprocessor/modules/commons/nats-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nats/NatsPropertiesDSL.kt
new file mode 100644
index 000000000..5c4301b38
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/nats-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nats/NatsPropertiesDSL.kt
@@ -0,0 +1,112 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.nats
+
+import com.fasterxml.jackson.databind.JsonNode
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintConstants
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonNode
+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipType
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.PropertiesAssignmentBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.RelationshipTemplateBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.TopologyTemplateBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.relationshipType
+
+/** Relationships Types DSL for NATS Producer */
+fun BluePrintTypes.relationshipTypeConnectsToNats(): RelationshipType {
+    return relationshipType(
+        id = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_NATS,
+        version = BluePrintConstants.DEFAULT_VERSION_NUMBER,
+        derivedFrom = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO,
+        description = "Relationship connects to through NATS Client."
+    ) {
+        property(
+            BluePrintConstants.PROPERTY_CONNECTION_CONFIG,
+            BluePrintConstants.DATA_TYPE_MAP,
+            true,
+            "Connection Config details."
+        )
+        validTargetTypes(arrayListOf(BluePrintConstants.MODEL_TYPE_CAPABILITY_TYPE_ENDPOINT))
+    }
+}
+
+/** Relationships Templates for Nats */
+fun TopologyTemplateBuilder.relationshipTemplateNats(
+    name: String,
+    description: String,
+    block: NatsRelationshipTemplateBuilder.() -> Unit
+) {
+    if (relationshipTemplates == null) relationshipTemplates = hashMapOf()
+    val relationshipTemplate = NatsRelationshipTemplateBuilder(name, description).apply(block).build()
+    relationshipTemplates!![relationshipTemplate.id!!] = relationshipTemplate
+}
+
+class NatsRelationshipTemplateBuilder(name: String, description: String) :
+    RelationshipTemplateBuilder(
+        name,
+        BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_NATS, description
+    ) {
+
+    fun tokenAuth(block: NatsTokenAuthPropertiesAssignmentBuilder.() -> Unit) {
+        property(BluePrintConstants.PROPERTY_CONNECTION_CONFIG, BluePrintTypes.tokenAuthNatsProperties(block))
+    }
+
+    fun tlsAuth(block: NatsTLSAuthPropertiesAssignmentBuilder.() -> Unit) {
+        property(BluePrintConstants.PROPERTY_CONNECTION_CONFIG, BluePrintTypes.tlsAuthNatsProperties(block))
+    }
+}
+
+fun BluePrintTypes.tokenAuthNatsProperties(block: NatsTokenAuthPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val assignments = NatsTokenAuthPropertiesAssignmentBuilder().apply(block).build()
+    assignments[NatsConnectionProperties::type.name] = NatsLibConstants.TYPE_TOKEN_AUTH.asJsonPrimitive()
+    return assignments.asJsonNode()
+}
+
+fun BluePrintTypes.tlsAuthNatsProperties(block: NatsTLSAuthPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val assignments = NatsTLSAuthPropertiesAssignmentBuilder().apply(block).build()
+    assignments[NatsConnectionProperties::type.name] = NatsLibConstants.TYPE_TLS_AUTH.asJsonPrimitive()
+    return assignments.asJsonNode()
+}
+
+open class NatsConnectionPropertiesAssignmentBuilder : PropertiesAssignmentBuilder() {
+
+    fun clusterId(clusterId: String) = clusterId(clusterId.asJsonPrimitive())
+
+    fun clusterId(clusterId: JsonNode) = property(NatsConnectionProperties::clusterId, clusterId)
+
+    fun clientId(clientId: String) = clientId(clientId.asJsonPrimitive())
+
+    fun clientId(clientId: JsonNode) = property(NatsConnectionProperties::clientId, clientId)
+
+    fun host(host: String) = host(host.asJsonPrimitive())
+
+    fun host(host: JsonNode) = property(NatsConnectionProperties::host, host)
+
+    fun monitoringSelector(monitoringSelector: String) = monitoringSelector(monitoringSelector.asJsonPrimitive())
+
+    fun monitoringSelector(monitoringSelector: JsonNode) =
+        property(NatsConnectionProperties::monitoringSelector, monitoringSelector)
+}
+
+class NatsTokenAuthPropertiesAssignmentBuilder : NatsConnectionPropertiesAssignmentBuilder() {
+    fun token(selector: String) = token(selector.asJsonPrimitive())
+
+    fun token(selector: JsonNode) = property(TokenAuthNatsConnectionProperties::token, selector)
+}
+
+class NatsTLSAuthPropertiesAssignmentBuilder : NatsConnectionPropertiesAssignmentBuilder()
diff --git a/ms/blueprintsprocessor/modules/commons/nats-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nats/NatsPropertiesDSLTest.kt b/ms/blueprintsprocessor/modules/commons/nats-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nats/NatsPropertiesDSLTest.kt
new file mode 100644
index 000000000..4cf474b93
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/nats-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/nats/NatsPropertiesDSLTest.kt
@@ -0,0 +1,63 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.nats
+
+import org.junit.Test
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.getInput
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.relationshipTypeConnectsTo
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.serviceTemplate
+import kotlin.test.assertEquals
+import kotlin.test.assertNotNull
+
+class NatsPropertiesDSLTest {
+
+    @Test
+    fun testNatsPropertiesDSL() {
+        val serviceTemplate = serviceTemplate("nats-dsl", "1.0.0", "xx@xx.com", "nats") {
+            topologyTemplate {
+                relationshipTemplateNats("sample-token-auth", "Nats TokenAuth endpoint") {
+                    tokenAuth {
+                        host("nats://localhost:4222")
+                        token("tokenAuth")
+                        monitoringSelector(getInput("monitoringUrl"))
+                    }
+                }
+                relationshipTemplateNats("sample-tls-auth", "Nats TLS endpoint.") {
+                    tlsAuth {
+                        host("nats://localhost:4222")
+                    }
+                }
+            }
+
+            relationshipTypes(
+                arrayListOf(
+                    BluePrintTypes.relationshipTypeConnectsToNats(),
+                    BluePrintTypes.relationshipTypeConnectsTo()
+                )
+            )
+        }
+
+        assertNotNull(serviceTemplate, "failed to create service template")
+        val relationshipTemplates = serviceTemplate.topologyTemplate?.relationshipTemplates
+        assertNotNull(relationshipTemplates, "failed to get relationship templates")
+        assertEquals(2, relationshipTemplates.size, "relationshipTemplates doesn't match")
+        assertNotNull(relationshipTemplates["sample-token-auth"], "failed to get sample-token-auth")
+        assertNotNull(relationshipTemplates["sample-tls-auth"], "failed to get sample-tls-auth")
+        // println(serviceTemplate.asJsonString(true))
+    }
+}
diff --git a/ms/blueprintsprocessor/modules/commons/rest-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/BluePrintRestLibConfiguration.kt b/ms/blueprintsprocessor/modules/commons/rest-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/BluePrintRestLibConfiguration.kt
index 9e1be36a7..23125430a 100644
--- a/ms/blueprintsprocessor/modules/commons/rest-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/BluePrintRestLibConfiguration.kt
+++ b/ms/blueprintsprocessor/modules/commons/rest-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/BluePrintRestLibConfiguration.kt
@@ -48,6 +48,7 @@ fun BluePrintDependencyService.restClientService(jsonNode: JsonNode): BlueprintW
 class RestLibConstants {
     companion object {
         const val SERVICE_BLUEPRINT_REST_LIB_PROPERTY = "blueprint-rest-lib-property-service"
+        const val PROPERTY_REST_CLIENT_PREFIX = "blueprintsprocessor.restclient."
         const val PROPERTY_TYPE = "type"
         const val TYPE_TOKEN_AUTH = "token-auth"
         const val TYPE_BASIC_AUTH = "basic-auth"
diff --git a/ms/blueprintsprocessor/modules/commons/rest-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/RestClientPropertiesDSL.kt b/ms/blueprintsprocessor/modules/commons/rest-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/RestClientPropertiesDSL.kt
index 429931377..4c25cb5bf 100644
--- a/ms/blueprintsprocessor/modules/commons/rest-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/RestClientPropertiesDSL.kt
+++ b/ms/blueprintsprocessor/modules/commons/rest-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/RestClientPropertiesDSL.kt
@@ -17,54 +17,100 @@
 package org.onap.ccsdk.cds.blueprintsprocessor.rest
 
 import com.fasterxml.jackson.databind.JsonNode
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintConstants
 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
 import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive
 import org.onap.ccsdk.cds.controllerblueprints.core.asJsonType
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipType
 import org.onap.ccsdk.cds.controllerblueprints.core.dsl.PropertiesAssignmentBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.RelationshipTemplateBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.TopologyTemplateBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.relationshipType
+
+/** Relationships Type DSL for Rest */
+fun BluePrintTypes.relationshipTypeConnectsToRestClient(): RelationshipType {
+    return relationshipType(
+        id = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_REST_CLIENT,
+        version = BluePrintConstants.DEFAULT_VERSION_NUMBER,
+        derivedFrom = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO,
+        description = "Relationship connects to through"
+    ) {
+        property(
+            BluePrintConstants.PROPERTY_CONNECTION_CONFIG,
+            BluePrintConstants.DATA_TYPE_MAP,
+            true,
+            "Connection Config details."
+        )
+        validTargetTypes(arrayListOf(BluePrintConstants.MODEL_TYPE_CAPABILITY_TYPE_ENDPOINT))
+    }
+}
 
-fun BluePrintTypes.dslBasicAuthRestClientProperties(block: BasicAuthRestClientPropertiesBuilder.() -> Unit): JsonNode {
-    val assignments = BasicAuthRestClientPropertiesBuilder().apply(block).build()
-    assignments[RestLibConstants.PROPERTY_TYPE] = RestLibConstants.TYPE_BASIC_AUTH.asJsonPrimitive()
-    return assignments.asJsonType()
+/** Relationships Templates DSL for Rest */
+fun TopologyTemplateBuilder.relationshipTemplateRestClient(
+    name: String,
+    description: String,
+    block: RestClientRelationshipTemplateBuilder.() -> Unit
+) {
+    if (relationshipTemplates == null) relationshipTemplates = hashMapOf()
+    val relationshipTemplate = RestClientRelationshipTemplateBuilder(name, description).apply(block).build()
+    relationshipTemplates!![relationshipTemplate.id!!] = relationshipTemplate
 }
 
-fun BluePrintTypes.dslTokenAuthRestClientProperties(block: TokenAuthRestClientPropertiesBuilder.() -> Unit): JsonNode {
-    val assignments = TokenAuthRestClientPropertiesBuilder().apply(block).build()
-    assignments[RestLibConstants.PROPERTY_TYPE] = RestLibConstants.TYPE_TOKEN_AUTH.asJsonPrimitive()
+open class RestClientRelationshipTemplateBuilder(name: String, description: String) :
+    RelationshipTemplateBuilder(
+        name,
+        BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_REST_CLIENT, description
+    ) {
+
+    fun basicAuth(block: BasicAuthRestClientPropertiesAssignmentBuilder.() -> Unit) {
+        property(BluePrintConstants.PROPERTY_CONNECTION_CONFIG, BluePrintTypes.basicAuthRestClientProperties(block))
+    }
+
+    fun tokenAuth(block: TokenAuthRestClientPropertiesAssignmentBuilder.() -> Unit) {
+        property(BluePrintConstants.PROPERTY_CONNECTION_CONFIG, BluePrintTypes.tokenAuthRestClientProperties(block))
+    }
+
+    fun sslAuth(block: SslAuthRestClientPropertiesAssignmentBuilder.() -> Unit) {
+        property(BluePrintConstants.PROPERTY_CONNECTION_CONFIG, BluePrintTypes.sslRestClientProperties(block))
+    }
+}
+
+fun BluePrintTypes.basicAuthRestClientProperties(block: BasicAuthRestClientPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val assignments = BasicAuthRestClientPropertiesAssignmentBuilder().apply(block).build()
+    assignments[RestClientProperties::type.name] = RestLibConstants.TYPE_BASIC_AUTH.asJsonPrimitive()
     return assignments.asJsonType()
 }
 
-fun BluePrintTypes.dslSSLRestClientProperties(block: SSLRestClientPropertiesBuilder.() -> Unit): JsonNode {
-    val assignments = SSLRestClientPropertiesBuilder().apply(block).build()
-    assignments[RestLibConstants.PROPERTY_TYPE] = RestLibConstants.TYPE_SSL_NO_AUTH.asJsonPrimitive()
+fun BluePrintTypes.tokenAuthRestClientProperties(block: TokenAuthRestClientPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val assignments = TokenAuthRestClientPropertiesAssignmentBuilder().apply(block).build()
+    assignments[RestClientProperties::type.name] = RestLibConstants.TYPE_TOKEN_AUTH.asJsonPrimitive()
     return assignments.asJsonType()
 }
 
-open class RestClientPropertiesBuilder : PropertiesAssignmentBuilder() {
-    fun type(type: String) {
-        type(type.asJsonPrimitive())
-    }
+fun BluePrintTypes.sslRestClientProperties(block: SslAuthRestClientPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val assignments = SslAuthRestClientPropertiesAssignmentBuilder().apply(block).build()
+    assignments[RestClientProperties::type.name] = RestLibConstants.TYPE_SSL_NO_AUTH.asJsonPrimitive()
+    return assignments.asJsonType()
+}
 
-    fun type(type: JsonNode) {
-        property(RestLibConstants.PROPERTY_TYPE, type)
-    }
+open class RestClientPropertiesAssignmentBuilder : PropertiesAssignmentBuilder() {
 
     open fun url(url: String) {
         url(url.asJsonPrimitive())
     }
 
     open fun url(url: JsonNode) {
-        property("url", url)
+        property(RestClientProperties::url, url)
     }
 }
 
-open class BasicAuthRestClientPropertiesBuilder : RestClientPropertiesBuilder() {
+open class BasicAuthRestClientPropertiesAssignmentBuilder : RestClientPropertiesAssignmentBuilder() {
     open fun password(password: String) {
         password(password.asJsonPrimitive())
     }
 
     open fun password(password: JsonNode) {
-        property("password", password)
+        property(BasicAuthRestClientProperties::password, password)
     }
 
     open fun username(username: String) {
@@ -72,27 +118,27 @@ open class BasicAuthRestClientPropertiesBuilder : RestClientPropertiesBuilder()
     }
 
     open fun username(username: JsonNode) {
-        property("username", username)
+        property(BasicAuthRestClientProperties::username, username)
     }
 }
 
-open class TokenAuthRestClientPropertiesBuilder : RestClientPropertiesBuilder() {
+open class TokenAuthRestClientPropertiesAssignmentBuilder : RestClientPropertiesAssignmentBuilder() {
     open fun token(token: String) {
         token(token.asJsonPrimitive())
     }
 
     open fun token(token: JsonNode) {
-        property("token", token)
+        property(TokenAuthRestClientProperties::token, token)
     }
 }
 
-open class SSLRestClientPropertiesBuilder : RestClientPropertiesBuilder() {
+open class SslAuthRestClientPropertiesAssignmentBuilder : RestClientPropertiesAssignmentBuilder() {
     open fun keyStoreInstance(keyStoreInstance: String) {
         keyStoreInstance(keyStoreInstance.asJsonPrimitive())
     }
 
     open fun keyStoreInstance(keyStoreInstance: JsonNode) {
-        property("keyStoreInstance", keyStoreInstance)
+        property(SSLRestClientProperties::keyStoreInstance, keyStoreInstance)
     }
 
     open fun sslTrust(sslTrust: String) {
@@ -100,7 +146,7 @@ open class SSLRestClientPropertiesBuilder : RestClientPropertiesBuilder() {
     }
 
     open fun sslTrust(sslTrust: JsonNode) {
-        property("sslTrust", sslTrust)
+        property(SSLRestClientProperties::sslTrust, sslTrust)
     }
 
     open fun sslTrustPassword(sslTrustPassword: String) {
@@ -108,7 +154,7 @@ open class SSLRestClientPropertiesBuilder : RestClientPropertiesBuilder() {
     }
 
     open fun sslTrustPassword(sslTrustPassword: JsonNode) {
-        property("sslTrustPassword", sslTrustPassword)
+        property(SSLRestClientProperties::sslTrustPassword, sslTrustPassword)
     }
 
     open fun sslKey(sslKey: String) {
@@ -116,7 +162,7 @@ open class SSLRestClientPropertiesBuilder : RestClientPropertiesBuilder() {
     }
 
     open fun sslKey(sslKey: JsonNode) {
-        property("sslKey", sslKey)
+        property(SSLRestClientProperties::sslKey, sslKey)
     }
 
     open fun sslKeyPassword(sslKeyPassword: String) {
@@ -124,14 +170,14 @@ open class SSLRestClientPropertiesBuilder : RestClientPropertiesBuilder() {
     }
 
     open fun sslKeyPassword(sslKeyPassword: JsonNode) {
-        property("sslKeyPassword", sslKeyPassword)
+        property(SSLRestClientProperties::sslKeyPassword, sslKeyPassword)
     }
 }
 
-open class SSLBasicAuthRestClientPropertiesBuilder : SSLRestClientPropertiesBuilder() {
+open class SSLBasicAuthRestClientPropertiesBuilder : SslAuthRestClientPropertiesAssignmentBuilder() {
     // TODO()
 }
 
-open class SSLTokenAuthRestClientPropertiesBuilder : SSLRestClientPropertiesBuilder() {
+open class SSLTokenAuthRestClientPropertiesBuilder : SslAuthRestClientPropertiesAssignmentBuilder() {
     // TODO()
 }
diff --git a/ms/blueprintsprocessor/modules/commons/rest-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/service/RestClientPropertiesDSLTest.kt b/ms/blueprintsprocessor/modules/commons/rest-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/service/RestClientPropertiesDSLTest.kt
index f82fc6124..28784e4ae 100644
--- a/ms/blueprintsprocessor/modules/commons/rest-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/service/RestClientPropertiesDSLTest.kt
+++ b/ms/blueprintsprocessor/modules/commons/rest-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/rest/service/RestClientPropertiesDSLTest.kt
@@ -17,43 +17,60 @@
 package org.onap.ccsdk.cds.blueprintsprocessor.rest.service
 
 import org.junit.Test
-import org.onap.ccsdk.cds.blueprintsprocessor.rest.dslBasicAuthRestClientProperties
-import org.onap.ccsdk.cds.blueprintsprocessor.rest.dslSSLRestClientProperties
-import org.onap.ccsdk.cds.blueprintsprocessor.rest.dslTokenAuthRestClientProperties
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.relationshipTemplateRestClient
+import org.onap.ccsdk.cds.blueprintsprocessor.rest.relationshipTypeConnectsToRestClient
 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.relationshipTypeConnectsTo
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.serviceTemplate
+import kotlin.test.assertEquals
 import kotlin.test.assertNotNull
 
 class RestClientPropertiesDSLTest {
 
     @Test
-    fun testBasicAuthRestClientProperties() {
-        val properties = BluePrintTypes.dslBasicAuthRestClientProperties {
-            url("http://localhost:8080")
-            username("xxxxx")
-            password("******")
-        }
-        assertNotNull(properties, "failed to get dslBasicAuthRestClientProperties")
-    }
+    fun testRestClientProperties() {
 
-    @Test
-    fun testBasicTokenAuthRestClientProperties() {
-        val properties = BluePrintTypes.dslTokenAuthRestClientProperties {
-            url("http://localhost:8080")
-            token("sdfgfsadgsgf")
+        val serviceTemplate = serviceTemplate("rest-properties-test", "1.0.0", "xxx.@xx.com", "rest") {
+            topologyTemplate {
+                relationshipTemplateRestClient("sample-basic-auth", "") {
+                    basicAuth {
+                        url("http://localhost:8080")
+                        username("xxxxx")
+                        password("******")
+                    }
+                }
+                relationshipTemplateRestClient("sample-token-auth", "") {
+                    tokenAuth {
+                        url("http://localhost:8080")
+                        token("sdfgfsadgsgf")
+                    }
+                }
+                relationshipTemplateRestClient("sample-ssl-auth", "") {
+                    sslAuth {
+                        url("http://localhost:8080")
+                        keyStoreInstance("instance")
+                        sslTrust("sample-trust")
+                        sslTrustPassword("sample-trust-password")
+                        sslKey("sample-sslkey")
+                        sslKeyPassword("sample-key-password")
+                    }
+                }
+            }
+            relationshipTypes(
+                arrayListOf(
+                    BluePrintTypes.relationshipTypeConnectsToRestClient(),
+                    BluePrintTypes.relationshipTypeConnectsTo()
+                )
+            )
         }
-        assertNotNull(properties, "failed to get dslTokenAuthRestClientProperties")
-    }
 
-    @Test
-    fun testDslSSLRestClientProperties() {
-        val properties = BluePrintTypes.dslSSLRestClientProperties {
-            url("http://localhost:8080")
-            keyStoreInstance("instance")
-            sslTrust("sample-trust")
-            sslTrustPassword("sample-trust-password")
-            sslKey("sample-sslkey")
-            sslKeyPassword("sample-key-password")
-        }
-        assertNotNull(properties, "failed to get dslSSLRestClientProperties")
+        // println(serviceTemplate.asJsonString(true))
+        assertNotNull(serviceTemplate, "failed to create service template")
+        val relationshipTemplates = serviceTemplate.topologyTemplate?.relationshipTemplates
+        assertNotNull(relationshipTemplates, "failed to get relationship templates")
+        assertEquals(3, relationshipTemplates.size, "relationshipTemplates doesn't match")
+        assertNotNull(relationshipTemplates["sample-basic-auth"], "failed to get sample-basic-auth")
+        assertNotNull(relationshipTemplates["sample-token-auth"], "failed to get sample-token-auth")
+        assertNotNull(relationshipTemplates["sample-ssl-auth"], "failed to get sample-ssl-auth")
     }
 }
diff --git a/ms/blueprintsprocessor/modules/commons/ssh-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/ssh/SshPropertiesDSL.kt b/ms/blueprintsprocessor/modules/commons/ssh-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/ssh/SshPropertiesDSL.kt
new file mode 100644
index 000000000..e63f2eb49
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/ssh-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/ssh/SshPropertiesDSL.kt
@@ -0,0 +1,101 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.ssh
+
+import com.fasterxml.jackson.databind.JsonNode
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintConstants
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive
+import org.onap.ccsdk.cds.controllerblueprints.core.asJsonType
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipType
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.PropertiesAssignmentBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.RelationshipTemplateBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.TopologyTemplateBuilder
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.relationshipType
+
+/** Relationships Types DSL for Message Producer */
+fun BluePrintTypes.relationshipTypeConnectsToSshClient(): RelationshipType {
+    return relationshipType(
+        id = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_SSH_CLIENT,
+        version = BluePrintConstants.DEFAULT_VERSION_NUMBER,
+        derivedFrom = BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO,
+        description = "Relationship connects to through SSH Client."
+    ) {
+        property(
+            BluePrintConstants.PROPERTY_CONNECTION_CONFIG,
+            BluePrintConstants.DATA_TYPE_MAP,
+            true,
+            "Connection Config details."
+        )
+        validTargetTypes(arrayListOf(BluePrintConstants.MODEL_TYPE_CAPABILITY_TYPE_ENDPOINT))
+    }
+}
+
+/** Relationships Templates for Ssh */
+fun TopologyTemplateBuilder.relationshipTemplateSshClient(
+    name: String,
+    description: String,
+    block: SshRelationshipTemplateBuilder.() -> Unit
+) {
+    if (relationshipTemplates == null) relationshipTemplates = hashMapOf()
+    val relationshipTemplate = SshRelationshipTemplateBuilder(name, description).apply(block).build()
+    relationshipTemplates!![relationshipTemplate.id!!] = relationshipTemplate
+}
+
+open class SshRelationshipTemplateBuilder(name: String, description: String) :
+    RelationshipTemplateBuilder(
+        name,
+        BluePrintConstants.MODEL_TYPE_RELATIONSHIPS_CONNECTS_TO_SSH_CLIENT, description
+    ) {
+
+    fun basicAuth(block: BasicAuthSshClientPropertiesAssignmentBuilder.() -> Unit) {
+        property(BluePrintConstants.PROPERTY_CONNECTION_CONFIG, BluePrintTypes.basicAuthSshProperties(block))
+    }
+}
+
+fun BluePrintTypes.basicAuthSshProperties(block: BasicAuthSshClientPropertiesAssignmentBuilder.() -> Unit): JsonNode {
+    val sshProperties = BasicAuthSshClientPropertiesAssignmentBuilder().apply(block).build()
+    sshProperties[SshClientProperties::type.name] = SshLibConstants.TYPE_BASIC_AUTH.asJsonPrimitive()
+    return sshProperties.asJsonType()
+}
+
+open class SshClientPropertiesAssignmentBuilder : PropertiesAssignmentBuilder() {
+
+    fun connectionTimeOut(connectionTimeOut: Int) = connectionTimeOut(connectionTimeOut.asJsonPrimitive())
+
+    fun connectionTimeOut(connectionTimeOut: JsonNode) =
+        property(SshClientProperties::connectionTimeOut.name, connectionTimeOut)
+
+    fun port(port: Int) = port(port.asJsonPrimitive())
+
+    fun port(port: JsonNode) = property(SshClientProperties::port.name, port)
+
+    fun host(host: String) = host(host.asJsonPrimitive())
+
+    fun host(host: JsonNode) = property(SshClientProperties::host.name, host)
+}
+
+class BasicAuthSshClientPropertiesAssignmentBuilder : SshClientPropertiesAssignmentBuilder() {
+
+    fun username(username: String) = username(username.asJsonPrimitive())
+
+    fun username(username: JsonNode) = property(BasicAuthSshClientProperties::username.name, username)
+
+    fun password(password: String) = password(password.asJsonPrimitive())
+
+    fun password(password: JsonNode) = property(BasicAuthSshClientProperties::password.name, password)
+}
diff --git a/ms/blueprintsprocessor/modules/commons/ssh-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/ssh/SshPropertiesDSLTest.kt b/ms/blueprintsprocessor/modules/commons/ssh-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/ssh/SshPropertiesDSLTest.kt
new file mode 100644
index 000000000..bc4355357
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/commons/ssh-lib/src/test/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/ssh/SshPropertiesDSLTest.kt
@@ -0,0 +1,56 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.ssh
+
+import org.junit.Test
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.relationshipTypeConnectsTo
+import org.onap.ccsdk.cds.controllerblueprints.core.dsl.serviceTemplate
+import kotlin.test.assertEquals
+import kotlin.test.assertNotNull
+
+class SshPropertiesDSLTest {
+
+    @Test
+    fun testSshPropertiesDSL() {
+        val serviceTemplate = serviceTemplate("ssh-properties-test", "1.0.0", "xxx.@xx.com", "ssh") {
+            topologyTemplate {
+                relationshipTemplateSshClient("sample-basic-auth", "SSH Connection") {
+                    basicAuth {
+                        username("sample-user")
+                        password("sample-password")
+                        host("sample-host")
+                        connectionTimeOut(30)
+                    }
+                }
+            }
+            relationshipTypes(
+                arrayListOf(
+                    BluePrintTypes.relationshipTypeConnectsToSshClient(),
+                    BluePrintTypes.relationshipTypeConnectsTo()
+                )
+            )
+        }
+
+        assertNotNull(serviceTemplate, "failed to create service template")
+        val relationshipTemplates = serviceTemplate.topologyTemplate?.relationshipTemplates
+        assertNotNull(relationshipTemplates, "failed to get relationship templates")
+        assertEquals(1, relationshipTemplates.size, "relationshipTemplates doesn't match")
+        assertNotNull(relationshipTemplates["sample-basic-auth"], "failed to get sample-basic-auth")
+        // println(serviceTemplate.asJsonString(true))
+    }
+}
diff --git a/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintRelationshipTemplateEnhancerImpl.kt b/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintRelationshipTemplateEnhancerImpl.kt
new file mode 100644
index 000000000..c208f68e5
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintRelationshipTemplateEnhancerImpl.kt
@@ -0,0 +1,69 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.designer.api.enhancer
+
+import org.onap.ccsdk.cds.blueprintsprocessor.designer.api.utils.BluePrintEnhancerUtils
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipTemplate
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintRelationshipTemplateEnhancer
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintRepoService
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintTypeEnhancerService
+import org.onap.ccsdk.cds.controllerblueprints.core.logger
+import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintContext
+import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintRuntimeService
+import org.springframework.beans.factory.config.ConfigurableBeanFactory
+import org.springframework.context.annotation.Scope
+import org.springframework.stereotype.Service
+
+@Service
+@Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE)
+open class BluePrintRelationshipTemplateEnhancerImpl(
+    private val bluePrintRepoService: BluePrintRepoService,
+    private val bluePrintTypeEnhancerService: BluePrintTypeEnhancerService
+) :
+    BluePrintRelationshipTemplateEnhancer {
+
+    private val log = logger(BluePrintRelationshipTemplateEnhancerImpl::class)
+
+    lateinit var bluePrintRuntimeService: BluePrintRuntimeService<*>
+    lateinit var bluePrintContext: BluePrintContext
+
+    override fun enhance(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        relationshipTemplate: RelationshipTemplate
+    ) {
+        log.info("***** Enhancing RelationshipTemplate($name)")
+        this.bluePrintRuntimeService = bluePrintRuntimeService
+        this.bluePrintContext = bluePrintRuntimeService.bluePrintContext()
+
+        val relationshipTypeName = relationshipTemplate.type
+        // Get RelationshipType from Repo and Update Service Template
+        val relationshipType =
+            BluePrintEnhancerUtils.populateRelationshipType(
+                bluePrintContext,
+                bluePrintRepoService,
+                relationshipTypeName
+            )
+
+        // Enrich NodeType
+        bluePrintTypeEnhancerService.enhanceRelationshipType(
+            bluePrintRuntimeService,
+            relationshipTypeName,
+            relationshipType
+        )
+    }
+}
diff --git a/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintRelationshipTypeEnhancerImpl.kt b/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintRelationshipTypeEnhancerImpl.kt
new file mode 100644
index 000000000..b0e166090
--- /dev/null
+++ b/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintRelationshipTypeEnhancerImpl.kt
@@ -0,0 +1,87 @@
+/*
+ * Copyright © 2018-2019 AT&T Intellectual Property.
+ *
+ * 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 at
+ *
+ *     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.
+ */
+
+package org.onap.ccsdk.cds.blueprintsprocessor.designer.api.enhancer
+
+import org.onap.ccsdk.cds.blueprintsprocessor.designer.api.utils.BluePrintEnhancerUtils
+import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintTypes
+import org.onap.ccsdk.cds.controllerblueprints.core.data.RelationshipType
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintRelationshipTypeEnhancer
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintRepoService
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintTypeEnhancerService
+import org.onap.ccsdk.cds.controllerblueprints.core.logger
+import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintContext
+import org.onap.ccsdk.cds.controllerblueprints.core.service.BluePrintRuntimeService
+import org.springframework.beans.factory.config.ConfigurableBeanFactory
+import org.springframework.context.annotation.Scope
+import org.springframework.stereotype.Service
+
+@Service
+@Scope(value = ConfigurableBeanFactory.SCOPE_PROTOTYPE)
+open class BluePrintRelationshipTypeEnhancerImpl(
+    private val bluePrintRepoService: BluePrintRepoService,
+    private val bluePrintTypeEnhancerService: BluePrintTypeEnhancerService
+) : BluePrintRelationshipTypeEnhancer {
+
+    private val log = logger(BluePrintRelationshipTypeEnhancerImpl::class)
+
+    lateinit var bluePrintRuntimeService: BluePrintRuntimeService<*>
+    lateinit var bluePrintContext: BluePrintContext
+
+    override fun enhance(
+        bluePrintRuntimeService: BluePrintRuntimeService<*>,
+        name: String,
+        relationshipType: RelationshipType
+    ) {
+        this.bluePrintRuntimeService = bluePrintRuntimeService
+        this.bluePrintContext = bluePrintRuntimeService.bluePrintContext()
+
+        val derivedFrom = relationshipType.derivedFrom
+
+        if (!BluePrintTypes.rootRelationshipTypes().contains(derivedFrom)) {
+            val derivedFromRelationshipType =
+                BluePrintEnhancerUtils.populateRelationshipType(bluePrintContext, bluePrintRepoService, name)
+            // Enrich RelationshipType
+            enhance(bluePrintRuntimeService, derivedFrom, derivedFromRelationshipType)
+        }
+
+        // NodeType Attribute Definitions
+        enrichRelationshipTypeAttributes(name, relationshipType)
+
+        // NodeType Property Definitions
+        enrichRelationshipTypeProperties(name, relationshipType)
+
+        // TODO("Interface Enrichment, If needed")
+    }
+
+    open fun enrichRelationshipTypeAttributes(nodeTypeName: String, relationshipType: RelationshipType) {
+        relationshipType.attributes?.let {
+            bluePrintTypeEnhancerService.enhanceAttributeDefinitions(
+                bluePrintRuntimeService,
+                relationshipType.attributes!!
+            )
+        }
+    }
+
+    open fun enrichRelationshipTypeProperties(nodeTypeName: String, relationshipType: RelationshipType) {
+        relationshipType.properties?.let {
+            bluePrintTypeEnhancerService.enhancePropertyDefinitions(
+                bluePrintRuntimeService,
+                relationshipType.properties!!
+            )
+        }
+    }
+}
diff --git a/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintTopologyTemplateEnhancerImpl.kt b/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintTopologyTemplateEnhancerImpl.kt
index c0100fbea..750cd0ff4 100644
--- a/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintTopologyTemplateEnhancerImpl.kt
+++ b/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintTopologyTemplateEnhancerImpl.kt
@@ -40,6 +40,7 @@ open class BluePrintTopologyTemplateEnhancerImpl(
 
         enhanceTopologyTemplateInputs(type)
         enhanceTopologyTemplateNodeTemplates(type)
+        enhanceTopologyTemplateRelationshipTemplates(type)
         enhanceTopologyTemplateWorkflows(type)
     }
 
@@ -55,6 +56,16 @@ open class BluePrintTopologyTemplateEnhancerImpl(
         }
     }
 
+    open fun enhanceTopologyTemplateRelationshipTemplates(topologyTemplate: TopologyTemplate) {
+        topologyTemplate.relationshipTemplates?.forEach { relationshipTemplateName, relationshipTemplate ->
+            bluePrintTypeEnhancerService.enhanceRelationshipTemplate(
+                bluePrintRuntimeService,
+                relationshipTemplateName,
+                relationshipTemplate
+            )
+        }
+    }
+
     open fun enhanceTopologyTemplateWorkflows(topologyTemplate: TopologyTemplate) {
         topologyTemplate.workflows?.forEach { workflowName, workflow ->
             bluePrintTypeEnhancerService.enhanceWorkflow(bluePrintRuntimeService, workflowName, workflow)
diff --git a/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintTypeEnhancerServiceImpl.kt b/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintTypeEnhancerServiceImpl.kt
index 5b7c6b2d0..c27c206fa 100644
--- a/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintTypeEnhancerServiceImpl.kt
+++ b/ms/blueprintsprocessor/modules/inbounds/designer-api/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/designer/api/enhancer/BluePrintTypeEnhancerServiceImpl.kt
@@ -22,6 +22,8 @@ import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintNodeTemp
 import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintNodeTypeEnhancer
 import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintPolicyTypeEnhancer
 import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintPropertyDefinitionEnhancer
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintRelationshipTemplateEnhancer
+import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintRelationshipTypeEnhancer
 import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintServiceTemplateEnhancer
 import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintTopologyTemplateEnhancer
 import org.onap.ccsdk.cds.controllerblueprints.core.interfaces.BluePrintTypeEnhancerService
@@ -56,6 +58,14 @@ open class BluePrintTypeEnhancerServiceImpl : BluePrintTypeEnhancerService {
         return context.getBeansOfType(BluePrintNodeTypeEnhancer::class.java).map { it.value }
     }
 
+    override fun getRelationshipTemplateEnhancers(): List<BluePrintRelationshipTemplateEnhancer> {
+        return context.getBeansOfType(BluePrintRelationshipTemplateEnhancer::class.java).map { it.value }
+    }
+
+    override fun getRelationshipTypeEnhancers(): List<BluePrintRelationshipTypeEnhancer> {
+        return context.getBeansOfType(BluePrintRelationshipTypeEnhancer::class.java).map { it.value }
+    }
+
     override fun getArtifactDefinitionEnhancers(): List<BluePrintArtifactDefinitionEnhancer> {
         return context.getBeansOfType(BluePrintArtifactDefinitionEnhancer::class.java).map { it.value }
     }