<extension-point id="taskJobListeners" name="org.eclipse.mylyn.tasks.core" schema="schema/taskJobListeners.exsd"/>

<?xml version='1.0' encoding='UTF-8'?>

<!-- Schema file written by PDE -->

<schema targetNamespace="org.eclipse.mylyn.tasks.core" xmlns="http://www.w3.org/2001/XMLSchema">

<annotation>

      <appInfo>

         <meta.schema plugin="org.eclipse.mylyn.tasks.core" id="taskJobListeners" name="org.eclipse.mylyn.tasks.core"/>

      </appInfo>

      <documentation>

         Provides notification of task submission.

      </documentation>

   </annotation>

   <element name="extension">

      <annotation>

         <appInfo>

            <meta.element />

         </appInfo>

      </annotation>

      <complexType>

         <sequence minOccurs="1" maxOccurs="unbounded">

            <element ref="listener"/>

         </sequence>

         <attribute name="point" type="string" use="required">

            <annotation>

               <documentation>

               </documentation>

            </annotation>

         </attribute>

         <attribute name="id" type="string">

            <annotation>

               <documentation>

               </documentation>

            </annotation>

         </attribute>

         <attribute name="name" type="string">

            <annotation>

               <documentation>

               </documentation>

               <appInfo>

                  <meta.attribute translatable="true"/>

               </appInfo>

            </annotation>

         </attribute>

      </complexType>

   </element>

   <element name="listener">

      <complexType>

         <attribute name="name" type="string">

            <annotation>

               <documentation>

               </documentation>

            </annotation>

         </attribute>

         <attribute name="connectorKind" type="string">

            <annotation>

               <documentation>

                  If specified, the listener is only notified about submits for the specified connector. Otherwise, it is notified about all submits.

               </documentation>

            </annotation>

         </attribute>

         <attribute name="class" type="string">

            <annotation>

               <documentation>

               </documentation>

               <appInfo>

                  <meta.attribute kind="java" basedOn="org.eclipse.mylyn.tasks.core.TaskJobListener:"/>

               </appInfo>

            </annotation>

         </attribute>

      </complexType>

   </element>

   <annotation>

      <appInfo>

         <meta.section type="since"/>

      </appInfo>

      <documentation>

         3.7

      </documentation>

   </annotation>

   <annotation>

      <appInfo>

         <meta.section type="copyright"/>

      </appInfo>

      <documentation>

         Copyright (c) 2004, 2009 Tasktop Technologies and others.

All rights reserved. This program and the accompanying materials

are made available under the terms of the Eclipse Public License v1.0

which accompanies this distribution, and is available at

http://www.eclipse.org/legal/epl-v10.html

      </documentation>

   </annotation>

</schema>

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.eclipse.mylyn.tasks.core.TaskJobListener;

	private static final String ALL_CONNECTORS = "org.eclipse.mylyn.tasks.core.all.connectors"; //$NON-NLS-1$

	/**

	 * listeners provided by extension point

	 */

	private static Map<String, List<TaskJobListener>> taskJobListeners;

	protected static synchronized List<TaskJobListener> getTaskJobListeners(AbstractRepositoryConnector connector) {

		if (taskJobListeners == null) {

			taskJobListeners = new HashMap<String, List<TaskJobListener>>();

			List<TaskJobListener> listeners = loadTaskJobListeners(""); //$NON-NLS-1$

			taskJobListeners.put(ALL_CONNECTORS, listeners);

		}

		if (taskJobListeners.get(connector.getConnectorKind()) == null) {

			List<TaskJobListener> listeners = loadTaskJobListeners(connector.getConnectorKind());

			taskJobListeners.put(connector.getConnectorKind(), listeners);

		}

		List<TaskJobListener> listeners = new ArrayList<TaskJobListener>();

		listeners.addAll(taskJobListeners.get(ALL_CONNECTORS));

		listeners.addAll(taskJobListeners.get(connector.getConnectorKind()));

		return listeners;

	}

	protected static List<TaskJobListener> loadTaskJobListeners(String connectorKind) {

		ExtensionPointReader<TaskJobListener> reader = new ExtensionPointReader<TaskJobListener>(

				ITasksCoreConstants.ID_PLUGIN,

				"taskJobListeners", "listener", TaskJobListener.class, "connectorKind", connectorKind); //$NON-NLS-1$ //$NON-NLS-2$ //$NON-NLS-3$

		IStatus status = reader.read();

		if (!status.isOK()) {

			StatusHandler.log(status);

		}

		return reader.getItems();

	}

import java.util.Collections;

import java.util.List;

import org.eclipse.core.runtime.ISafeRunnable;

import org.eclipse.core.runtime.SafeRunner;

import org.eclipse.mylyn.tasks.core.TaskJobEvent;

import org.eclipse.mylyn.tasks.core.TaskJobListener;

	private final ITask originalTask;

	private final List<TaskJobListener> taskJobListeners;

		this(taskDataManager, connector, taskRepository, task, taskData, oldAttributes,

				Collections.<TaskJobListener> emptyList());

	}

	public SubmitTaskJob(TaskDataManager taskDataManager, AbstractRepositoryConnector connector,

			TaskRepository taskRepository, ITask task, TaskData taskData, Set<TaskAttribute> oldAttributes,

			List<TaskJobListener> taskJobListeners) {

		this.originalTask = task;

		this.taskJobListeners = taskJobListeners;

				fireTaskSubmissionComplete();

	protected void fireTaskAboutToSubmit() {

		for (final TaskJobListener listener : taskJobListeners) {

			SafeRunner.run(new ISafeRunnable() {

				public void run() throws Exception {

					listener.aboutToSubmit(new TaskJobEvent(originalTask, task));

				}

				public void handleException(Throwable e) {

					StatusHandler.log(new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN,

							"Error thrown by TaskJobListener", e)); //$NON-NLS-1$

				}

			});

		}

	}

	protected void fireTaskSubmissionComplete() {

		for (final TaskJobListener listener : taskJobListeners) {

			SafeRunner.run(new ISafeRunnable() {

				public void run() throws Exception {

					listener.taskSubmitted(new TaskJobEvent(originalTask, task));

				}

				public void handleException(Throwable e) {

					StatusHandler.log(new Status(IStatus.ERROR, ITasksCoreConstants.ID_PLUGIN,

							"Error thrown by TaskJobListener", e)); //$NON-NLS-1$

				}

			});

		}

	}

/*******************************************************************************

 * Copyright (c) 2012 Tasktop Technologies and others.

 * All rights reserved. This program and the accompanying materials

 * are made available under the terms of the Eclipse Public License v1.0

 * which accompanies this distribution, and is available at

 * http://www.eclipse.org/legal/epl-v10.html

 *

 * Contributors:

 *     Tasktop Technologies - initial API and implementation

 *******************************************************************************/

package org.eclipse.mylyn.tasks.core;

/**

 * @author Sam Davis

 */

public class TaskJobEvent {

	private final ITask task;

	private final ITask originalTask;

	public TaskJobEvent(ITask originalTask, ITask task) {

		this.originalTask = originalTask;

		this.task = task;

	}

	/**

	 * @return the original task that was submitted

	 */

	public ITask getOriginalTask() {

		return originalTask;

	}

	/**

	 * @return the task that exists after submission has completed; will be the same as originalTask unless originalTask

	 *         was a new (previously unsubmitted) task and this is a submission complete event

	 */

	public ITask getTask() {

		return task;

	}

}

/*******************************************************************************

 * Copyright (c) 2012 Tasktop Technologies and others.

 * All rights reserved. This program and the accompanying materials

 * are made available under the terms of the Eclipse Public License v1.0

 * which accompanies this distribution, and is available at

 * http://www.eclipse.org/legal/epl-v10.html

 *

 * Contributors:

 *     Tasktop Technologies - initial API and implementation

 *******************************************************************************/

package org.eclipse.mylyn.tasks.core;

import org.eclipse.mylyn.tasks.core.sync.SubmitJob;

import org.eclipse.mylyn.tasks.core.sync.SubmitJobListener;

/**

 * Clients can contribute an implementation of this class to be notified of all task submissions for a particular

 * connector, or all connectors. Implementations can be contributed using the taskJobListeners extension point. See also

 * {@link SubmitJobListener} if you only need to be notified about specific {@link SubmitJob}s.

 * 

 * @author Sam Davis

 */

public abstract class TaskJobListener {

	/**

	 * Called when a task is about to be submitted. Note that the submission may fail after this call due to network

	 * error, invalid credentials, etc.

	 * 

	 * @param event

	 */

	public abstract void aboutToSubmit(TaskJobEvent event);

	/**

	 * Called after a submission has completed successfully.

	 * 

	 * @param event

	 */

	public abstract void taskSubmitted(TaskJobEvent event);

}