blob: 8154c025a13373c88c4a41164f2e657f771cfb13 [file] [log] [blame]
#ifndef __GEMFIRE_CQ_ATTRIBUTES_MUTATOR_IMPL_H__
#define __GEMFIRE_CQ_ATTRIBUTES_MUTATOR_IMPL_H__
/*=========================================================================
* Copyright (c) 2002-2014 Pivotal Software, Inc. All Rights Reserved.
* This product is protected by U.S. and international copyright
* and intellectual property laws. Pivotal products are covered by
* more patents listed at http://www.pivotal.io/patents.
*========================================================================
*/
#include "../gfcpp_globals.hpp"
#include "../gf_types.hpp"
#include "../VectorT.hpp"
#include "../CqAttributesMutator.hpp"
#include "../CqAttributes.hpp"
/**
* @file
*/
namespace gemfire
{
/**
* @class CqAttributesMutatorImpl CqAttributesMutatorImpl.hpp
*
* This interface is used to modify the listeners that are associated with a CQ.
* Each CqQuery has an CqAttributesMutatorImpl interface which supports modification
* of certain CQ attributes after the CQ has been created.
*
*/
class CPPCACHE_EXPORT CqAttributesMutatorImpl : public CqAttributesMutator
{
public:
CqAttributesMutatorImpl(const CqAttributesPtr& impl);
/**
* Adds a CQ listener to the end of the list of CQ listeners on this CqQuery.
* @param aListener the user defined CQ listener to add to the CqQuery.
* @throws IllegalArgumentException if <code>aListener</code> is null
*/
void addCqListener(const CqListenerPtr& aListener);
/**
* Removes given CQ listener from the list of CQ listeners on this CqQuery.
* Does nothing if the specified listener has not been added.
* If the specified listener has been added then will
* be called on it; otherwise does nothing.
* @param aListener the CQ listener to remove from the CqQuery.
* @throws IllegalArgumentException if <code>aListener</code> is null
*/
void removeCqListener(const CqListenerPtr& aListener);
/**
* Adds the given set CqListner on this CQ. If the CQ already has CqListeners, this
* removes those old CQs and initializes with the newListeners.
* @param newListeners a possibly null or empty array of listeners to add
* to this CqQuery.
* @throws IllegalArgumentException if the <code>newListeners</code> array
* has a null element
*/
void setCqListeners(VectorOfCqListener& newListeners);
private:
CqAttributesPtr m_cqAttributes;
};
} //namespace gemfire
#endif //ifndef __GEMFIRE_CQ_ATTRIBUTES_MUTATOR_IMPL_H__