ode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a..@apache.org
Subject svn commit: r381686 [14/40] - in /incubator/ode/scratch/bpe: ./ bpelTests/ bpelTests/probeService/ bpelTests/test1/ bpelTests/test10/ bpelTests/test12/ bpelTests/test13/ bpelTests/test14/ bpelTests/test15/ bpelTests/test16/ bpelTests/test17/ bpelTests/...
Date Tue, 28 Feb 2006 16:05:47 GMT
Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/IVariable.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/IVariable.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/IVariable.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/IVariable.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,53 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client;
+
+import java.util.Collection;
+
+
+/**
+ * Exposes variable level command and control operations.
+ */
+public interface IVariable
+{
+	/**
+	 * Get a collection of handles to parts contained in the variable.
+	 * @return
+	 * A collection of parts.
+	 * @throws CCException
+	 */
+	public Collection getParts() throws CCException;
+	/**
+	 * Get a handle to the scope that contains the variable.
+	 * @return
+	 * @throws CCException
+	 */
+	public IScope getScope() throws CCException;
+	/**
+	 * Get the name of the variable.
+	 * @return
+	 * The name of the variable.
+	 * @throws CCException
+	 */
+	public String getName() throws CCException;
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/IVariablePart.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/IVariablePart.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/IVariablePart.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/IVariablePart.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,52 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client;
+
+
+
+/**
+ * Exposes variable part level operations.
+ */
+public interface IVariablePart
+{
+	/**
+	 * Get the value contained in the part.
+	 * @return
+	 * The value object.
+	 * @throws CCException
+	 */
+	public Object getValue() throws CCException;
+	/**
+	 * Get the name of the variable part.
+	 * @return
+	 * The name of the variable part.
+	 * @throws CCException
+	 */
+	public String getName() throws CCException;
+	/**
+	 * Get a handle to the variable that contains the part.
+	 * @return
+	 * @throws CCException
+	 */
+	public IVariable getVariable() throws CCException;
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/InstanceState.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/InstanceState.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/InstanceState.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/InstanceState.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,115 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client;
+
+import java.io.ObjectStreamException;
+import java.io.Serializable;
+
+
+/**
+ * Represents enumerated states of the process instance.
+ */
+public class InstanceState implements Serializable
+{
+    static final long serialVersionUID = 4860370316474738334L;
+    
+	private final String m_state;
+	private final int m_intState;
+	private InstanceState( String iState, int iIntState )
+	{
+		m_state = iState;
+		m_intState = iIntState;
+	}
+	
+	public String toString()
+	{
+		return m_state;
+	}
+	
+	public int toInt()
+	{
+		return m_intState;
+	}
+	
+	/*
+	   private static final int STARTED_INT = 1;
+	   private static final int UNSTARTED_INT = 2;
+	   private static final int PAUSED_INT = 3;
+	   private static final int FINISHED_INT = 4;
+	   private static final int TERMINATED_INT = 5;
+	   private static final int RUNNING_INT = 6;
+	   */
+	
+	public static final int STARTED_CONST = 1;
+	public static final int PAUSED_CONST = 3;
+	public static final int FINISHED_CONST = 4;
+	public static final int TERMINATED_CONST = 5;
+	public static final int RUNNING_CONST = 6;
+	public static final int UNKNOWN_CONST = -1;
+	
+	public static final InstanceState STARTED = 
+		new InstanceState( "Started", STARTED_CONST);
+	public static final InstanceState RUNNING = 
+		new InstanceState( "Running", RUNNING_CONST);
+	public static final InstanceState PAUSED = 
+		new InstanceState("Paused", PAUSED_CONST);
+	public static final InstanceState FINISHED = 
+		new InstanceState("Finished", FINISHED_CONST);
+	public static final InstanceState TERMINATED =
+	    new InstanceState("Terminated", TERMINATED_CONST);
+	public static final InstanceState UNKNOWN =
+		new InstanceState("Unknown", UNKNOWN_CONST);
+	
+	private Object readResolve() throws 
+	  ObjectStreamException
+	  {
+	    	switch( m_intState )
+	    	{
+	    		case(STARTED_CONST):
+	    		{
+	    		    return STARTED;
+	    		}
+	    		case(RUNNING_CONST):
+	    		{
+	    		    return RUNNING;
+	    		}
+	    		case(PAUSED_CONST):
+	    		{
+	    		    return PAUSED;
+	    		}
+	    		case(FINISHED_CONST):
+	    		{
+	    		    return FINISHED;
+	    		}
+	    		case(TERMINATED_CONST):
+	    		{
+	    		    return TERMINATED;
+	    		}
+	    		case(UNKNOWN_CONST):
+	    		{
+	    		    return UNKNOWN;
+	    		}
+	    	}
+	    	return UNKNOWN;    	
+	  }
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/UnsupportedBundleException.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/UnsupportedBundleException.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/UnsupportedBundleException.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/UnsupportedBundleException.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,33 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client;
+
+
+public class UnsupportedBundleException extends CCException
+{
+	static final long serialVersionUID = 1836839893097971493L;
+	
+	public UnsupportedBundleException()
+	{
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/ejbproxy/CCClientProxyBean.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/ejbproxy/CCClientProxyBean.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/ejbproxy/CCClientProxyBean.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/ejbproxy/CCClientProxyBean.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,497 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+package com.sybase.bpe.cc.client.ejbproxy;
+
+import java.rmi.RemoteException;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import javax.ejb.CreateException;
+import javax.ejb.EJBException;
+import javax.ejb.SessionBean;
+import javax.ejb.SessionContext;
+
+import com.sybase.bpe.cc.client.CCClient;
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.IDefinition;
+import com.sybase.bpe.cc.client.IEngine;
+import com.sybase.bpe.cc.client.IInstance;
+
+/**
+ * This bean is a flattened abstraction of the Command and Control
+ * client's "tiered facade" class hierarchy.  This bean is intended
+ * to support JMX exposure of its management operations, and thus
+ * does not implement server-side interfaces nor utilize complex
+ * parameter data types in its public API.
+ * 
+ * @ejb:bean 
+ *		description="CCClient proxy implemented as an EJB"
+ *		jndi-name="BPE/CCClientProxy"
+ *		name="CCClientProxy"
+ *		type="Stateless"
+ *		view-type="both"
+ *		local-jndi-name="BPE/CCClientProxyLocal"
+ * 
+ * @ejb.transaction type="Required"
+ **/
+public class CCClientProxyBean implements SessionBean
+{
+	static final long serialVersionUID = -577190264022194039L;
+	
+	/** The logger. **/
+	private static Logger ms_logger = Logger.getLogger(
+			CCClientProxyBean.class.getName() );
+	
+	/** Session context. **/
+//	private SessionContext m_context = null;
+
+	/** ctor **/
+	public CCClientProxyBean()
+	{
+	}
+
+	//========================================================================
+	// Session bean methods
+	//========================================================================
+
+	/**
+	 * Create EJB.
+	 * @ejb.create-method
+	 **/
+	public void ejbCreate()
+		throws CreateException
+	{
+	}
+
+	/**
+	 * Remove EJB.
+	 **/
+	public void ejbRemove()
+		throws EJBException, RemoteException
+	{
+	}
+
+	/**
+	 * Activate EJB.
+	 **/
+	public void ejbActivate()
+		throws EJBException, RemoteException
+	{
+	}
+
+	/**
+	 * Passivate EJB.
+	 **/
+	public void ejbPassivate()
+		throws EJBException, RemoteException
+	{
+	}
+
+	/**
+	 * Set EJB session context.
+	 **/
+	public void setSessionContext( SessionContext ctx )
+		throws EJBException, RemoteException
+	{
+//		m_context = ctx;
+	}
+
+	//========================================================================
+	// Private methods
+	//========================================================================
+
+	/**
+	 * Get BP engine associated with specified package/engine name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * 
+	 * @return BP engine associated with specified package name.
+	 * 
+	 * @throws CCException on error.
+	 **/
+	private IEngine getEngine( String pkgName )
+		throws CCException
+	{
+		ms_logger.log( Level.FINEST, "Obtaining reference to BP engine \""
+				+ pkgName + "\"" );
+
+		CCClient client = new CCClient();
+
+		HashMap props = new HashMap();
+		props.put( IEngine.ENGINE_NAME, pkgName );
+
+		return client.getEngine( props );
+	}
+
+	/**
+	 * Get specified BP definition.
+	 * 
+	 * @param engine BP engine to query.
+	 * @param name BP definition name.
+	 * 
+	 * @return BP definition or null if specified definition
+	 * name was not found.
+	 * 
+	 * @throws CCException on error.
+	 **/
+	private IDefinition getDefinition( IEngine engine, String name )
+		throws CCException
+	{
+		// Note: IEngine.getDefinition() not yet implemented!
+		
+		Collection definitions = engine.getDefinitions();
+		for ( Iterator i = definitions.iterator(); i.hasNext(); )
+		{
+			IDefinition def = (IDefinition) i.next();
+			if ( def.getName().equals(name) )
+				return def;
+		}
+		
+		return null;
+	}
+
+	//========================================================================
+	// Business methods
+	//========================================================================
+
+	/**
+	 * Return human-readable name of BP engine associated
+	 * with specified package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @return BP engine human-readable name string.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public String getName( String pkgName )
+		throws Exception
+	{
+		try
+		{
+			return getEngine( pkgName ).getName();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to get name of BP Engine \""
+					+ pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+	
+	/**
+	 * Return state of BP engine associated with
+	 * specified package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @return BP engine state string.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public String getState( String pkgName )
+		throws Exception
+	{
+		try
+		{
+			return getEngine( pkgName ).getState().toString();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to get state of BP Engine \""
+					+ pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+	
+	/**
+	 * Return statistics of BP engine associated with
+	 * specified package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @return BP engine statistics map.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public Map getStatistics( String pkgName )
+		throws Exception
+	{
+		try
+		{
+			return getEngine( pkgName ).getStatistics();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to get statistics of BP Engine \""
+					+ pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+
+	/**
+	 * Pause BP engine associated with specified package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public void pause( String pkgName )
+		throws Exception
+	{
+		try
+		{
+			getEngine( pkgName ).pause();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to pause BP Engine \"" + pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new CreateException( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+
+	/**
+	 * Resume BP engine associated with specified package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public void resume( String pkgName )
+		throws Exception
+	{
+		try
+		{
+			getEngine( pkgName ).resume();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to resume BP Engine \"" + pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+	
+	/**
+	 * Return names of all BP definitions hosted by the BP engine
+	 * associated with specified package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @return Collection of BP definition name strings.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public Collection getDefinitions( String pkgName )
+		throws Exception
+	{
+		Collection names = new ArrayList();
+		
+		try
+		{
+			Collection definitions = getEngine( pkgName ).getDefinitions();
+			for ( Iterator i = definitions.iterator(); i.hasNext(); )
+			{
+				IDefinition def = (IDefinition) i.next();
+				names.add( def.getName() );
+			}
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to get BP Definitions from BP Engine \""
+					+ pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+		
+		return names;
+	}
+
+	/**
+	 * Pause/deactivate the specified BP definition of the
+	 * BP engine associated with the given package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @param defName Name of BP definition to pause.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public void pauseDefinition( String pkgName, String defName )
+		throws Exception
+	{
+		try
+		{
+			IEngine engine = getEngine( pkgName );
+			IDefinition def = getDefinition( engine, defName );
+			def.deactivate();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to pause BP Definition \"" + defName + "\""
+					+ " of BP Engine \"" + pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+
+	/**
+	 * Resume/activate the specified BP definition of the
+	 * BP engine associated with the specifed package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @param defName Name of BP definition to resume.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public void resumeDefinition( String pkgName, String defName )
+		throws Exception
+	{
+		try
+		{
+			IEngine engine = getEngine( pkgName );
+			IDefinition def = getDefinition( engine, defName );
+			def.deactivate();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to resume BP Definition \"" + defName + "\""
+					+ " of BP Engine \"" + pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+
+	/**
+	 * Return all instances of specified BP definition of
+	 * BP engine associated with given package name.
+	 *
+	 * @param pkgName Package name of engine.
+	 * @param defName Name of BP definition to query.
+	 * @return Collection of BP instance ID strings.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public Collection getInstances( String pkgName, String defName )
+		throws Exception
+	{
+		Collection ids = new ArrayList();
+	
+		try
+		{
+			IEngine engine = getEngine( pkgName );
+			IDefinition def = getDefinition( engine, defName );
+
+			Collection instances = def.getInstances();
+			for ( Iterator i = instances.iterator(); i.hasNext(); )
+			{
+				IInstance inst = (IInstance) i.next();
+				ids.add( inst.getID() );
+			}
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to get instances of BP Definition \""
+					+ defName + "\" from BP Engine \"" + pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+		
+		return ids;
+	}
+
+	/**
+	 * Pause the specified BP instance of the BP Engine associated
+	 * with the given package name.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @param id ID of instance to pause.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public void pauseInstance( String pkgName, String id )
+		throws Exception
+	{
+		try
+		{
+			IInstance inst = getEngine( pkgName ).getInstance( id );
+			inst.pause();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to pause BP Instance \"" + id + "\""
+					+ " of BP Engine \"" + pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+
+	/**
+	 * Resume the specified BP instance.
+	 * 
+	 * @param pkgName Package name of engine.
+	 * @param id ID of instance to resume.
+	 * @throws Exception on CC Client system error.
+	 * 
+	 * @ejb.interface-method
+	 **/
+	public void resumeInstance( String pkgName, String id )
+		throws Exception
+	{
+		try
+		{
+			IInstance inst = getEngine( pkgName ).getInstance( id );
+			inst.resume();
+		}
+		catch ( CCException e )
+		{
+			String msg = "Failed to resume BP Instance \"" + id + "\""
+					+ " of BP Engine \"" + pkgName + "\"";
+			ms_logger.log( Level.SEVERE, msg, e );
+			throw new Exception( msg + ". Exception: " + e
+					+ ", Cause: " +	e.getCause() );
+		}
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ChildScope.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ChildScope.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ChildScope.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ChildScope.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,47 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.IChildScope;
+import com.sybase.bpe.cc.client.IInstance;
+import com.sybase.bpe.cc.client.IScope;
+import com.sybase.bpe.cc.data.ScopeData;
+import com.sybase.bpe.cc.service.ICCService;
+
+
+public class ChildScope extends Scope implements IChildScope
+{
+	private IScope m_parentScope;
+
+	public ChildScope(ICCService service, IInstance instance, IScope parentScope, ScopeData cdata)
+	{
+		super(service, instance, cdata);
+		m_parentScope = parentScope;
+	}
+
+	public IScope getParentScope() throws CCException
+	{
+		return m_parentScope;
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Definition.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Definition.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Definition.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Definition.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,121 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.Map;
+
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.DefinitionState;
+import com.sybase.bpe.cc.client.IDefinition;
+import com.sybase.bpe.cc.client.IEngine;
+import com.sybase.bpe.cc.data.DefinitionData;
+import com.sybase.bpe.cc.data.InstanceData;
+import com.sybase.bpe.cc.data.OperationData;
+import com.sybase.bpe.cc.service.ICCService;
+
+
+public class Definition extends ServiceNode implements IDefinition
+{
+	private DefinitionData m_data;
+//	private ICCService m_ccservice;
+	private IEngine m_engine;
+
+	public Definition(ICCService service, Engine engine, DefinitionData ddata)
+	{
+		super( service );
+		m_engine = engine;
+		m_data = ddata;
+
+	}
+	public void deactivate() throws CCException
+	{
+		getService().deactivateDefinition( m_data );
+	}
+	public void activate() throws CCException
+	{
+		getService().activateDefinition( m_data );
+	}
+	public void remove() throws CCException
+	{
+		getService().removeDefinition( m_data );
+	}
+	public DefinitionState getState() throws CCException
+	{
+		return m_data.getState();
+	}
+	public Collection getInstances() throws CCException
+	{
+		Collection instances = getService().getInstancesData( 
+				m_data.getID() );
+		Iterator instanceIter = instances.iterator();
+		LinkedList instancelist = new LinkedList();
+		while( instanceIter.hasNext() )
+		{
+			InstanceData instanceData = 
+				( InstanceData )( instanceIter.next());
+			instanceData.setDefinitionID(m_data.getID());
+			
+			Instance newInstance = 
+				new Instance( getService(), this, instanceData );
+			instancelist.add( newInstance );
+		}
+		return instancelist;
+	}
+	public String getName() throws CCException
+	{
+		return m_data.getName();
+	}
+	public String getID() throws CCException
+	{
+		return m_data.getID();
+	}
+	public IEngine getEngine() throws CCException
+	{
+		return m_engine;
+	}
+	public Map getStatistics() throws CCException
+	{
+		Map statistics = 
+			getService().getDefinitionStatistics(m_data);
+		return statistics;
+	}
+    public Collection getProcessCreatingOperations() throws CCException
+    {
+        LinkedList returnCollection = new LinkedList();
+        Collection operationData = 
+            getService().getProcessCreatingOperations(m_data);
+        
+        Iterator iter = operationData.iterator();
+        while( iter.hasNext() )
+        {
+            OperationData opData = (OperationData )(iter.next());
+            ProcessCreatingOperation pco = 
+                new ProcessCreatingOperation(opData);
+            returnCollection.add(pco);
+        }
+        return returnCollection;
+    }
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Engine.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Engine.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Engine.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Engine.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,226 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import java.util.Collection;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.Map;
+
+import com.sybase.bpe.bped.DeployTypeEnum;
+import com.sybase.bpe.bped.EventDirector;
+import com.sybase.bpe.bped.EventDirectorFactory;
+import com.sybase.bpe.bped.IDeployer;
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.EngineState;
+import com.sybase.bpe.cc.client.IBPELBundle;
+import com.sybase.bpe.cc.client.IBundle;
+import com.sybase.bpe.cc.client.IDefinition;
+import com.sybase.bpe.cc.client.IDefinitionQuery;
+import com.sybase.bpe.cc.client.IEngine;
+import com.sybase.bpe.cc.client.IInstance;
+import com.sybase.bpe.cc.client.UnsupportedBundleException;
+import com.sybase.bpe.cc.data.DefinitionData;
+import com.sybase.bpe.cc.data.EngineData;
+import com.sybase.bpe.cc.data.InstanceData;
+import com.sybase.bpe.cc.service.CCServiceFactory;
+import com.sybase.bpe.cc.service.ICCService;
+import com.sybase.bpe.util.BPException;
+
+public class Engine implements IEngine
+{
+	private ICCService m_CCService = null;
+	private EngineData m_data = null;
+	private HashMap iCreationalParameters;
+	
+	Engine( HashMap iCreationalParameters ) throws CCException
+	{
+		this.iCreationalParameters = iCreationalParameters;
+		String engineName = (String)iCreationalParameters.get(ENGINE_NAME);
+		if (engineName != null ) {
+			m_CCService = 
+				CCServiceFactory.newInstance().createCCService(engineName);			
+		} else {
+			m_CCService = 
+				CCServiceFactory.newInstance().createCCService();
+		}
+		m_data = getService().getEngineData();
+	}
+	
+	ICCService getService()
+	{
+		return m_CCService;
+	}
+	
+	
+	public void pause() throws CCException
+	{
+		getService().pauseEngine();
+	}
+
+	public void resume() throws CCException
+	{
+		getService().resumeEngine();
+	}
+	
+	public EngineState getState() throws CCException
+	{
+		return m_data.getState();
+	}
+	
+	public Collection getDefinitions() throws CCException
+	{
+		Collection defData = getService().getDefinitionData();
+		Iterator defDataIter = defData.iterator();
+		LinkedList definitions = new LinkedList();
+		while( defDataIter.hasNext())
+		{
+			Definition newDef = new Definition( getService(), this, ( DefinitionData ) 
+					( defDataIter.next()));
+			definitions.add(newDef);
+		}
+		return definitions;
+	}
+	
+	public void deployBundle(IBundle source) throws CCException
+	{
+		// TODO: We should really move this deployment in closer to the
+		// core of the engine.  For now simply forward the request
+		// to the existing interfaces.
+//		Collection keys;
+		try
+		{ 
+			EventDirector eventDirector;
+			if ( iCreationalParameters != null && 
+					iCreationalParameters.get(ENGINE_NAME) != null ) {
+				eventDirector = EventDirectorFactory
+					.createEventDirectorCached((String)iCreationalParameters.get(ENGINE_NAME));
+			} else {
+				eventDirector = EventDirectorFactory
+				.createEventDirectorCached();		
+			}
+			
+			if ( source instanceof IBPELBundle )
+			{
+				IBPELBundle bpelBundle = ( IBPELBundle ) ( source );
+				IDeployer deployer = eventDirector.getDeployer(DeployTypeEnum.BPEL);
+				if ( bpelBundle.isStream() ) {
+					deployer.loadDefinition(bpelBundle.getAsInputStream(), false);
+				} 
+				else 
+				{
+					deployer.loadDefinition(bpelBundle.getResourcePath(), false);
+				}
+			}
+			else
+			{
+				throw new UnsupportedBundleException();
+			}
+		}
+		catch (BPException e)
+		{
+			throw new CCException(e);
+		}
+	}
+	
+	public void cleanupNow() throws CCException
+	{
+		getService().cleanupNow();
+	}
+	
+	public IInstance getInstance(String iInstanceID) throws CCException
+	{
+		InstanceData instanceData =  
+			getService().getInstanceData( iInstanceID );
+		DefinitionData dd = 
+			getService().getDefinitionForInstance( iInstanceID );
+		Definition def = new Definition( getService(), this, dd );
+		Instance instance = new Instance(getService(), 
+				def, instanceData);
+		return instance;
+	}
+
+	
+	public String getName() throws CCException
+	{
+		String engineName = m_data.getName();
+		return engineName;
+	}
+	
+	public String getID() throws CCException
+	{
+		String id = m_data.getID();
+		return id;
+	}
+
+	public IDefinition getDefinition(IDefinitionQuery query) throws CCException
+	{
+		// TODO: propagate the query structure down further into the CC layer.
+		String definitionName = 
+			query.getQueryProperties().
+			  getProperty(IDefinitionQuery.DEFINITION_NAME);
+		
+		DefinitionData defData = getService().getDefinitionData( definitionName );
+		Definition newDef = new Definition( getService(), this, defData );
+		return newDef;
+	}
+
+	public void cleanup(Date iCompletionDate) throws CCException
+	{
+		getService().cleanCompletedSince( iCompletionDate );
+		
+	}
+
+	public void setAutomaticCleanup(boolean iAutomaticCleanup) throws CCException
+	{
+		getService().setAutomaticCleanup( iAutomaticCleanup );
+		
+	}
+
+	public boolean getAutomaticCleanup()
+	{
+		// TODO Auto-generated method stub
+		return m_data.getAutomaticCleanup();
+	}
+
+	public Map getStatistics() throws CCException
+	{
+		Map statistics = getService().getEngineStatistics( m_data);
+		return statistics;
+	}
+
+    public boolean isBootstrapped() throws CCException
+    {
+        Collection defs = getDefinitions();
+        if ( defs.size() > 0 )
+        {
+            return true;
+        }
+        else
+        {
+            return false;
+        }      
+    }
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/EngineFactory.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/EngineFactory.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/EngineFactory.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/EngineFactory.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,37 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import java.util.HashMap;
+
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.IEngine;
+
+public class EngineFactory
+{
+	public static IEngine createEngine(HashMap iCreationalParameters)
+	  throws CCException
+	{
+		return new Engine( iCreationalParameters );
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Instance.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Instance.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Instance.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Instance.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,113 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.Map;
+
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.IDefinition;
+import com.sybase.bpe.cc.client.IInstance;
+import com.sybase.bpe.cc.client.IScope;
+import com.sybase.bpe.cc.client.InstanceState;
+import com.sybase.bpe.cc.data.InstanceData;
+import com.sybase.bpe.cc.data.RegistrationData;
+import com.sybase.bpe.cc.data.ScopeData;
+import com.sybase.bpe.cc.service.ICCService;
+
+
+public class Instance extends ServiceNode implements IInstance
+{
+	IDefinition m_definition;
+	InstanceData m_data;
+	
+	public Instance(ICCService service, Definition definition, 
+			InstanceData instanceData)
+	{
+		super( service );
+		m_definition = definition;
+		m_data = instanceData;
+	}
+	public void pause() throws CCException
+	{
+		getService().pauseInstance( m_data );
+	}
+	public void terminate() throws CCException
+	{
+		getService().terminateInstance(m_data);
+	}
+	public void resume() throws CCException
+	{
+		getService().resumeInstance(m_data);
+	}
+	public void remove() throws CCException
+	{
+		getService().removeInstance( m_data );
+	}
+	public InstanceState getState() throws CCException
+	{
+		return m_data.getState();
+	}
+	public String getID() throws CCException
+	{
+		return m_data.getID();
+	}
+	public IDefinition getDefinition() throws CCException
+	{
+		return m_definition;
+	}
+	public IScope getRootContext() throws CCException
+	{
+		ScopeData cdata = getService().getContextScopeData
+		  (m_data);
+		if ( cdata == null ) { return null; }
+		Scope newScope = new Scope( getService(), this, 
+			cdata);
+		return newScope;
+	}
+	public Collection getRegistrations() throws CCException
+	{
+		Collection registrations = 
+			getService().getRegistrations( m_data );
+		
+		LinkedList regList = new LinkedList();
+		Iterator iter = registrations.iterator();
+		while( iter.hasNext() )
+		{
+			RegistrationData rd = ( RegistrationData )
+			  ( iter.next() );
+			Registration newRegistration = 
+				new Registration( this, rd );
+			regList.add( newRegistration );
+		}
+		return regList;
+	}
+	public Map getStatistics() throws CCException
+	{
+		Map statistics = 
+			getService().getInstanceStatistics( m_data );
+		return statistics;
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Part.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Part.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Part.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Part.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,56 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.IVariable;
+import com.sybase.bpe.cc.client.IVariablePart;
+import com.sybase.bpe.cc.data.PartData;
+import com.sybase.bpe.cc.service.ICCService;
+
+
+public class Part extends ServiceNode implements IVariablePart
+{
+	private PartData m_data;
+	private IVariable m_variable;
+	public Part( ICCService iService, IVariable iVariable, PartData iData )
+	{
+		super( iService );
+		m_variable = iVariable;
+		m_data = iData;
+	}
+	public Object getValue() throws CCException
+	{
+		Object object = getService().getPartValue(
+				m_data);
+		return object;
+	}
+	public String getName() throws CCException
+	{
+		return m_data.getName();
+	}
+	public IVariable getVariable() throws CCException
+	{
+		return m_variable;
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ProcessCreatingOperation.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ProcessCreatingOperation.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ProcessCreatingOperation.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ProcessCreatingOperation.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,58 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import com.sybase.bpe.cc.client.IProcessCreatingOperation;
+import com.sybase.bpe.cc.data.OperationData;
+
+
+public class ProcessCreatingOperation implements 
+  IProcessCreatingOperation 
+{
+    private OperationData m_data;
+    public ProcessCreatingOperation( OperationData data )
+    {
+        m_data = data;
+    }
+
+    public String getPortType()
+    {
+        return m_data.getPortType();
+    }
+
+    public String getOperationName()
+    {
+        return m_data.getOperation();
+    }
+
+    public String getPortTypeNamespace()
+    {
+        return m_data.getPortTypeNamespace();
+    }
+
+    public String getStaticKey()
+    {
+        return m_data.getStaticKey();
+    }
+
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Registration.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Registration.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Registration.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Registration.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,65 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import com.sybase.bpe.cc.client.IInstance;
+import com.sybase.bpe.cc.client.IRegistration;
+import com.sybase.bpe.cc.data.RegistrationData;
+
+
+public class Registration implements IRegistration
+{
+	private RegistrationData m_data;
+	private IInstance m_instance;
+	
+	public Registration( IInstance iInstance, 
+			RegistrationData iData)
+	{
+		m_instance = iInstance;
+		m_data = iData;
+	}
+	public String getPortType()
+	{
+		return m_data.getPortType();
+	}
+	public String getOperation()
+	{
+		return m_data.getOperation();
+	}
+	public String getTargetNamespace()
+	{
+		return m_data.getTargetNamespace();
+	}
+	public String getDynamicKey()
+	{
+		return m_data.getDynamicKey();
+	}
+	public IInstance getInstance()
+	{
+		return m_instance;
+	}
+	public String getName()
+	{
+		return m_data.getName();
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Scope.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Scope.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Scope.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Scope.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,87 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.LinkedList;
+
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.IInstance;
+import com.sybase.bpe.cc.client.IScope;
+import com.sybase.bpe.cc.data.ScopeData;
+import com.sybase.bpe.cc.data.VariableData;
+import com.sybase.bpe.cc.service.ICCService;
+
+public class Scope extends ServiceNode implements IScope
+{
+	private IInstance m_instance;
+//	private IScope m_parentScope;
+	private ScopeData m_data;
+	public Scope(ICCService service, IInstance instance, 
+			ScopeData cdata)
+	{
+		super(service);
+		m_instance = instance;
+		m_data = cdata;
+	}
+	public Collection getChildScopes() throws CCException
+	{
+		Collection childScopes = getService().getChildScopes(
+				m_data );
+		Iterator iter = childScopes.iterator();
+		LinkedList scopeList = new LinkedList();
+		while( iter.hasNext() )
+		{
+			ScopeData data = ( ScopeData )
+			  ( iter.next() );
+			ChildScope newScope = new ChildScope( getService(), 
+					m_instance, this, data );
+			scopeList.add( newScope );
+		}
+		return scopeList;
+	}
+	public Collection getVariables() throws CCException
+	{
+		Collection variables = getService().getVariables(m_data);
+		
+		Iterator iter = variables.iterator();
+		LinkedList variableList = new LinkedList();
+		while( iter.hasNext())
+		{
+			VariableData vd = (VariableData)( iter.next());
+			Variable newVariable = new Variable( getService(),
+					this, vd );
+			variableList.add(newVariable);
+		}
+		return variableList;
+	}
+	public IInstance getBPInstance() throws CCException
+	{
+		return m_instance;
+	}
+	public String getName() throws CCException
+	{
+		return m_data.getName();
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ServiceNode.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ServiceNode.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ServiceNode.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/ServiceNode.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,41 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import com.sybase.bpe.cc.service.ICCService;
+
+
+
+public class ServiceNode
+{
+	private ICCService m_CCService;
+	public ServiceNode(ICCService service)
+	{
+		m_CCService = service;
+	}
+	protected ICCService getService()
+	{
+		return m_CCService;
+	}
+	
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Variable.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Variable.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Variable.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/client/impl/Variable.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,70 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.client.impl;
+
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.LinkedList;
+
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.IScope;
+import com.sybase.bpe.cc.client.IVariable;
+import com.sybase.bpe.cc.data.PartData;
+import com.sybase.bpe.cc.data.VariableData;
+import com.sybase.bpe.cc.service.ICCService;
+
+
+public class Variable  extends ServiceNode implements IVariable 
+{
+	private VariableData m_data;
+	private IScope m_scope;
+	public Variable( ICCService iService, IScope iScope, 
+			VariableData iData)
+	{
+		super( iService );
+		m_scope = iScope;
+		m_data = iData;
+	}
+	public Collection getParts() throws CCException
+	{
+		Collection partData = getService().getPartData(m_data);
+		LinkedList partList = new LinkedList();
+		Iterator iter = partData.iterator();
+		while( iter.hasNext() )
+		{
+			PartData pd = (PartData)(iter.next());
+			Part part = new Part(getService(),this, pd);
+			partList.add(part);
+		}
+		return partList;
+		
+	}
+	public IScope getScope() throws CCException
+	{
+		return m_scope;
+	}
+	public String getName() throws CCException
+	{
+		return m_data.getName();
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/DefinitionData.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/DefinitionData.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/DefinitionData.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/DefinitionData.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,82 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.data;
+
+import java.io.Serializable;
+
+import com.sybase.bpe.cc.client.DefinitionState;
+
+
+public class DefinitionData implements Serializable
+{
+	
+    static final long serialVersionUID = -2744350622781004507L;
+    
+	private String m_id;
+	private String m_name;
+	private DefinitionState m_state;
+	
+
+	
+	public DefinitionData( String iID, String iName, 
+			  DefinitionState iState )
+	{
+		m_id = iID;
+		m_name = iName;
+		m_state = iState;
+	}
+
+	public DefinitionData()
+	{		
+	}
+	
+	public void setID( String iID )
+	{
+		m_id = iID;
+	}
+	
+	public String getID( )
+	{
+		return m_id;
+	}
+	
+	public void setName(String iName)
+	{
+		m_name = iName;
+	}
+	
+	public String getName()
+	{
+		return m_name;
+	}
+	
+	public void setState( DefinitionState iState )
+	{
+		m_state = iState;
+	}
+	
+	public DefinitionState getState()
+	{
+		return m_state;
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/EngineData.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/EngineData.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/EngineData.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/EngineData.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,88 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.data;
+
+import java.io.Serializable;
+
+import com.sybase.bpe.cc.client.EngineState;
+
+
+public class EngineData implements Serializable
+{
+    static final long serialVersionUID = -1851035273514785141L;
+    
+	private EngineState m_state;
+	private String m_name;
+	private String m_ID;
+	private boolean m_automaticCleanup;
+	
+	public EngineData()
+	{
+		
+	}
+	
+	public EngineData( String iName, String iID, EngineState iState, boolean iAutomaticCleanup )
+	{
+		m_state = iState;
+	}
+	
+	public EngineState getState()
+	{
+		return m_state;
+	}
+	
+	public void  setState( EngineState iState )
+	{
+		m_state = iState;
+	}
+	
+	public void setName( String iName )
+	{
+		m_name = iName;
+	}
+
+	public String getName()
+	{
+		return m_name;
+	}
+	
+	public void setID( String iID )
+	{
+		m_ID = iID;
+	}
+	
+	public String getID()
+	{
+		return m_ID;
+	}
+	
+	public boolean getAutomaticCleanup()
+	{
+		return m_automaticCleanup;
+	}
+	
+	public void setAutomaticCleanup( boolean iAutomaticCleanup )
+	{
+		m_automaticCleanup = iAutomaticCleanup;
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/InstanceData.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/InstanceData.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/InstanceData.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/InstanceData.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,78 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.data;
+
+import java.io.Serializable;
+
+import com.sybase.bpe.cc.client.InstanceState;
+
+
+public class InstanceData implements Serializable
+{
+    static final long serialVersionUID = -1292139018864615305L;
+    
+	private InstanceState m_state;
+	private String m_id;
+	private String m_definitionID;
+	
+	public InstanceData()
+	{	
+	}
+	
+	public InstanceData( String iID, String iDefinitionID, InstanceState iState )
+	{
+		m_id = iID;
+		m_state = iState;
+		m_definitionID = iDefinitionID;
+	}
+	
+	public void setID( String iID )
+	{
+		m_id = iID;
+	}
+	
+	public String getID()
+	{
+		return m_id;
+	}
+	
+	public String getDefinitionID()
+	{
+		return m_definitionID;
+	}
+	
+	public void setDefinitionID( String iDefinitionID )
+	{
+		m_definitionID = iDefinitionID;
+	}
+	
+	public void setState( InstanceState iState )
+	{
+		m_state = iState;
+	}
+	
+	public InstanceState getState()
+	{
+		return m_state;
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/OperationData.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/OperationData.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/OperationData.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/OperationData.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,70 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.data;
+
+import java.io.Serializable;
+
+
+public class OperationData implements Serializable
+{
+	
+    static final long serialVersionUID = 7184233691844807142L;
+    
+    private String m_portTypeNamespace;
+    private String m_portType;
+    private String m_operation;
+    private String m_staticKey;
+    
+    public OperationData( 
+            String portTypeNamespace,
+            String portType,
+            String operation,
+            String staticKey)
+    {
+        m_portTypeNamespace = portTypeNamespace;
+        m_portType = portType;
+        m_operation = operation;
+        m_staticKey = staticKey;
+        
+    }
+    
+    public String getPortTypeNamespace()
+    {
+        return m_portTypeNamespace;
+    }
+    
+    public String getPortType()
+    {
+        return m_portType;
+    }
+    
+    public String getOperation()
+    {
+        return m_operation;
+    }
+    
+    public String getStaticKey()
+    {
+        return m_staticKey;
+    }
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/PartData.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/PartData.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/PartData.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/PartData.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,55 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.data;
+
+import java.io.Serializable;
+
+
+public class PartData implements Serializable
+{
+	
+    static final long serialVersionUID = -7855461618668281086L;
+    
+	private String m_name;
+	
+	public PartData()
+	{
+		
+	}
+	
+	public PartData( String iName )
+	{
+		m_name = iName;
+	}
+	
+	public void setName( String iName )
+	{
+		m_name = iName;
+	}
+	
+	public String getName()
+	{
+		return m_name;
+	}
+	
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/RegistrationData.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/RegistrationData.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/RegistrationData.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/RegistrationData.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,102 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.data;
+
+import java.io.Serializable;
+
+
+public class RegistrationData implements Serializable
+{
+    static final long serialVersionUID = -6816714273398328712L;
+    
+	private InstanceData m_instanceData;
+	private String m_operation;
+	private String m_portType;
+	private String m_targetNamespace;
+	private String m_dynamicKey;
+	private String m_name;
+	
+	public RegistrationData()
+	{
+	}
+	
+	public RegistrationData(InstanceData data, String iName, String operation, 
+			String type,
+			String namespace, String key)
+	{
+		m_instanceData = data;
+		m_operation = operation;
+		m_portType = type;
+		m_targetNamespace = namespace;
+		m_dynamicKey = key;
+	}
+	public String getDynamicKey()
+	{
+		return m_dynamicKey;
+	}
+	public void setDynamicKey(String key)
+	{
+		m_dynamicKey = key;
+	}
+	public InstanceData getInstanceData()
+	{
+		return m_instanceData;
+	}
+	public void setInstanceData(InstanceData data)
+	{
+		m_instanceData = data;
+	}
+	public String getOperation()
+	{
+		return m_operation;
+	}
+	public void setOperation(String operation)
+	{
+		m_operation = operation;
+	}
+	public String getPortType()
+	{
+		return m_portType;
+	}
+	public void setPortType(String type)
+	{
+		m_portType = type;
+	}
+	public String getTargetNamespace()
+	{
+		return m_targetNamespace;
+	}
+	public void setTargetNamespace(String namespace)
+	{
+		m_targetNamespace = namespace;
+	}
+	public String getName()
+	{
+		return m_name;
+	}
+	public void setName( String iName )
+	{
+		m_name = iName;
+	}
+	
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/ScopeData.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/ScopeData.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/ScopeData.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/ScopeData.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,78 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.data;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+
+
+public class ScopeData implements Serializable
+{
+	
+    static final long serialVersionUID = 3436317860567815149L;
+    
+	private String m_instanceID;
+	private ArrayList m_path;
+	private String m_name;
+	
+	public ScopeData()
+	{
+	}
+	
+	public ScopeData( String iInstanceID, ArrayList iPath, String iName )
+	{
+		m_instanceID = iInstanceID;
+		m_path = iPath;
+		m_name = iName;
+	}
+	
+	public String getInstanceID()
+	{
+		return m_instanceID;
+	}
+	
+	public void setInstanceID( String iInstanceID )
+	{
+		m_instanceID = iInstanceID;
+	}
+	
+	public ArrayList getPath()
+	{
+		return m_path;
+	}
+	
+	public void setPath( ArrayList iPath )
+	{
+		m_path = iPath;
+	}
+	
+	public void setName( String iName )
+	{
+		m_name = iName;
+	}
+	
+	public String getName()
+	{
+		return m_name;
+	}
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/VariableData.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/VariableData.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/VariableData.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/data/VariableData.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,67 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.data;
+
+import java.io.Serializable;
+
+
+
+public class VariableData implements Serializable
+{
+	
+    static final long serialVersionUID = 6745387099208735618L;
+    
+	private ScopeData m_scopeData;
+	private String m_name;
+	
+	public VariableData()
+	{
+		
+	}
+	public VariableData( ScopeData iScopeData, String iName)
+	{
+		m_name = iName;
+		m_scopeData = iScopeData;
+	}
+	
+	public String getName()
+	{
+		return m_name;
+	}
+	
+	public void setName( String iName)
+	{
+		m_name = iName;
+	}
+	
+	public ScopeData getScopeData()
+	{
+		return m_scopeData;
+	}
+	
+	public void setScopeData( ScopeData iScopeData )
+	{
+		m_scopeData = iScopeData;
+	}
+	
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/ejb/CCServiceBean.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/ejb/CCServiceBean.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/ejb/CCServiceBean.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/ejb/CCServiceBean.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,124 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.ejb;
+
+import java.rmi.RemoteException;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+import javax.ejb.EJBException;
+import javax.ejb.SessionBean;
+import javax.ejb.SessionContext;
+
+import com.sybase.bpe.bped.EventDirectorFactory;
+import com.sybase.bpe.cc.base.CCServiceBase;
+import com.sybase.bpe.util.BPException;
+
+/**
+ * 
+ * This bean can start definitions.
+ * @ejb:bean 
+ *    type="Stateless"
+ *    name="CCService"
+ *    jndi-name="BPE/CCService"
+ *    view-type="remote"
+ * 
+ * @ejb.transaction type="Required"
+ * 
+ * @ejb.ejb-ref
+ *   --ejb-name="EngineState"
+ *   ejb-name="EngineStateCoarse"
+ * 	view-type="local"
+ *  ref-name="theEngineState"
+ * 
+ * @ejb.ejb-ref
+ *   ejb-name="RegistrationEntity"
+ * 	 view-type="local"
+ *   ref-name="registrationBean"
+ * 
+ * @ejb.ejb-ref
+ *      ejb-name="BPE_CMPBLOB"
+ *  	view-type="local"
+ *  	ref-name="theCMPObjectBean"
+ * 
+ * @ejb.ejb-ref
+ *      ejb-name="BPEventDirector"
+ *  	view-type="local"
+ *  	ref-name="theLocalBPEDBean"
+ * 
+ */
+public class CCServiceBean extends CCServiceBase implements SessionBean
+{
+	
+	static final long serialVersionUID = -1304129724404194169L;
+	
+	
+	private static Logger logger = 
+		Logger.getLogger(CCServiceBean.class.getName());
+	
+	public void setSessionContext(SessionContext arg0) throws EJBException,
+			RemoteException
+	{
+		// TODO Auto-generated method stub
+
+	}
+	/**
+	 * 
+	 * @ejb.create-method
+	 */
+	public void ejbCreate()
+	{
+	}
+
+	/**
+	 * 
+	 * @ejb.interface-method
+	 */
+	public void init(String packageName)
+	{
+		try {
+			eventDirector = EventDirectorFactory.createRemoteEventDirector(packageName,true);
+			m_intED = eventDirector.getIInternalEventDirector();
+		} catch (BPException e) {
+			logger.log(Level.SEVERE,"",e);
+		}
+	}
+	public void ejbRemove() throws EJBException, RemoteException
+	{
+		// TODO Auto-generated method stub
+
+	}
+	public void ejbActivate() throws EJBException, RemoteException
+	{
+		// TODO Auto-generated method stub
+
+	}
+	public void ejbPassivate() throws EJBException, RemoteException
+	{
+		// TODO Auto-generated method stub
+
+	}
+
+
+
+}

Added: incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/ejb/CCServiceRemoteProxy.java
URL: http://svn.apache.org/viewcvs/incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/ejb/CCServiceRemoteProxy.java?rev=381686&view=auto
==============================================================================
--- incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/ejb/CCServiceRemoteProxy.java (added)
+++ incubator/ode/scratch/bpe/src/main/java/com/sybase/bpe/cc/ejb/CCServiceRemoteProxy.java Tue Feb 28 08:02:48 2006
@@ -0,0 +1,461 @@
+/*
+* Confidential property of Sybase, Inc.
+*
+* Copyright 1987 - 2006.
+*
+* Sybase, Inc. All rights reserved.
+*
+* Unpublished rights reserved under U.S. copyright laws.
+*
+* This software contains confidential and trade secret information
+* of Sybase, Inc. Use, duplication or disclosure of the software and
+* documentation by the U.S. Government is subject to restrictions
+* set forth in a license agreement between the Government and Sybase,
+* Inc. or other written agreement specifying the Government's rights
+* to use the software and any applicable FAR provisions, for example,
+* FAR 52.227-19.
+*
+* Sybase, Inc. One Sybase Drive, Dublin, CA 94568, USA
+*
+* http://www.sybase.com
+*/
+
+package com.sybase.bpe.cc.ejb;
+
+import java.rmi.RemoteException;
+import java.util.Collection;
+import java.util.Date;
+import java.util.Map;
+
+import javax.naming.InitialContext;
+import javax.rmi.PortableRemoteObject;
+
+import com.sybase.bpe.cc.client.CCException;
+import com.sybase.bpe.cc.client.IBundle;
+import com.sybase.bpe.cc.data.DefinitionData;
+import com.sybase.bpe.cc.data.EngineData;
+import com.sybase.bpe.cc.data.InstanceData;
+import com.sybase.bpe.cc.data.PartData;
+import com.sybase.bpe.cc.data.ScopeData;
+import com.sybase.bpe.cc.data.VariableData;
+import com.sybase.bpe.cc.service.ICCService;
+
+
+public class CCServiceRemoteProxy implements ICCService
+{
+	private CCService remoteService;
+	public CCServiceRemoteProxy(String pkgName) throws CCException
+	{
+		try
+		{
+		
+			InitialContext ic = new InitialContext();
+			Object o = ic.lookup(pkgName+ "/CCService");
+			CCServiceHome pdHome = (CCServiceHome) PortableRemoteObject
+					.narrow(o, CCServiceHome.class);
+			remoteService = pdHome.create();
+			remoteService.init(pkgName);
+		}
+		catch( Exception e )
+		{
+			throw new CCException(e);
+		}
+		
+			
+	}
+	public Collection getDefinitionData() throws CCException
+	{
+		try
+		{
+			return remoteService.getDefinitionData();
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+		
+	}
+	public Collection getInstancesData(String iDefinitionID) throws CCException
+	{
+		try
+		{
+			return remoteService.getInstancesData(iDefinitionID);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void cleanupNow() throws CCException
+	{
+		try
+		{
+			remoteService.cleanupNow();
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void cleanCompletedSince(Date iDate) throws CCException
+	{
+		try
+		{
+			remoteService.cleanup(iDate);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void pauseEngine() throws CCException
+	{
+		try
+		{
+			remoteService.pauseEngine();
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void resumeEngine() throws CCException
+	{
+		try
+		{
+			remoteService.resumeEngine();
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Collection deployBundle(IBundle source)
+			throws CCException
+	{
+		try
+		{
+			return remoteService.deployBundle(source);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public InstanceData getInstanceData(String instanceID) throws CCException
+	{
+		try
+		{
+			return remoteService.getInstanceData(instanceID);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public DefinitionData getDefinitionData(String definitionID)
+			throws CCException
+	{
+		try
+		{
+			return remoteService.getDefinitionData(definitionID);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void deactivateDefinition(DefinitionData data) throws CCException
+	{
+		try
+		{
+			remoteService.deactivateDefinition(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void activateDefinition(DefinitionData data) throws CCException
+	{
+		try
+		{
+			remoteService.activateDefinition(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void removeDefinition(DefinitionData data) throws CCException
+	{
+		try
+		{
+			remoteService.removeDefinition(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public EngineData getEngineData() throws CCException
+	{
+		try
+		{
+			return remoteService.getEngineData();
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public DefinitionData getDefinitionForInstance(String instanceID)
+			throws CCException
+	{
+		try
+		{
+			return remoteService.getDefinitionForInstance(instanceID);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void pauseInstance(InstanceData data) throws CCException
+	{
+		try
+		{
+			remoteService.pauseInstance(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void terminateInstance(InstanceData data) throws CCException
+	{
+		try
+		{
+			remoteService.terminateInstance(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void resumeInstance(InstanceData data) throws CCException
+	{
+		try
+		{
+			remoteService.resumeInstance(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void removeInstance(InstanceData data) throws CCException
+	{
+		try
+		{
+			remoteService.removeInstance(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public ScopeData getContextScopeData(InstanceData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getContextScopeData(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Collection getChildScopes(ScopeData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getChildScopes(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Collection getVariables(ScopeData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getVariables(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Collection getRegistrations(InstanceData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getRegistrations(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Collection getPartData(VariableData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getPartData(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void cleanup(Date completionDate) throws CCException
+	{
+		try
+		{
+			remoteService.cleanup(completionDate);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Object getPartValue(PartData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getPartValue(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public void setAutomaticCleanup(boolean automaticCleanup)
+			throws CCException
+	{
+		try
+		{
+			remoteService.setAutomaticCleanup(automaticCleanup);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Map getDefinitionStatistics(DefinitionData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getDefinitionStatistics(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Map getEngineStatistics(EngineData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getEngineStatistics(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+	public Map getInstanceStatistics(InstanceData data) throws CCException
+	{
+		try
+		{
+			return remoteService.getInstanceStatistics(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+	}
+    public Collection getProcessCreatingOperations(DefinitionData data) throws CCException
+    {
+        try
+		{
+			return remoteService.getProcessCreatingOperations(data);
+		} catch (RemoteException e)
+		{
+			throw new CCException(e);
+		} catch (CCException e)
+		{
+			throw e;
+		}
+    }
+}



Mime
View raw message