anchor.diff:  		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");
  
positive.code: 						else
  							currentStage++;
  					}
  					x = variableContext.getParameter("output_op");
  					if (x != null && x.equals("Add"))
  					{
  
negative.code: 						}
  					}
  
  					for (int j = 0; j < job.countNotifications(); j++)
  					{
  						INotificationConnection notificationConnection = notificationManager.load(job.getNotificationConnectionName(j));
  						if (notificationConnection != null)
  						{
  							INotificationConnector notificationConnector = notificationConnectorPool.grab(notificationConnection);
  							if (notificationConnector != null)
  							{
  								try
  								{
  									String error = notificationConnector.processSpecificationPost(variableContext,pageContext.getRequest().getLocale(),job.getNotificationSpecification(j),1+job.countPipelineStages()+j);
  									if (error != null)
  									{
  										variableContext.setParameter("text",error);
  										variableContext.setParameter("target","listjobs.jsp");
  %>
  									<jsp:forward page="error.jsp"/>
  <%
  									}
  								}
  								finally
  								{
  									notificationConnectorPool.release(notificationConnection,notificationConnector);
  								}
  							}
  						}
  					}
  					
  					// Now, after gathering is complete, consider doing changes to the pipeline.
  					int currentStage = 0;
  					for (int j = 0; j < job.countPipelineStages(); j++)
  