AndroMeta/include/AndroMeta/MBroker.h

Go to the documentation of this file.

/*
 * Copyright 2009-2012 AndroMeta LLC. All rights reserved.
 *
 * AndroMeta LLC retains all intellectual property and proprietary 
 * rights to this software and related documentation and any modifications 
 * thereto.  Any use, reproduction, disclosure, or distribution of this 
 * software and related documentation without an express license agreement 
 * from AndroMeta LLC is strictly prohibited.
 * 
 */

#ifndef ANDROMETA_M_BROKER_H
#define ANDROMETA_M_BROKER_H

#include <AndroMeta/MObject.h>
#include <AndroMeta/MBrokerBase.h>

namespace Meta{
  
  class MProcTask;
  class MAuth;
  
  class MBroker : public MBrokerBase{
  public:
    
    MBroker(MProcTask* task, MAuth* auth);
    
    virtual ~MBroker();
    
    mnode process(MObject* object, mnode n, bool block);
    
    MProcTask* task();
    
    bool listen(int port);
    
    bool isListening() const;
    
    MAuth* auth();
    
    const MAuth* auth() const;
    
    mstr distribute(MObject* object,
                    const mstr& className,
                    const mstr& objectName="");
    
    bool revoke(MObject* object);
    
    MObject* obtain(const mstr& host,
                    int port,
                    const mstr& objectName,
                    const mstr& user="",
                    const mstr& key="",
                    const mvar& session=0);
    
    virtual bool onObtain(MObject* object);
    
    bool release(MObject* object, bool disconnect=false);
    
    mvar& session(MObject* object);
    
  private:  
    MBroker& operator=(const MBroker&);
    MBroker(const MBroker&);
    
    class MBroker_* x_;
  };
  
} // end namespace Meta

#endif // ANDROMETA_M_BROKER_H