#include <ConsumerFactoryImpl.h>
Public Member Functions | |
Consumer * | createConsumer (TimeInterval terminationInterval, std::string selectStatement, QueryProperties queryProperties) throw (RemoteException, RGMAException) |
Consumer * | reconnectConsumer (ResourceEndpoint &resourceEndpoint) 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.
|