TAO_Notify_PushConsumer Class Reference

Wrapper for the PushConsumer that connect to the EventChannel. More...

#include <PushConsumer.h>

Inheritance diagram for TAO_Notify_PushConsumer:

[legend]Collaboration diagram for TAO_Notify_PushConsumer:

[legend]List of all members.

Public Member Functions
	TAO_Notify_PushConsumer (TAO_Notify_ProxySupplier *proxy)
	Constructor.
virtual	~TAO_Notify_PushConsumer ()
	Destructor.
void	init (CosEventComm::PushConsumer_ptr push_consumer)
	Init.
virtual void	push (const CORBA::Any &event)
	Push <event> to this consumer.
virtual void	push (const CosNotification::StructuredEvent &event)
	Push <event> to this consumer.
virtual void	push (const CosNotification::EventBatch &event)
	Push a batch of events to this consumer.
virtual ACE_CString	get_ior (void) const
	Retrieve the ior of this peer.
virtual void	reconnect_from_consumer (TAO_Notify_Consumer *old_consumer)
Protected Attributes
CosEventComm::PushConsumer_var	push_consumer_
	The Consumer.
Private Member Functions
virtual void	release (void)
	TAO_Notify_Destroy_Callback methods.

---

Detailed Description

Wrapper for the PushConsumer that connect to the EventChannel.

Definition at line 33 of file PushConsumer.h.

---

Constructor & Destructor Documentation

TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Notify_PushConsumer::TAO_Notify_PushConsumer

(

TAO_Notify_ProxySupplier *

proxy

)

Constructor.

Definition at line 18 of file PushConsumer.cpp.

  :TAO_Notify_Consumer (proxy)
{
}

TAO_Notify_PushConsumer::~TAO_Notify_PushConsumer

(

)

[virtual]

Destructor.

Definition at line 23 of file PushConsumer.cpp.

{
}

---

Member Function Documentation

ACE_CString TAO_Notify_PushConsumer::get_ior

(

void

)

const [virtual]

Retrieve the ior of this peer.

Implements TAO_Notify_Peer.

Definition at line 136 of file PushConsumer.cpp.

References ACE_String_Base< CHAR >::fast_clear(), TAO_Notify_Properties::instance(), and TAO_Notify_Properties::orb().

{
  ACE_CString result;
  CORBA::ORB_var orb = TAO_Notify_PROPERTIES::instance()->orb();
  try
    {
      CORBA::String_var ior = orb->object_to_string(this->push_consumer_.in());
      result = static_cast<const char*> (ior.in ());
    }
  catch (const CORBA::Exception&)
    {
      result.fast_clear();
    }
  return result;
}

void TAO_Notify_PushConsumer::init

(

CosEventComm::PushConsumer_ptr

push_consumer

)

Init.

Definition at line 28 of file PushConsumer.cpp.

References ACE_ASSERT, ACE_DEBUG, TAO_Notify_Properties::dispatching_orb(), TAO_Pseudo_Var_T< T >::in(), TAO_Notify_Properties::instance(), CORBA::is_nil(), LM_DEBUG, CORBA::ORB::object_to_string(), TAO_Notify_Properties::orb(), TAO_Notify_Consumer::publish_, push_consumer_, CORBA::ORB::string_to_object(), and TAO_debug_level.

Referenced by reconnect_from_consumer().

{
  // Initialize only once
  ACE_ASSERT( CORBA::is_nil (this->push_consumer_.in()) );

  // push_consumer not optional
  if (CORBA::is_nil (push_consumer))
  {
    throw CORBA::BAD_PARAM();
  }

  try
  {
    if (!TAO_Notify_PROPERTIES::instance()->separate_dispatching_orb ())
      {
        this->push_consumer_ = CosEventComm::PushConsumer::_duplicate (push_consumer);

        this->publish_ =
          CosNotifyComm::NotifyPublish::_narrow (push_consumer);
      }
    else
      {
        // "Port" consumer's object reference from receiving ORB to dispatching ORB.
        CORBA::String_var temp =
          TAO_Notify_PROPERTIES::instance()->orb()->object_to_string(push_consumer);

        CORBA::Object_var obj =
          TAO_Notify_PROPERTIES::instance()->dispatching_orb()->string_to_object(temp.in());

        CosEventComm::PushConsumer_var new_cos_comm_pc =
          CosEventComm::PushConsumer::_unchecked_narrow(obj.in());

        this->push_consumer_ =
          CosEventComm::PushConsumer::_duplicate (new_cos_comm_pc.in());

        //
        // Note that here we do an _unchecked_narrow() in order to avoid
        // making a call on the consumer b/c the consumer may not have activated
        // its POA just yet.  That means that before we use this reference the first
        // time, we'll actually need to call _is_a() on it, i.e., the equivalent
        // of an _narrow().  At the time of this writing, the only use of
        // this->publish_ is in TAO_NS_Consumer::dispatch_updates_i (the superclass).
        // If any other use is made of this data member, then the code to validate
        // the actual type of the target object must be refactored.
        this->publish_ =
          CosNotifyComm::NotifyPublish::_unchecked_narrow (obj.in());


        //--cj verify dispatching ORB
        if (TAO_debug_level >= 10)
          {
            ACE_DEBUG ((LM_DEBUG, "(%P|%t) Any push init dispatching ORB id is %s.\n",
                        obj->_stubobj()->orb_core()->orbid()));
          }
        //--cj end
      }
  }
  catch (const CORBA::TRANSIENT& ex)
    {
      ex._tao_print_exception ("Got a TRANSIENT in NS_PushConsumer::init");
      ACE_DEBUG ((LM_DEBUG, "(%P|%t) got it for NS_PushConsumer %@\n", this));
    }
  catch (const CORBA::Exception&)
    {
      // _narrow failed which probably means the interface is CosEventComm type.
    }
}

void TAO_Notify_PushConsumer::push

(

const CosNotification::EventBatch &

event

)

[virtual]

Push a batch of events to this consumer.

Implements TAO_Notify_Consumer.

Definition at line 128 of file PushConsumer.cpp.

References ACE_ASSERT.

{
  ACE_ASSERT(false);
  ACE_UNUSED_ARG (event);
  // TODO exception?
}

void TAO_Notify_PushConsumer::push

(

const CosNotification::StructuredEvent &

event

)

[virtual]

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

Definition at line 117 of file PushConsumer.cpp.

References push_consumer_, and TAO_Notify_Event::translate().

{
  CORBA::Any any;

  TAO_Notify_Event::translate (event, any);

  this->push_consumer_->push (any);
}

void TAO_Notify_PushConsumer::push

(

const CORBA::Any &

event

)

[virtual]

Push <event> to this consumer.

Implements TAO_Notify_Consumer.

Definition at line 104 of file PushConsumer.cpp.

References ACE_DEBUG, LM_DEBUG, push_consumer_, and TAO_debug_level.

{
  //--cj verify dispatching ORB
  if (TAO_debug_level >= 10) {
    ACE_DEBUG ((LM_DEBUG, "(%P|%t) Any push dispatching ORB id is %s.\n",
                this->push_consumer_->_stubobj()->orb_core()->orbid()));
  }
  //--cj end

  this->push_consumer_->push (payload);
}

void TAO_Notify_PushConsumer::reconnect_from_consumer

(

TAO_Notify_Consumer *

old_consumer

)

[virtual]

on reconnect we need to move events from the old consumer to the new one

Implements TAO_Notify_Consumer.

Definition at line 153 of file PushConsumer.cpp.

References ACE_ASSERT, init(), push_consumer_, and TAO_Notify_Consumer::schedule_timer().

{
  TAO_Notify_PushConsumer* tmp =
    dynamic_cast<TAO_Notify_PushConsumer*> (old_consumer);
  ACE_ASSERT(tmp != 0);
  this->init(tmp->push_consumer_.in());
  this->schedule_timer(false);
}

void TAO_Notify_PushConsumer::release

(

void

)

[private, virtual]

TAO_Notify_Destroy_Callback methods.

Implements TAO_Notify_Peer.

Definition at line 97 of file PushConsumer.cpp.

{
  delete this;
  //@@ inform factory
}

---

Member Data Documentation

CosEventComm::PushConsumer_var TAO_Notify_PushConsumer::push_consumer_ [protected]

The Consumer.

Definition at line 67 of file PushConsumer.h.

Referenced by init(), push(), and reconnect_from_consumer().

---

The documentation for this class was generated from the following files:

• PushConsumer.h
• PushConsumer.cpp

---