00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
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