ProxyPushConsumer.h

Go to the documentation of this file.

//                            Package   : omniEvents
// ProxyPushConsumer.h        Created   : 2003/12/04
//                            Author    : Alex Tingle
//
//    Copyright (C) 2003,2005 Alex Tingle.
//
//    This file is part of the omniEvents application.
//
//    omniEvents is free software; you can redistribute it and/or
//    modify it under the terms of the GNU Lesser General Public
//    License as published by the Free Software Foundation; either
//    version 2.1 of the License, or (at your option) any later version.
//
//    omniEvents is distributed in the hope that it will be useful,
//    but WITHOUT ANY WARRANTY; without even the implied warranty of
//    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
//    Lesser General Public License for more details.
//
//    You should have received a copy of the GNU Lesser General Public
//    License along with this library; if not, write to the Free Software
//    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
//

#ifndef OMNIEVENTS__PROXYPUSHCONSUMER_H
#define OMNIEVENTS__PROXYPUSHCONSUMER_H

#ifdef HAVE_CONFIG_H
#  include "config.h"
#endif

#include <string>
#include <map>
#include <list>

#ifdef HAVE_IOSTREAM
#  include <iostream>
#else
#  include <iostream.h>
#endif

#include "Callback.h"
#include "Servant.h"

#include "CosEventChannelAdmin.hh"

#ifdef HAVE_STD_IOSTREAM
using namespace std;
#endif

namespace OmniEvents {

class PersistNode;
class ConsumerAdmin_i;

class ProxyPushConsumer_i
: public virtual POA_CosEventChannelAdmin::ProxyPushConsumer,
  public Servant
{
public: // CORBA interface methods
  void connect_push_supplier(CosEventComm::PushSupplier_ptr pushSupplier);

  void disconnect_push_consumer();

  void push(const CORBA::Any& event);

public:
  ProxyPushConsumer_i(
    PortableServer::POA_ptr parentPoa,
    list<CORBA::Any*>&      q,
    ConsumerAdmin_i&        consumerAdmin
  );
  virtual ~ProxyPushConsumer_i();
  
  void trigger() {_useLocalQueue=false;}

  CosEventChannelAdmin::ProxyPushConsumer_ptr createObject();

  void disconnect();

  void reincarnate(const PersistNode& node);
  void output(ostream& os) const;

private:
  string currentObjectId() const;
  struct Connection : public Callback
  {
    const char*                    _channelName;
    string                         _oidstr;
    CosEventComm::PushSupplier_var _target;
    bool _targetIsProxy; 

    Connection(
      const char*                    channelName,
      const string&                  oidstr,
      CosEventComm::PushSupplier_ptr pushSupplier,
      bool                           isProxy=false
    );
    virtual ~Connection();
    OMNIEVENTS__DEBUG_REF_COUNTS__DECL
    void callback(CORBA::Request_ptr req);
    void output(ostream& os) const;
  private:
    Connection(); 
#if OMNIEVENTS__DEBUG_SERVANT
    static int _objectCount;
#endif
  };

  typedef map<string,Connection*> Connections_t;
  Connections_t      _connections;
  CORBA::String_var  _channelName;
  ConsumerAdmin_i&   _consumerAdmin;
  list<CORBA::Any*>& _queue;
  bool               _useLocalQueue; 
};

}; // end namespace OmniEvents

#endif // OMNIEVENTS__PROXYPUSHCONSUMER_H

---