#include <ConsumerFactory.h>
Public Member Functions | |
virtual Consumer * | createConsumer (TimeInterval terminationInterval, std::string selectStatement, QueryProperties queryProperties)=0 throw (RemoteException, RGMAException) |
virtual Consumer * | reconnectConsumer (ResourceEndpoint &resourceEndpoint)=0 throw (RGMAException, RemoteException, UnknownResourceException) |
|
Creates a consumer with a specific SELECT query and query type. The Consumer will only consume data from the VO's listed in
|
|
Reconnects to an existing Consumer and checks that it is still active by sending a showSignOfLife call.
|