---

CConsumer.hpp

Go to the documentation of this file.

#ifndef CConsumer_h
#define CConsumer_h 1

#include "jic/exc/CCreateException.hpp"

// CFnConsumer
#include "jic/task/CFnConsumer.hpp"
// CChainTask
#include "jic/task/CChainTask.hpp"

namespace TASK {

  //    Recibe mensajes y los consume (solo hace gets).
  //    El trabajo realmente lo hace un objeto función.
  //    Notas: Al solo soportarse de momento 1 solo controlador
  //    por cadena, en el constructor no se puede pasar un
  //    controlador.

  template <class MessageType>
  class CConsumer : public CChainTask<MessageType>  
  {

    public:
        CConsumer();

        //      El task no libera el objeto funcion, solo se queda con
        //      su "referencia".
        CConsumer (const CFnConsumer<MessageType> *fnConsumer, std::string strName = "Consumidor", int nThreads = 1) throw (CCreateException);

        ~CConsumer();

      // Additional Public Declarations

    protected:

        virtual void specificStep () /*throw (CTaskException)*/;

      // Additional Protected Declarations

    private:
        CConsumer(const CConsumer< MessageType > &right);

        CConsumer< MessageType > & operator=(const CConsumer< MessageType > &right);

      // Additional Private Declarations

    private: 
      // Data Members for Class Attributes

        CFnConsumer<MessageType> *m_fnConsumer;

      // Data Members for Associations

      // Additional Implementation Declarations

  };

  // Parameterized Class TASK::CConsumer 

} // namespace TASK

#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
#include "CConsumer.cpp"
#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */

#endif

---