Main Page | Class Hierarchy | Class List | File List | Class Members | Related Pages

ConsumerImpl.h

00001 /*
00002  *  Copyright (c) 2004 on behalf of the EU EGEE Project:
00003  *  The European Organization for Nuclear Research (CERN),
00004  *  Istituto Nazionale di Fisica Nucleare (INFN), Italy
00005  *  Datamat Spa, Italy
00006  *  Centre National de la Recherche Scientifique (CNRS), France
00007  *  CS Systeme d'Information (CSSI), France
00008  *  Royal Institute of Technology, Center for Parallel Computers (KTH-PDC), Sweden
00009  *  Universiteit van Amsterdam (UvA), Netherlands
00010  *  University of Helsinki (UH.HIP), Finland
00011  *  University of Bergen (UiB), Norway
00012  *  Council for the Central Laboratory of the Research Councils (CCLRC), United Kingdom
00013  */
00014 #ifndef CONSUMERIMPL_H
00015 #define CONSUMERIMPL_H
00016 
00017 #include "rgma/Consumer.h"
00018 #include "rgma/ResourceEndpoint.h"
00019 #include "rgma/ResourceEndpointList.h"
00020 #include "rgma/TimeInterval.h"
00021 #include "rgma/RemoteException.h"
00022 #include "rgma/UnknownResourceException.h"
00023 #include "rgma/RGMAException.h"
00024 #include "rgma/Resource.h"
00025 #include "rgma/StringList.h"
00026 #include "rgma/ProducerProperties.h"
00027 #include "rgma/QueryProperties.h"
00028 #include "rgma/Units.h"
00029 #include "rgma/ResultSet.h"
00030 #include "rgma/ResultSetMetaData.h"
00031 #include "rgma/Tuple.h"
00032 #include "rgma/Types.h"
00033 
00034 namespace glite
00035 {
00036     namespace rgma
00037     {
00041         class ConsumerImpl : virtual public Consumer
00042         {
00043 
00044             public:
00045 
00046                 ConsumerImpl(TimeInterval terminationInterval,
00047                     std::string selectStatement, QueryProperties queryProperties)throw(RemoteException, RGMAException);
00048 
00049                 ConsumerImpl(ResourceEndpoint& resourceEndpoint)throw(RemoteException, RGMAException);
00050 
00051                 virtual ~ConsumerImpl();
00060                 bool isExecuting() throw(UnknownResourceException, RemoteException, RGMAException);
00061 
00068                 void abort() throw(UnknownResourceException, RemoteException);
00077                 int count() throw(UnknownResourceException, RemoteException);
00086                 bool hasAborted()throw(UnknownResourceException, RemoteException);
00099                 void pop(ResultSet& results, int maxCount)throw(UnknownResourceException, RemoteException, RGMAException);
00111                 void popAll(ResultSet& results)throw(UnknownResourceException, RemoteException, RGMAException);
00126                 void start(TimeInterval timeout)throw(UnknownResourceException, RemoteException, RGMAException);
00141                 void start(TimeInterval timeout, ResourceEndpointList producers)
00142                     throw(UnknownResourceException, RemoteException, RGMAException);
00143 
00144         };
00145     }
00146 }
00147 #endif                                            // CONSUMERWRAPPER_H

Generated on Thu May 11 19:23:43 2006 for glite-rgma-api-cpp by doxygen 1.3.5