examples/bundles/org.eclipse.ecf.examples.loadbalancing.ds.consumer/src/org/eclipse/ecf/examples/internal/loadbalancing/ds/consumer/DataProcessorClientComponent.java

/****************************************************************************
 * Copyright (c) 2010 Composent, Inc. and others.
 *
 * This program and the accompanying materials are made
 * available under the terms of the Eclipse Public License 2.0
 * which is available at https://www.eclipse.org/legal/epl-2.0/
 *
 * Contributors:
 *   Composent, Inc. - initial API and implementation
 *
 * SPDX-License-Identifier: EPL-2.0
 *****************************************************************************/
package org.eclipse.ecf.examples.internal.loadbalancing.ds.consumer;

import org.eclipse.ecf.examples.loadbalancing.IDataProcessor;
import org.eclipse.ecf.examples.loadbalancing.IDataProcessorAsync;
import org.eclipse.ecf.remoteservice.IAsyncCallback;

public class DataProcessorClientComponent {

	public void bind(IDataProcessor dataProcessor) {
		System.out.println("Got data processor on client");
		final String data = "Here's some data from a client";
		// Use it
		System.out.println("Invoking data processor");
		String result = dataProcessor.processData(data);
		System.out.println("Sync result="+result);
		System.out.println();
		// See if we've got an async interface and if so, use it
		if (dataProcessor instanceof IDataProcessorAsync) {
			IDataProcessorAsync dpAsync = (IDataProcessorAsync) dataProcessor;
			System.out.println("Got async data processor on client");
			IAsyncCallback<String> callback = new IAsyncCallback<String>() {
				public void onSuccess(String result) {
					System.out.println("Async result="+result);
				}
				public void onFailure(Throwable exception) {
					System.out.println("Async invoke failed with exception");
					if (exception != null) exception.printStackTrace();
				}
				
			};
			// Now invoke async
			dpAsync.processDataAsync(data, callback);
		}
	}
}