anchor.diff:  							String connectionName = variableContext.getParameter("pipeline_"+j+"_connectionname");
   							String description = variableContext.getParameter("pipeline_"+j+"_description");
   							job.addPipelineStage(precedent, isOutput, connectionName, description);
  +						}
  +					}
  +					x = variableContext.getParameter("notification_count");
  +					if (x != null)
  +					{
  +						// Do we need to keep the old specifications around, or can we destroy them?
  +						// Not clear that retention is required., so I'm not wasting time trying to implement that.
  +						int count = Integer.parseInt(x);
  +						job.clearNotifications();
  +						for (int j = 0; j < count; j++)
  +						{
  +							// Gather everything first; we'll look at edits later
  +							String connectionName = variableContext.getParameter("notification_"+j+"_connectionname");
  +							String description = variableContext.getParameter("notification_"+j+"_description");
  +							job.addNotification(connectionName, description);
   						}
   					}
   
  
positive.code: 						else
  							currentStage++;
  					}
  					x = variableContext.getParameter("output_op");
  					if (x != null && x.equals("Add"))
  					{
  
negative.code: 		IOutputConnectorPool outputConnectorPool = OutputConnectorPoolFactory.make(threadContext);
  		ITransformationConnectorPool transformationConnectorPool = TransformationConnectorPoolFactory.make(threadContext);
  		IRepositoryConnectorPool repositoryConnectorPool = RepositoryConnectorPoolFactory.make(threadContext);
  		INotificationConnectorPool notificationConnectorPool = NotificationConnectorPoolFactory.make(threadContext);
  		
  		String type = variableContext.getParameter("type");
  		String op = variableContext.getParameter("op");
  