getrequestimpl.java

来自「CmisJavaApi」· Java 代码 · 共 131 行

/*
 * The contents of this file are subject to the Dyade Public License, 
 * as defined by the file DYADE_PUBLIC_LICENSE.TXT
 *
 * You may not use this file except in compliance with the License. You may
 * obtain a copy of the License on the Dyade web site (www.dyade.fr).
 *
 * Software distributed under the License is distributed on an "AS IS" basis,
 * WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License for
 * the specific terms governing rights and limitations under the License.
 *
 * The Original Code is CmisJava API, including the java package 
 * fr.dyade.cmis, released September 5, 2000.
 *
 * The Initial Developer of the Original Code is Dyade. The Original Code and
 * portions created by Dyade are Copyright Bull and Copyright INRIA. 
 * All Rights Reserved.
 */

/*      Copyright 1996-2000 by Institut National de Recherche en Informatique 
 *                             et en Automatique (INRIA)
 *          All rights reserved.  See COPYRIGHT in top-level directory.
 *
 *      Authors: Laurent Andrey, Eric Dillon, Olivier Festor
 */

//  $Id: GetRequestImpl.java,v 1.2 2000/09/05 14:30:46 festor Exp $
//  $Source: /local/resedas/CVS-Repository/CmisJavaApi/src/fr/dyade/cmis/impl/operation/GetRequestImpl.java,v $
//
//  Todo
// 

package fr.dyade.cmis.impl.operation;

import java.util.Enumeration;
import fr.dyade.cmis.api.*;
import fr.dyade.cmis.api.types.*;
import fr.dyade.cmis.api.operation.*;
import fr.dyade.cmis.api.operation.event.*;
import fr.dyade.cmis.impl.*;

/** Basic implementation for a CMIS Get request.
  *
  * This class mainly implements the <code>{@link fr.dyade.cmis.api.operation.SetRequest}</code> interface.
  * It has the filtering and scoping features so
  * it is a subclass of <code>{@link FilteredAndScopedOperationImpl}</code>.
  *
  * Because of java scope properties this class is public, but user can not directly build instances
  * as it is an abstract class. Instances are to be built using
  * {@link fr.dyade.cmis.api.CMISManagerStack#newGetRequest factory method}.
  *
  * @version cvs $Id: GetRequestImpl.java,v 1.2 2000/09/05 14:30:46 festor Exp $
  */
public abstract class GetRequestImpl  extends FilteredAndScopedOperationImpl
   implements GetRequest {
	 protected GetRequestImpl( CMISStackImpl pStack ) {
	    super(pStack, GET_REQUEST);
	 }
	 
	 public final AttributeIdList getAttributeIdentifierList() {
	    return fAttributeIdentifierList;
	 }
      
	 public final void setAttributeIdentifierList(AttributeIdList pList) {
	    fAttributeIdentifierList=pList;
	 }	 
	/**
	  * Add an GetRequestListner object to a get request.
	  * @param pGl the  listener to add
	  */
	 public final void addGetRequestListener(GetRequestListener pGl) {
	    addCMISListener(pGl);
	 }
	/**
	  * Remove an GetRequestListner object from a get request.
	  * @param pGl the  listener to remove
	  */
	 public final void removeGetRequestListener(GetRequestListener pGl) {
	    removeCMISListener(pGl);
	 }
	/** The dispatch METHOD for event loop.
	  * @param the event (GetConfirmation/Completion Event) to dispatch on this GetRequest
	  * @see fr.dyade.cmis.impl.CMISEventQueue
	  */
	public final void dispatchEvent( CMISEvent pEvent ) {
	   if (pEvent instanceof GetConfirmationEvent) {
	      GetConfirmationEvent lEvent=(GetConfirmationEvent)pEvent;
	      lEvent.getRequest().addConfirmation(lEvent.getConfirmation());
	      synchronized (fCMISEventListener){
		 for (Enumeration e = fCMISEventListener.elements() ; e.hasMoreElements() ;) {
		  ((GetRequestListener)e.nextElement()).confirmation(lEvent);
		 }
	      }
	   } else {
	    if (pEvent instanceof GetCompletionEvent) {
	       complete(); // just to mark the request as complete
	       synchronized (fCMISEventListener){
		  for (Enumeration e = fCMISEventListener.elements() ; e.hasMoreElements() ;) {
		     ((GetRequestListener)e.nextElement()).completion((GetCompletionEvent)pEvent);
		  }
	       }
	       // ok now all processing is done. Except if listener start threads.....
	       endProcessing();
	    } else {
	       System.err.println("GetRequestImpl.java:dispatchEvent bad event type INTERNAL ERROR");
	    }
	   }
	}
	 /**
	   * Effective Get service invocation.
	   * This method is synchronized to ensure
	   * that no thread (listening thread when dispatching event) would change  the request state (fState)
	   * in the meanwhile.
	   */
	 public final  synchronized void doIt() throws CMISException { 
	    synchronized(fStack.getPendingRequestQueueSynchronization()) {
	       setInvokeId(new InvokeId(nativeDoIt()));
	       fStack.addPendingRequest(this);
	       // Get is always a confirmed service.
	       // Update state only if request sending is successfull.
	       startProcessing();
	    } 
	 }
	 private AttributeIdList fAttributeIdentifierList=null;
} // GetRequestImpl