anchor.diff:  						}
   					}
   
  +					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++)
  
positive.code: 		IOutputConnectorPool outputConnectorPool = OutputConnectorPoolFactory.make(threadContext);
  		ITransformationConnectorPool transformationConnectorPool = TransformationConnectorPoolFactory.make(threadContext);
  		IRepositoryConnectorPool repositoryConnectorPool = RepositoryConnectorPoolFactory.make(threadContext);
  		
  		String type = variableContext.getParameter("type");
  		String op = variableContext.getParameter("op");
  
negative.code: 						else
  							currentStage++;
  					}
  
  					x = variableContext.getParameter("output_op");
  					if (x != null && x.equals("Add"))
  					{
  