#ifndef CPXEVENTCONSUMER_H
#define CPXEVENTCONSUMER_H

#include <orbsvcs/RtecEventCommS.h>
#include <iostream>

class CPXEventConsumer_i : public virtual POA_RtecEventComm::PushConsumer
{
public:
	CPXEventConsumer_i(CORBA::ORB_ptr orb/*, int event_limit*/);
	virtual void push(const RtecEventComm::EventSet& events) throw(CORBA::SystemException);
	virtual void disconnect_push_consumer() throw(CORBA::SystemException);
private:
	CORBA::ORB_var orb_;
};

#endif