diff --git a/AlgebraicDataflowArchitectureModel/src/generators/JavaCodeGenerator.java b/AlgebraicDataflowArchitectureModel/src/generators/JavaCodeGenerator.java
index 7e60d6f..dd19cc1 100644
--- a/AlgebraicDataflowArchitectureModel/src/generators/JavaCodeGenerator.java
+++ b/AlgebraicDataflowArchitectureModel/src/generators/JavaCodeGenerator.java
@@ -473,4 +473,25 @@
 			return getter;
 		}
 	};
+	static public IResourceStateAccessor refAccessor = new IResourceStateAccessor() {
+		@Override
+		public Expression getCurrentStateAccessorFor(ResourcePath target, ResourcePath from) {
+			if (target.equals(from)) {
+				return new Field("value",
+						target.getResourceStateType() != null ? target.getResourceStateType()
+								: DataConstraintModel.typeInt);
+			}
+			// for reference channel member
+			return new Parameter(target.getResourceName(),
+					target.getResourceStateType() != null ? target.getResourceStateType()
+							: DataConstraintModel.typeInt);
+		}
+
+		@Override
+		public Expression getNextStateAccessorFor(ResourcePath target, ResourcePath from) {
+			return new Parameter(target.getResourceName(),
+					target.getResourceStateType() != null ? target.getResourceStateType()
+							: DataConstraintModel.typeInt);
+		}
+	};
 }
diff --git a/AlgebraicDataflowArchitectureModel/src/generators/JavaMethodBodyGenerator.java b/AlgebraicDataflowArchitectureModel/src/generators/JavaMethodBodyGenerator.java
index 234b802..a22f1cd 100644
--- a/AlgebraicDataflowArchitectureModel/src/generators/JavaMethodBodyGenerator.java
+++ b/AlgebraicDataflowArchitectureModel/src/generators/JavaMethodBodyGenerator.java
@@ -65,7 +65,21 @@
 							MethodDeclaration update = getUpdateMethod(dstType, srcType);
 							if (((StoreAttribute) dst.getAttribute()).isStored()) {
 								// update stored state of dst side resource (when every incoming edge is in push style)
-								Expression updateExp = d.getChannel().deriveUpdateExpressionOf(out, JavaCodeGenerator.pushAccessor);									
+								Expression updateExp = null;
+								if (d.getChannel().getReferenceChannelMembers().size() == 0) {
+									updateExp = d.getChannel().deriveUpdateExpressionOf(out, JavaCodeGenerator.pushAccessor);									
+								} else {
+									// if there exists one or more reference channel member.
+									HashMap<ResourcePath, IResourceStateAccessor> inputResourceToStateAccessor = new HashMap<>();
+									for (Edge eIn: dst.getInEdges()) {
+										DataFlowEdge dIn = (DataFlowEdge) eIn;
+										inputResourceToStateAccessor.put(((ResourceNode) dIn.getSource()).getResource(), JavaCodeGenerator.pushAccessor);
+									}
+									for (ChannelMember c: d.getChannel().getReferenceChannelMembers()) {
+										inputResourceToStateAccessor.put(c.getResource(), JavaCodeGenerator.refAccessor);
+									}
+									updateExp = d.getChannel().deriveUpdateExpressionOf(out, JavaCodeGenerator.pushAccessor, inputResourceToStateAccessor);
+								}
 								String[] sideEffects = new String[] {""};
 								String curState = updateExp.toImplementation(sideEffects);
 								String updateStatement;
diff --git a/AlgebraicDataflowArchitectureModel/src/generators/JerseyCodeGenerator.java b/AlgebraicDataflowArchitectureModel/src/generators/JerseyCodeGenerator.java
index af56da8..672ce4b 100644
--- a/AlgebraicDataflowArchitectureModel/src/generators/JerseyCodeGenerator.java
+++ b/AlgebraicDataflowArchitectureModel/src/generators/JerseyCodeGenerator.java
@@ -359,4 +359,25 @@
 							: DataConstraintModel.typeInt);
 		}
 	};
+	static public IResourceStateAccessor refAccessor = new IResourceStateAccessor() {
+		@Override
+		public Expression getCurrentStateAccessorFor(ResourcePath target, ResourcePath from) {
+			if (target.equals(from)) {
+				return new Field("value",
+						target.getResourceStateType() != null ? target.getResourceStateType()
+								: DataConstraintModel.typeInt);
+			}
+			// for reference channel member
+			return new Parameter(target.getResourceName(),
+					target.getResourceStateType() != null ? target.getResourceStateType()
+							: DataConstraintModel.typeInt);
+		}
+
+		@Override
+		public Expression getNextStateAccessorFor(ResourcePath target, ResourcePath from) {
+			return new Parameter(target.getResourceName(),
+					target.getResourceStateType() != null ? target.getResourceStateType()
+							: DataConstraintModel.typeInt);
+		}
+	};
 }
diff --git a/AlgebraicDataflowArchitectureModel/src/generators/JerseyMethodBodyGenerator.java b/AlgebraicDataflowArchitectureModel/src/generators/JerseyMethodBodyGenerator.java
index d06a757..5e4cb77 100644
--- a/AlgebraicDataflowArchitectureModel/src/generators/JerseyMethodBodyGenerator.java
+++ b/AlgebraicDataflowArchitectureModel/src/generators/JerseyMethodBodyGenerator.java
@@ -82,7 +82,7 @@
 										inputResourceToStateAccessor.put(((ResourceNode) dIn.getSource()).getResource(), JerseyCodeGenerator.pushAccessor);
 									}
 									for (ChannelMember c: d.getChannel().getReferenceChannelMembers()) {
-										inputResourceToStateAccessor.put(c.getResource(), JerseyCodeGenerator.pullAccessor);
+										inputResourceToStateAccessor.put(c.getResource(), JerseyCodeGenerator.refAccessor);
 									}
 									updateExp = d.getChannel().deriveUpdateExpressionOf(out, JerseyCodeGenerator.pushAccessor, inputResourceToStateAccessor);
 								}