/*******************************************************************************
 * Copyright (c) 2014 Markus Alexander Kuppe 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:
 *   Markus Alexander Kuppe - initial API and implementation
 ******************************************************************************/
package org.eclipse.ecf.tests.discovery.listener;

import org.eclipse.ecf.discovery.IDiscoveryLocator;
import org.eclipse.ecf.discovery.IServiceEvent;

public class ThreadTestServiceListener extends TestServiceListener {

	private volatile Thread currentThread;

	public Thread getCallingThread() {
		return currentThread;
	}

	/* (non-Javadoc)
	 * @see org.eclipse.ecf.tests.discovery.listener.TestServiceListener#triggerDiscovery()
	 */
	public boolean triggerDiscovery() {
		return true;
	}

	public ThreadTestServiceListener(int eventsToExpect,
			IDiscoveryLocator aLocator, String testName, String testId) {
		super(eventsToExpect, aLocator, testName, testId);
	}

	public void serviceDiscovered(IServiceEvent anEvent) {
		if (matchesExpected(anEvent)) {
			currentThread = Thread.currentThread();
			super.serviceDiscovered(anEvent);
		}
	}
}