diff --git a/AlgebraicDataflowArchitectureModel/src/generators/JerseyMethodBodyGenerator.java b/AlgebraicDataflowArchitectureModel/src/generators/JerseyMethodBodyGenerator.java
index bedb738..ae6062b 100644
--- a/AlgebraicDataflowArchitectureModel/src/generators/JerseyMethodBodyGenerator.java
+++ b/AlgebraicDataflowArchitectureModel/src/generators/JerseyMethodBodyGenerator.java
@@ -520,6 +520,52 @@
 													srcUpdate.addStatement(getHttpMethodParamsStatement(srcComponent.getTypeName(), params, false));
 													srcUpdate.addStatement("result = " + getHttpMethodCallStatement(baseURL, dstPath, srcResName, httpMethod));
 												}
+												if (descendantDstChannels.contains(chNode)) {
+													// For hierarchical channels (broadcasting push transfer).
+													if (ch.getSelectors() != null && ch.getSelectors().size() > 0) {
+														Expression selExp = ch.getSelectors().get(0).getExpression();
+														Type selType = null;
+														String varName = null;
+														if (selExp instanceof Variable) {
+															selType = ((Variable) selExp).getType();
+															varName = ((Variable) selExp).getName();
+															ChannelMember insideChMem = null;
+															for (ChannelMember cm :ch.getInputChannelMembers()) {
+																if (!cm.isOutside()) {
+																	insideChMem = cm;
+																	break;
+																}
+															}
+															if (insideChMem == null) {
+																for (ChannelMember cm :ch.getReferenceChannelMembers()) {
+																	if (!cm.isOutside()) {
+																		insideChMem = cm;
+																		break;
+																	}
+																}
+															}
+															ResourcePath insideResPath = insideChMem.getResource();
+															while (insideResPath.getParent() != null && (insideResPath.getNumberOfParameters() == 0 || !insideResPath.getLastParam().equals(selExp))) {
+																insideResPath = insideResPath.getParent();
+															}
+															insideResPath = insideResPath.getParent();
+															String parent = JerseyCodeGenerator.pullAccessor.getDirectStateAccessorFor(insideResPath, src.getPrimaryResourcePath()).toImplementation(new String[] {});
+															if (insideResPath != null) {
+																if (selType.equals(DataConstraintModel.typeInt)) {
+																	// make a for loop (for a list) for broadcasting.
+																	srcUpdate.addFirstStatement("for (int " + varName + " = 0; " + varName +" < " + parent + ".size(); " + varName + "++) {");
+																	srcUpdate.addStatement("}");
+																} else if (selType.equals(DataConstraintModel.typeString)) {
+																	// make a for loop (for a map) for broadcasting.
+																	srcUpdate.addFirstStatement("for (String " + varName + ": " + parent + ".keySet()) {");
+																	srcUpdate.addStatement("}");
+																}
+															}
+														} else if (selExp instanceof Term) {
+															// not supported.
+														}
+													}
+												}
 												srcUpdate.addThrow("JsonProcessingException");
 											} else {
 												// Inner-service
@@ -637,6 +683,52 @@
 												srcInput.addStatement(getHttpMethodParamsStatement(srcComponent.getTypeName(), params, false));
 												srcInput.addStatement("result = " + getHttpMethodCallStatement(baseURL, dstPath, srcResName, httpMethod));
 											}
+											if (descendantDstChannels.contains(chNode)) {
+												// For hierarchical channels (broadcasting push transfer).
+												if (ch.getSelectors() != null && ch.getSelectors().size() > 0) {
+													Expression selExp = ch.getSelectors().get(0).getExpression();
+													Type selType = null;
+													String varName = null;
+													if (selExp instanceof Variable) {
+														selType = ((Variable) selExp).getType();
+														varName = ((Variable) selExp).getName();
+														ChannelMember insideChMem = null;
+														for (ChannelMember cm :ch.getInputChannelMembers()) {
+															if (!cm.isOutside()) {
+																insideChMem = cm;
+																break;
+															}
+														}
+														if (insideChMem == null) {
+															for (ChannelMember cm :ch.getReferenceChannelMembers()) {
+																if (!cm.isOutside()) {
+																	insideChMem = cm;
+																	break;
+																}
+															}
+														}
+														ResourcePath insideResPath = insideChMem.getResource();
+														while (insideResPath.getParent() != null && (insideResPath.getNumberOfParameters() == 0 || !insideResPath.getLastParam().equals(selExp))) {
+															insideResPath = insideResPath.getParent();
+														}
+														insideResPath = insideResPath.getParent();
+														String parent = JerseyCodeGenerator.pullAccessor.getDirectStateAccessorFor(insideResPath, src.getPrimaryResourcePath()).toImplementation(new String[] {});
+														if (insideResPath != null) {
+															if (selType.equals(DataConstraintModel.typeInt)) {
+																// make a for loop (for a list) for broadcasting.
+																srcInput.addFirstStatement("for (int " + varName + " = 0; " + varName +" < " + parent + ".size(); " + varName + "++) {");
+																srcInput.addStatement("}");
+															} else if (selType.equals(DataConstraintModel.typeString)) {
+																// make a for loop (for a map) for broadcasting.
+																srcInput.addFirstStatement("for (String " + varName + ": " + parent + ".keySet()) {");
+																srcInput.addStatement("}");
+															}
+														}
+													} else if (selExp instanceof Term) {
+														// not supported.
+													}
+												}
+											}
 											srcInput.addThrow("JsonProcessingException");
 										} else {
 											// Inner-service