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

rgma::impl::ConsumerFactoryImpl Class Reference

#include <ConsumerFactoryImpl.h>

List of all members.

Public Member Functions

ConsumercreateConsumer (TimeInterval terminationInterval, std::string selectStatement, QueryProperties queryProperties) throw (RemoteException, RGMAException)
ConsumerreconnectConsumer (ResourceEndpoint &resourceEndpoint) throw (RGMAException, RemoteException, UnknownResourceException)


Detailed Description

Implementation of the ConsumerFactory interface


Member Function Documentation

Consumer * rgma::impl::ConsumerFactoryImpl::createConsumer TimeInterval  terminationInterval,
std::string  selectStatement,
QueryProperties  queryProperties
throw (RemoteException, RGMAException)
 

Creates a consumer with a specific SELECT query and query type. The Consumer will only consume data from the VO's listed in voNames.

Parameters:
terminationInterval The interval after which this Consumer will be removed from the remote service if there has been no contact from the API.
selectStatement An SQL SELECT statement.
queryType The type of the query.
voNames List of VO names to consume from.
Returns:
A pointer to a new Consumer.
Exceptions:
RemoteException If the service could not be contacted.
RGMAException If the select statement is invalid. If no endpointReference is defined in properties.

Consumer * rgma::impl::ConsumerFactoryImpl::reconnectConsumer ResourceEndpoint resourceEndpoint  )  throw (RGMAException, RemoteException, UnknownResourceException)
 

Reconnects to an existing Consumer and checks that it is still active by sending a showSignOfLife call.

Parameters:
resourceEndpoint Endpoint of the consumer.
Returns:
A reference to the Consumer.


The documentation for this class was generated from the following files:
Generated on Fri Mar 16 14:00:16 2007 for glite-rgma-api-cpp by doxygen 1.3.5