Initialize message exchanges of physical infrastructure scope.

tools.descartes.prisma.core/src/tools/descartes/prisma/core/scopes/PhysicalInfrastructureScope.java

@@ -8,6 +8,7 @@ import edu.kit.ipd.descartes.mm.resourcelandscape.DataCenter;
 import edu.kit.ipd.descartes.mm.resourcelandscape.DistributedDataCenter;
 import edu.kit.ipd.descartes.mm.resourcelandscape.ResourcelandscapeFactory;
 import tools.descartes.prisma.core.MessageBus;
+import tools.descartes.prisma.core.MessageBus.ExchangeType;
 import tools.descartes.prisma.core.ModelRepository;
 import tools.descartes.prisma.core.Transaction;
 import tools.descartes.prisma.core.adapter.ModelSkeletonAdapter;
@@ -34,6 +35,18 @@ public class PhysicalInfrastructureScope extends InfrastructureScope {
 		return dataCenter;
 	}
 
+	public String getComputeNodeExchange() {
+		return this.getName() + ".ComputeNode";
+	}
+
+	public String getStorageNodeExchange() {
+		return this.getName() + ".StorageNode";
+	}
+
+	public String getHypervisorExchange() {
+		return this.getName() + ".Hypervisor";
+	}
+
 	protected String getDataCenterPath() {
 		return PHYSICAL_INFRASTRUCTURE_SCOPE_TYPE + "/" + getName() + "/" + getName() + DATACENTER_SUFFIX;
 	}
@@ -77,4 +90,13 @@ public class PhysicalInfrastructureScope extends InfrastructureScope {
 		return PHYSICAL_INFRASTRUCTURE_SCOPE_TYPE;
 	}
 
+	@Override
+	protected void createMessageExchanges() {
+		super.createMessageExchanges();
+
+		getMessageBus().createExchange(getComputeNodeExchange(), ExchangeType.DIRECT);
+		getMessageBus().createExchange(getStorageNodeExchange(), ExchangeType.DIRECT);
+		getMessageBus().createExchange(getHypervisorExchange(), ExchangeType.DIRECT);
+	}
+
 }