// -*- C++ -*-
//
// $Id$

// ****  Code generated by the The ACE ORB (TAO) IDL Compiler ****
// TAO and the TAO IDL Compiler have been developed by:
//       Center for Distributed Object Computing
//       Washington University
//       St. Louis, MO
//       USA
//       http://www.cs.wustl.edu/~schmidt/doc-center.html
// and
//       Distributed Object Computing Laboratory
//       University of California at Irvine
//       Irvine, CA
//       USA
//       http://doc.ece.uci.edu/
// and
//       Institute for Software Integrated Systems
//       Vanderbilt University
//       Nashville, TN
//       USA
//       http://www.isis.vanderbilt.edu/
//
// Information about TAO is available at:
//     http://www.cs.wustl.edu/~schmidt/TAO.html


// TAO_IDL - Generated from 
// be/be_codegen.cpp:611

#ifndef _TAO_IDL_EVENT_FORWARDERS_CPP_
#define _TAO_IDL_EVENT_FORWARDERS_CPP_


#include "Event_ForwarderS.h"
#include "tao/PortableServer/Object_Adapter.h"
#include "tao/PortableServer/Operation_Table.h"
#include "tao/TAO_Server_Request.h"
#include "tao/ORB_Core.h"
#include "tao/Profile.h"
#include "tao/Stub.h"
#include "tao/IFR_Client_Adapter.h"
#include "tao/Object_T.h"
#include "tao/Typecode.h"
#include "tao/DynamicC.h"
#include "tao/CDR.h"
#include "tao/Basic_Arguments.h"
#include "tao/Object_Argument_T.h"
#include "tao/Special_Basic_Arguments.h"
#include "tao/UB_String_Arguments.h"
#include "tao/Var_Size_Argument_T.h"
#include "tao/PortableInterceptor.h"
#if TAO_HAS_INTERCEPTORS == 1
#include "tao/PortableServer/PICurrent_Guard.h"
#include "tao/PortableServer/ServerRequestInfo.h"
#include "tao/PortableServer/ServerInterceptorAdapter.h"
#include "tao/RequestInfo_Util.h"
#endif  /* TAO_HAS_INTERCEPTORS == 1 */

#include "ace/Dynamic_Service.h"
#include "ace/Malloc_Allocator.h"
#include "ace/config-all.h"

#if defined (__BORLANDC__)
#pragma option -w-rvl -w-rch -w-ccc -w-aus
#endif /* __BORLANDC__ */

#if !defined (__ACE_INLINE__)
#include "Event_ForwarderS.inl"
#endif /* !defined __ACE_INLINE__ */

// TAO_IDL - Generated from
// be/be_visitor_arg_traits.cpp:64

// Arg traits specializations.
namespace TAO
{
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:582

#if !defined (_CORBA_ANY__ARG_TRAITS_SS_)
#define _CORBA_ANY__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CORBA::Any>
    : public
        Var_Size_Arg_Traits_T<
            CORBA::Any,
            CORBA::Any_var,
            CORBA::Any_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFICATION_PROPERTYSEQ__ARG_TRAITS_SS_)
#define _COSNOTIFICATION_PROPERTYSEQ__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotification::PropertySeq>
    : public
        Var_Size_Arg_Traits_T<
            CosNotification::PropertySeq,
            CosNotification::PropertySeq_var,
            CosNotification::PropertySeq_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFICATION_EVENTTYPESEQ__ARG_TRAITS_SS_)
#define _COSNOTIFICATION_EVENTTYPESEQ__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotification::EventTypeSeq>
    : public
        Var_Size_Arg_Traits_T<
            CosNotification::EventTypeSeq,
            CosNotification::EventTypeSeq_var,
            CosNotification::EventTypeSeq_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFICATION_NAMEDPROPERTYRANGESEQ__ARG_TRAITS_SS_)
#define _COSNOTIFICATION_NAMEDPROPERTYRANGESEQ__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotification::NamedPropertyRangeSeq>
    : public
        Var_Size_Arg_Traits_T<
            CosNotification::NamedPropertyRangeSeq,
            CosNotification::NamedPropertyRangeSeq_var,
            CosNotification::NamedPropertyRangeSeq_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:618

#if !defined (_COSNOTIFICATION_STRUCTUREDEVENT__ARG_TRAITS_SS_)
#define _COSNOTIFICATION_STRUCTUREDEVENT__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotification::StructuredEvent>
    : public
        Var_Size_Arg_Traits_T<
            CosNotification::StructuredEvent,
            CosNotification::StructuredEvent_var,
            CosNotification::StructuredEvent_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFICATION_EVENTBATCH__ARG_TRAITS_SS_)
#define _COSNOTIFICATION_EVENTBATCH__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotification::EventBatch>
    : public
        Var_Size_Arg_Traits_T<
            CosNotification::EventBatch,
            CosNotification::EventBatch_var,
            CosNotification::EventBatch_out
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSEVENTCOMM_PUSHCONSUMER__ARG_TRAITS_SS_)
#define _COSEVENTCOMM_PUSHCONSUMER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosEventComm::PushConsumer>
    : public
        Object_Arg_Traits_T<
            CosEventComm::PushConsumer_ptr,
            CosEventComm::PushConsumer_var,
            CosEventComm::PushConsumer_out,
            TAO::Objref_Traits<CosEventComm::PushConsumer>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSEVENTCOMM_PUSHSUPPLIER__ARG_TRAITS_SS_)
#define _COSEVENTCOMM_PUSHSUPPLIER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosEventComm::PushSupplier>
    : public
        Object_Arg_Traits_T<
            CosEventComm::PushSupplier_ptr,
            CosEventComm::PushSupplier_var,
            CosEventComm::PushSupplier_out,
            TAO::Objref_Traits<CosEventComm::PushSupplier>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSEVENTCOMM_PULLCONSUMER__ARG_TRAITS_SS_)
#define _COSEVENTCOMM_PULLCONSUMER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosEventComm::PullConsumer>
    : public
        Object_Arg_Traits_T<
            CosEventComm::PullConsumer_ptr,
            CosEventComm::PullConsumer_var,
            CosEventComm::PullConsumer_out,
            TAO::Objref_Traits<CosEventComm::PullConsumer>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSEVENTCOMM_PULLSUPPLIER__ARG_TRAITS_SS_)
#define _COSEVENTCOMM_PULLSUPPLIER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosEventComm::PullSupplier>
    : public
        Object_Arg_Traits_T<
            CosEventComm::PullSupplier_ptr,
            CosEventComm::PullSupplier_var,
            CosEventComm::PullSupplier_out,
            TAO::Objref_Traits<CosEventComm::PullSupplier>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_NOTIFYSUBSCRIBE__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_NOTIFYSUBSCRIBE__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::NotifySubscribe>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::NotifySubscribe_ptr,
            CosNotifyComm::NotifySubscribe_var,
            CosNotifyComm::NotifySubscribe_out,
            TAO::Objref_Traits<CosNotifyComm::NotifySubscribe>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_STRUCTUREDPUSHCONSUMER__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_STRUCTUREDPUSHCONSUMER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::StructuredPushConsumer>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::StructuredPushConsumer_ptr,
            CosNotifyComm::StructuredPushConsumer_var,
            CosNotifyComm::StructuredPushConsumer_out,
            TAO::Objref_Traits<CosNotifyComm::StructuredPushConsumer>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_STRUCTUREDPULLCONSUMER__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_STRUCTUREDPULLCONSUMER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::StructuredPullConsumer>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::StructuredPullConsumer_ptr,
            CosNotifyComm::StructuredPullConsumer_var,
            CosNotifyComm::StructuredPullConsumer_out,
            TAO::Objref_Traits<CosNotifyComm::StructuredPullConsumer>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_STRUCTUREDPULLSUPPLIER__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_STRUCTUREDPULLSUPPLIER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::StructuredPullSupplier>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::StructuredPullSupplier_ptr,
            CosNotifyComm::StructuredPullSupplier_var,
            CosNotifyComm::StructuredPullSupplier_out,
            TAO::Objref_Traits<CosNotifyComm::StructuredPullSupplier>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_STRUCTUREDPUSHSUPPLIER__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_STRUCTUREDPUSHSUPPLIER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::StructuredPushSupplier>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::StructuredPushSupplier_ptr,
            CosNotifyComm::StructuredPushSupplier_var,
            CosNotifyComm::StructuredPushSupplier_out,
            TAO::Objref_Traits<CosNotifyComm::StructuredPushSupplier>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_SEQUENCEPUSHCONSUMER__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_SEQUENCEPUSHCONSUMER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::SequencePushConsumer>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::SequencePushConsumer_ptr,
            CosNotifyComm::SequencePushConsumer_var,
            CosNotifyComm::SequencePushConsumer_out,
            TAO::Objref_Traits<CosNotifyComm::SequencePushConsumer>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_SEQUENCEPULLCONSUMER__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_SEQUENCEPULLCONSUMER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::SequencePullConsumer>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::SequencePullConsumer_ptr,
            CosNotifyComm::SequencePullConsumer_var,
            CosNotifyComm::SequencePullConsumer_out,
            TAO::Objref_Traits<CosNotifyComm::SequencePullConsumer>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_SEQUENCEPULLSUPPLIER__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_SEQUENCEPULLSUPPLIER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::SequencePullSupplier>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::SequencePullSupplier_ptr,
            CosNotifyComm::SequencePullSupplier_var,
            CosNotifyComm::SequencePullSupplier_out,
            TAO::Objref_Traits<CosNotifyComm::SequencePullSupplier>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCOMM_SEQUENCEPUSHSUPPLIER__ARG_TRAITS_SS_)
#define _COSNOTIFYCOMM_SEQUENCEPUSHSUPPLIER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyComm::SequencePushSupplier>
    : public
        Object_Arg_Traits_T<
            CosNotifyComm::SequencePushSupplier_ptr,
            CosNotifyComm::SequencePushSupplier_var,
            CosNotifyComm::SequencePushSupplier_out,
            TAO::Objref_Traits<CosNotifyComm::SequencePushSupplier>
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFYFILTER_CONSTRAINTIDSEQ__ARG_TRAITS_SS_)
#define _COSNOTIFYFILTER_CONSTRAINTIDSEQ__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyFilter::ConstraintIDSeq>
    : public
        Var_Size_Arg_Traits_T<
            CosNotifyFilter::ConstraintIDSeq,
            CosNotifyFilter::ConstraintIDSeq_var,
            CosNotifyFilter::ConstraintIDSeq_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFYFILTER_CONSTRAINTEXPSEQ__ARG_TRAITS_SS_)
#define _COSNOTIFYFILTER_CONSTRAINTEXPSEQ__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyFilter::ConstraintExpSeq>
    : public
        Var_Size_Arg_Traits_T<
            CosNotifyFilter::ConstraintExpSeq,
            CosNotifyFilter::ConstraintExpSeq_var,
            CosNotifyFilter::ConstraintExpSeq_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFYFILTER_CONSTRAINTINFOSEQ__ARG_TRAITS_SS_)
#define _COSNOTIFYFILTER_CONSTRAINTINFOSEQ__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyFilter::ConstraintInfoSeq>
    : public
        Var_Size_Arg_Traits_T<
            CosNotifyFilter::ConstraintInfoSeq,
            CosNotifyFilter::ConstraintInfoSeq_var,
            CosNotifyFilter::ConstraintInfoSeq_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFYFILTER_MAPPINGCONSTRAINTPAIRSEQ__ARG_TRAITS_SS_)
#define _COSNOTIFYFILTER_MAPPINGCONSTRAINTPAIRSEQ__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyFilter::MappingConstraintPairSeq>
    : public
        Var_Size_Arg_Traits_T<
            CosNotifyFilter::MappingConstraintPairSeq,
            CosNotifyFilter::MappingConstraintPairSeq_var,
            CosNotifyFilter::MappingConstraintPairSeq_out
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:379

#if !defined (_COSNOTIFYFILTER_MAPPINGCONSTRAINTINFOSEQ__ARG_TRAITS_SS_)
#define _COSNOTIFYFILTER_MAPPINGCONSTRAINTINFOSEQ__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyFilter::MappingConstraintInfoSeq>
    : public
        Var_Size_Arg_Traits_T<
            CosNotifyFilter::MappingConstraintInfoSeq,
            CosNotifyFilter::MappingConstraintInfoSeq_var,
            CosNotifyFilter::MappingConstraintInfoSeq_out
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYFILTER_FILTER__ARG_TRAITS_SS_)
#define _COSNOTIFYFILTER_FILTER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyFilter::Filter>
    : public
        Object_Arg_Traits_T<
            CosNotifyFilter::Filter_ptr,
            CosNotifyFilter::Filter_var,
            CosNotifyFilter::Filter_out,
            TAO::Objref_Traits<CosNotifyFilter::Filter>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYFILTER_MAPPINGFILTER__ARG_TRAITS_SS_)
#define _COSNOTIFYFILTER_MAPPINGFILTER__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyFilter::MappingFilter>
    : public
        Object_Arg_Traits_T<
            CosNotifyFilter::MappingFilter_ptr,
            CosNotifyFilter::MappingFilter_var,
            CosNotifyFilter::MappingFilter_out,
            TAO::Objref_Traits<CosNotifyFilter::MappingFilter>
          >
  {
  };

#endif /* end #if !defined */

#if !defined (_COSNOTIFYCHANNELADMIN_CONSUMERADMIN__ARG_TRAITS_SS_)
#define _COSNOTIFYCHANNELADMIN_CONSUMERADMIN__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyChannelAdmin::ConsumerAdmin>
    : public
        Object_Arg_Traits_T<
            CosNotifyChannelAdmin::ConsumerAdmin_ptr,
            CosNotifyChannelAdmin::ConsumerAdmin_var,
            CosNotifyChannelAdmin::ConsumerAdmin_out,
            TAO::Objref_Traits<CosNotifyChannelAdmin::ConsumerAdmin>
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:537

#if !defined (_COSNOTIFYCHANNELADMIN_PROXYTYPE__ARG_TRAITS_SS_)
#define _COSNOTIFYCHANNELADMIN_PROXYTYPE__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyChannelAdmin::ProxyType>
    : public
        Basic_Arg_Traits_T<
            CosNotifyChannelAdmin::ProxyType
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:537

#if !defined (_COSNOTIFYCHANNELADMIN_OBTAININFOMODE__ARG_TRAITS_SS_)
#define _COSNOTIFYCHANNELADMIN_OBTAININFOMODE__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyChannelAdmin::ObtainInfoMode>
    : public
        Basic_Arg_Traits_T<
            CosNotifyChannelAdmin::ObtainInfoMode
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:537

#if !defined (_COSNOTIFYCHANNELADMIN_CLIENTTYPE__ARG_TRAITS_SS_)
#define _COSNOTIFYCHANNELADMIN_CLIENTTYPE__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyChannelAdmin::ClientType>
    : public
        Basic_Arg_Traits_T<
            CosNotifyChannelAdmin::ClientType
          >
  {
  };

#endif /* end #if !defined */
  
  // TAO_IDL - Generated from
  // be/be_visitor_arg_traits.cpp:537

#if !defined (_COSNOTIFYCHANNELADMIN_INTERFILTERGROUPOPERATOR__ARG_TRAITS_SS_)
#define _COSNOTIFYCHANNELADMIN_INTERFILTERGROUPOPERATOR__ARG_TRAITS_SS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_Event_Export Arg_Traits<CosNotifyChannelAdmin::InterFilterGroupOperator>
    : public
        Basic_Arg_Traits_T<
            CosNotifyChannelAdmin::InterFilterGroupOperator
          >
  {
  };

#endif /* end #if !defined */
}


// TAO_IDL - Generated from
// be/be_interface.cpp:1539

class TAO_Event_Forwarder_StructuredProxyPushSupplier_Perfect_Hash_OpTable
  : public TAO_Perfect_Hash_OpTable
{
private:
  unsigned int hash (const char *str, unsigned int len);

public:
  const TAO_operation_db_entry * lookup (const char *str, unsigned int len);
};

/* C++ code produced by gperf version 2.8 (ACE version) */
/* Command-line: /work/a/ports/devel/ace+tao/work/ACE_wrappers/bin/gperf -m -M -J -c -C -D -E -T -f 0 -F 0,0,0 -a -o -t -p -K opname_ -L C++ -Z TAO_Event_Forwarder_StructuredProxyPushSupplier_Perfect_Hash_OpTable -N lookup  */
unsigned int
TAO_Event_Forwarder_StructuredProxyPushSupplier_Perfect_Hash_OpTable::hash (const char *str, unsigned int len)
{
  static const unsigned char asso_values[] =
    {
#if defined (ACE_MVS)
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47,  0,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 11,
     47, 10,  5,  0,  0, 15, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 15,
     25, 47, 47,  0, 47, 47, 47, 47, 47, 47,
     47, 47,  0, 25, 47, 25, 47, 47, 15, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47,
#else
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47, 47, 47, 47, 47, 47,
     47, 47, 47, 47, 47,  0, 47, 11, 47, 10,
      5,  0,  0, 15, 47, 47, 47, 47, 47, 47,
     15, 25, 47, 47,  0,  0, 25, 47, 25, 47,
     47, 15, 47, 47, 47, 47, 47, 47,
#endif /* ACE_MVS */
    };
  return len + asso_values[(int) str[len - 1]] + asso_values[(int) str[0]];
}

const class TAO_operation_db_entry *
TAO_Event_Forwarder_StructuredProxyPushSupplier_Perfect_Hash_OpTable::lookup (const char *str, unsigned int len)
{
  enum
    {
      TOTAL_KEYWORDS = 29,
      MIN_WORD_LENGTH = 5,
      MAX_WORD_LENGTH = 35,
      MIN_HASH_VALUE = 7,
      MAX_HASH_VALUE = 46,
      HASH_VALUE_RANGE = 40,
      DUPLICATES = 4,
      WORDLIST_SIZE = 36
    };

  static const class TAO_operation_db_entry  wordlist[] =
    {
      {"",0,0,0},{"",0,0,0},{"",0,0,0},{"",0,0,0},{"",0,0,0},{"",0,0,0},{"",0,0,0},
      {"set_qos", &POA_Event_Forwarder::StructuredProxyPushSupplier::set_qos_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::set_qos, 0},
      {"_interface", &POA_Event_Forwarder::StructuredProxyPushSupplier::_interface_skel, 0, 0},
      {"_get_MyType", &POA_Event_Forwarder::StructuredProxyPushSupplier::_get_MyType_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::_get_MyType, 0},
      {"remove_filter", &POA_Event_Forwarder::StructuredProxyPushSupplier::remove_filter_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::remove_filter, 0},
      {"_is_a", &POA_Event_Forwarder::StructuredProxyPushSupplier::_is_a_skel, 0, 0},
      {"remove_all_filters", &POA_Event_Forwarder::StructuredProxyPushSupplier::remove_all_filters_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::remove_all_filters, 0},
      {"subscription_change", &POA_Event_Forwarder::StructuredProxyPushSupplier::subscription_change_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::subscription_change, 0},
      {"_get_priority_filter", &POA_Event_Forwarder::StructuredProxyPushSupplier::_get_priority_filter_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::_get_priority_filter, 0},
      {"_set_lifetime_filter", &POA_Event_Forwarder::StructuredProxyPushSupplier::_set_lifetime_filter_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::_set_lifetime_filter, 0},
      {"_get_lifetime_filter", &POA_Event_Forwarder::StructuredProxyPushSupplier::_get_lifetime_filter_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::_get_lifetime_filter, 0},
      {"_set_priority_filter", &POA_Event_Forwarder::StructuredProxyPushSupplier::_set_priority_filter_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::_set_priority_filter, 0},
      {"add_filter", &POA_Event_Forwarder::StructuredProxyPushSupplier::add_filter_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::add_filter, 0},
      {"get_qos", &POA_Event_Forwarder::StructuredProxyPushSupplier::get_qos_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::get_qos, 0},
      {"forward_structured", &POA_Event_Forwarder::StructuredProxyPushSupplier::forward_structured_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::forward_structured, 0},
      {"get_filter", &POA_Event_Forwarder::StructuredProxyPushSupplier::get_filter_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::get_filter, 0},
      {"forward_any", &POA_Event_Forwarder::StructuredProxyPushSupplier::forward_any_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::forward_any, 0},
      {"_get_MyAdmin", &POA_Event_Forwarder::StructuredProxyPushSupplier::_get_MyAdmin_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::_get_MyAdmin, 0},
      {"get_all_filters", &POA_Event_Forwarder::StructuredProxyPushSupplier::get_all_filters_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::get_all_filters, 0},
      {"resume_connection", &POA_Event_Forwarder::StructuredProxyPushSupplier::resume_connection_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::resume_connection, 0},
      {"suspend_connection", &POA_Event_Forwarder::StructuredProxyPushSupplier::suspend_connection_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::suspend_connection, 0},
      {"_component", &POA_Event_Forwarder::StructuredProxyPushSupplier::_component_skel, 0, 0},
      {"validate_qos", &POA_Event_Forwarder::StructuredProxyPushSupplier::validate_qos_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::validate_qos, 0},
      {"_non_existent", &POA_Event_Forwarder::StructuredProxyPushSupplier::_non_existent_skel, 0, 0},
      {"forward_any_no_filtering", &POA_Event_Forwarder::StructuredProxyPushSupplier::forward_any_no_filtering_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::forward_any_no_filtering, 0},
      {"disconnect_structured_push_supplier", &POA_Event_Forwarder::StructuredProxyPushSupplier::disconnect_structured_push_supplier_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::disconnect_structured_push_supplier, 0},
      {"connect_structured_push_consumer", &POA_Event_Forwarder::StructuredProxyPushSupplier::connect_structured_push_consumer_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::connect_structured_push_consumer, 0},
      {"validate_event_qos", &POA_Event_Forwarder::StructuredProxyPushSupplier::validate_event_qos_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::validate_event_qos, 0},
      {"obtain_offered_types", &POA_Event_Forwarder::StructuredProxyPushSupplier::obtain_offered_types_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::obtain_offered_types, 0},
      {"forward_structured_no_filtering", &POA_Event_Forwarder::StructuredProxyPushSupplier::forward_structured_no_filtering_skel, &POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::forward_structured_no_filtering, 0},
    };

  static const signed char lookup[] =
    {
       -1,  -1,  -1,  -1,  -1,  -1,  -1,   7,  -1,  -1,   8,   9,  -1,  10, 
      -14,  -4,  11,  -1,  12,  13, -52,  18,  19,  20,  -1,  21,  22,  23, 
       -1,  -1,  24,  -1,  25,  26,  -1,  27,  -1,  28,  29,  30,  31,  -1, 
       32,  33,  -1,  34,  35, 
    };

  if (len <= MAX_WORD_LENGTH && len >= MIN_WORD_LENGTH)
    {
      unsigned int key = hash (str, len);

      if (key <= MAX_HASH_VALUE && key >= MIN_HASH_VALUE)
        {
          int slot = lookup[key];

          if (slot >= 0 && slot < WORDLIST_SIZE)
            {
              const char *s = wordlist[slot].opname_;

              if (*str == *s && !strncmp (str + 1, s + 1, len - 1))
                return &wordlist[slot];
            }
          else if (slot < 0 && slot >= -MAX_HASH_VALUE)
            return 0;
          else
            {
              unsigned int offset = key + slot + (slot > 0 ? -MAX_HASH_VALUE : MAX_HASH_VALUE);
              const class TAO_operation_db_entry  *base = &wordlist[-lookup[offset]];
              const class TAO_operation_db_entry  *ptr = base + -lookup[offset + 1];

              while (--ptr >= base)
                if (*str == *ptr->opname_ && !strncmp (str + 1, ptr->opname_ + 1, len - 1))
                  return ptr;
            }
        }
    }
  return 0;
}

static TAO_Event_Forwarder_StructuredProxyPushSupplier_Perfect_Hash_OpTable tao_Event_Forwarder_StructuredProxyPushSupplier_optable;

// TAO_IDL - Generated from
// be/be_visitor_interface/interceptors_ss.cpp:53

#if (TAO_HAS_INTERCEPTORS == 1)

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:74

class TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured : public TAO_ServerRequestInfo
{
public:
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured (
      TAO_ServerRequest &_tao_server_request,
      TAO_Object_Adapter::Servant_Upcall *tao_servant_upcall,
      POA_Event_Forwarder::StructuredProxyPushSupplier *tao_impl,
      const ::CosNotification::StructuredEvent & event
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    );
  
  virtual Dynamic::ParameterList * arguments (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual Dynamic::ExceptionList * exceptions (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Any * result (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual char * target_most_derived_interface (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Boolean target_is_a (
      const char * id
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
private:
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured (
      const TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured &
    );
  
  void operator= (
      const TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured &
    );
  
private:
  POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl;
  
  const ::CosNotification::StructuredEvent & event_;
};

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:438

TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured::TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured (
    TAO_ServerRequest &_tao_server_request,
    TAO_Object_Adapter::Servant_Upcall *_tao_servant_upcall,
    POA_Event_Forwarder::StructuredProxyPushSupplier *tao_impl,
    const ::CosNotification::StructuredEvent & event
    ACE_ENV_ARG_DECL_NOT_USED
  )
  : TAO_ServerRequestInfo (_tao_server_request, _tao_servant_upcall),
    _tao_impl (tao_impl),
    event_ (event)
{}

Dynamic::ParameterList *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured::arguments (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the argument list on demand.
  Dynamic::ParameterList *parameter_list =
    TAO_RequestInfo_Util::make_parameter_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  Dynamic::ParameterList_var safe_parameter_list = parameter_list;
  parameter_list->length (1);
  CORBA::ULong len = 0;
  
  (*parameter_list)[len].argument <<=  this->event_;
  (*parameter_list)[len].mode = CORBA::PARAM_IN;
  len++;
  
  return safe_parameter_list._retn ();
}

Dynamic::ExceptionList *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured::exceptions (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the exception list on demand.
  Dynamic::ExceptionList *exception_list =
    TAO_RequestInfo_Util::make_exception_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return exception_list;
}

CORBA::Any * 
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured::result (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the result on demand.
  CORBA::Boolean tk_void_any = 1;
  CORBA::Any *result_any =
    TAO_RequestInfo_Util::make_any (tk_void_any ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return result_any;
}

char *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured::target_most_derived_interface (
    ACE_ENV_SINGLE_ARG_DECL_NOT_USED
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return
    CORBA::string_dup (this->_tao_impl->_interface_repository_id ());
}

CORBA::Boolean
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured::target_is_a (
    const char * id
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return this->_tao_impl->_is_a (id ACE_ENV_ARG_PARAMETER);
}

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:74

class TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering : public TAO_ServerRequestInfo
{
public:
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering (
      TAO_ServerRequest &_tao_server_request,
      TAO_Object_Adapter::Servant_Upcall *tao_servant_upcall,
      POA_Event_Forwarder::StructuredProxyPushSupplier *tao_impl,
      const ::CosNotification::StructuredEvent & event
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    );
  
  virtual Dynamic::ParameterList * arguments (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual Dynamic::ExceptionList * exceptions (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Any * result (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual char * target_most_derived_interface (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Boolean target_is_a (
      const char * id
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
private:
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering (
      const TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering &
    );
  
  void operator= (
      const TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering &
    );
  
private:
  POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl;
  
  const ::CosNotification::StructuredEvent & event_;
};

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:438

TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering::TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering (
    TAO_ServerRequest &_tao_server_request,
    TAO_Object_Adapter::Servant_Upcall *_tao_servant_upcall,
    POA_Event_Forwarder::StructuredProxyPushSupplier *tao_impl,
    const ::CosNotification::StructuredEvent & event
    ACE_ENV_ARG_DECL_NOT_USED
  )
  : TAO_ServerRequestInfo (_tao_server_request, _tao_servant_upcall),
    _tao_impl (tao_impl),
    event_ (event)
{}

Dynamic::ParameterList *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering::arguments (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the argument list on demand.
  Dynamic::ParameterList *parameter_list =
    TAO_RequestInfo_Util::make_parameter_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  Dynamic::ParameterList_var safe_parameter_list = parameter_list;
  parameter_list->length (1);
  CORBA::ULong len = 0;
  
  (*parameter_list)[len].argument <<=  this->event_;
  (*parameter_list)[len].mode = CORBA::PARAM_IN;
  len++;
  
  return safe_parameter_list._retn ();
}

Dynamic::ExceptionList *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering::exceptions (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the exception list on demand.
  Dynamic::ExceptionList *exception_list =
    TAO_RequestInfo_Util::make_exception_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return exception_list;
}

CORBA::Any * 
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering::result (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the result on demand.
  CORBA::Boolean tk_void_any = 1;
  CORBA::Any *result_any =
    TAO_RequestInfo_Util::make_any (tk_void_any ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return result_any;
}

char *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering::target_most_derived_interface (
    ACE_ENV_SINGLE_ARG_DECL_NOT_USED
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return
    CORBA::string_dup (this->_tao_impl->_interface_repository_id ());
}

CORBA::Boolean
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering::target_is_a (
    const char * id
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return this->_tao_impl->_is_a (id ACE_ENV_ARG_PARAMETER);
}

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:74

class TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any : public TAO_ServerRequestInfo
{
public:
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any (
      TAO_ServerRequest &_tao_server_request,
      TAO_Object_Adapter::Servant_Upcall *tao_servant_upcall,
      POA_Event_Forwarder::StructuredProxyPushSupplier *tao_impl,
      const ::CORBA::Any & event
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    );
  
  virtual Dynamic::ParameterList * arguments (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual Dynamic::ExceptionList * exceptions (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Any * result (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual char * target_most_derived_interface (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Boolean target_is_a (
      const char * id
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
private:
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any (
      const TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any &
    );
  
  void operator= (
      const TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any &
    );
  
private:
  POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl;
  
  const ::CORBA::Any & event_;
};

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:438

TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any::TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any (
    TAO_ServerRequest &_tao_server_request,
    TAO_Object_Adapter::Servant_Upcall *_tao_servant_upcall,
    POA_Event_Forwarder::StructuredProxyPushSupplier *tao_impl,
    const ::CORBA::Any & event
    ACE_ENV_ARG_DECL_NOT_USED
  )
  : TAO_ServerRequestInfo (_tao_server_request, _tao_servant_upcall),
    _tao_impl (tao_impl),
    event_ (event)
{}

Dynamic::ParameterList *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any::arguments (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the argument list on demand.
  Dynamic::ParameterList *parameter_list =
    TAO_RequestInfo_Util::make_parameter_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  Dynamic::ParameterList_var safe_parameter_list = parameter_list;
  parameter_list->length (1);
  CORBA::ULong len = 0;
  
  (*parameter_list)[len].argument <<= event_;
  (*parameter_list)[len].mode = CORBA::PARAM_IN;
  len++;
  
  return safe_parameter_list._retn ();
}

Dynamic::ExceptionList *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any::exceptions (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the exception list on demand.
  Dynamic::ExceptionList *exception_list =
    TAO_RequestInfo_Util::make_exception_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return exception_list;
}

CORBA::Any * 
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any::result (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the result on demand.
  CORBA::Boolean tk_void_any = 1;
  CORBA::Any *result_any =
    TAO_RequestInfo_Util::make_any (tk_void_any ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return result_any;
}

char *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any::target_most_derived_interface (
    ACE_ENV_SINGLE_ARG_DECL_NOT_USED
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return
    CORBA::string_dup (this->_tao_impl->_interface_repository_id ());
}

CORBA::Boolean
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any::target_is_a (
    const char * id
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return this->_tao_impl->_is_a (id ACE_ENV_ARG_PARAMETER);
}

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:74

class TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering : public TAO_ServerRequestInfo
{
public:
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering (
      TAO_ServerRequest &_tao_server_request,
      TAO_Object_Adapter::Servant_Upcall *tao_servant_upcall,
      POA_Event_Forwarder::StructuredProxyPushSupplier *tao_impl,
      const ::CORBA::Any & event
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    );
  
  virtual Dynamic::ParameterList * arguments (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual Dynamic::ExceptionList * exceptions (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Any * result (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual char * target_most_derived_interface (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Boolean target_is_a (
      const char * id
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
private:
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering (
      const TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering &
    );
  
  void operator= (
      const TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering &
    );
  
private:
  POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl;
  
  const ::CORBA::Any & event_;
};

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:438

TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering::TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering (
    TAO_ServerRequest &_tao_server_request,
    TAO_Object_Adapter::Servant_Upcall *_tao_servant_upcall,
    POA_Event_Forwarder::StructuredProxyPushSupplier *tao_impl,
    const ::CORBA::Any & event
    ACE_ENV_ARG_DECL_NOT_USED
  )
  : TAO_ServerRequestInfo (_tao_server_request, _tao_servant_upcall),
    _tao_impl (tao_impl),
    event_ (event)
{}

Dynamic::ParameterList *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering::arguments (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the argument list on demand.
  Dynamic::ParameterList *parameter_list =
    TAO_RequestInfo_Util::make_parameter_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  Dynamic::ParameterList_var safe_parameter_list = parameter_list;
  parameter_list->length (1);
  CORBA::ULong len = 0;
  
  (*parameter_list)[len].argument <<= event_;
  (*parameter_list)[len].mode = CORBA::PARAM_IN;
  len++;
  
  return safe_parameter_list._retn ();
}

Dynamic::ExceptionList *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering::exceptions (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the exception list on demand.
  Dynamic::ExceptionList *exception_list =
    TAO_RequestInfo_Util::make_exception_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return exception_list;
}

CORBA::Any * 
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering::result (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the result on demand.
  CORBA::Boolean tk_void_any = 1;
  CORBA::Any *result_any =
    TAO_RequestInfo_Util::make_any (tk_void_any ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return result_any;
}

char *
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering::target_most_derived_interface (
    ACE_ENV_SINGLE_ARG_DECL_NOT_USED
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return
    CORBA::string_dup (this->_tao_impl->_interface_repository_id ());
}

CORBA::Boolean
TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering::target_is_a (
    const char * id
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return this->_tao_impl->_is_a (id ACE_ENV_ARG_PARAMETER);
}

#endif /* TAO_HAS_INTERCEPTORS */

///////////////////////////////////////////////////////////////////////
//            Strategized Proxy Broker Implementation
//

// TAO_IDL - Generated from
// be/be_visitor_interface/strategized_proxy_broker_ss.cpp:40

// Factory function Implementation.
POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker *
POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker::the_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker (void)
{
  static POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker
  strategized_proxy_broker;
  
  return &strategized_proxy_broker;
}

POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker (void)
{
}

POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker::~_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker (void)
{
}

TAO::Collocation_Strategy
POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker::get_strategy (
    CORBA::Object_ptr obj
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  TAO::Collocation_Strategy strategy =
    TAO_ORB_Core::collocation_strategy (obj ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (TAO::TAO_CS_REMOTE_STRATEGY);
  
  return strategy;
}

void
POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker::dispatch (
    CORBA::Object_ptr obj,
    CORBA::Object_out forward_obj,
    TAO::Argument ** args,
    int num_args,
    const char * op,
    size_t op_len,
    TAO::Collocation_Strategy strategy
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::Exception))
{
  TAO_Object_Adapter::Servant_Upcall servant_upcall (
      obj->_stubobj ()->servant_orb_var ()->orb_core ()
    );
  
  TAO_Collocated_Skeleton collocated_skel;
  TAO_Abstract_ServantBase *servant = 0;
  
  if (strategy == TAO::TAO_CS_THRU_POA_STRATEGY)
    {
      servant_upcall.prepare_for_upcall (
          obj->_stubobj ()->object_key (),
          op,
          forward_obj
          ACE_ENV_ARG_PARAMETER
        );
      ACE_CHECK;
      
      servant_upcall.pre_invoke_collocated_request (
          ACE_ENV_SINGLE_ARG_PARAMETER
        );
      ACE_CHECK;
      
      servant = servant_upcall.servant ();
    }
  else
    {
      servant = obj->_servant ();
    }
  
  int status = servant->_find (op,
                               collocated_skel,
                               strategy,
                               op_len);
  
  if (status == -1)
    {
      ACE_THROW (CORBA::BAD_OPERATION ());
    }
  
  ACE_TRY
    {
      collocated_skel (servant,
                       args,
                       num_args
                       ACE_ENV_ARG_PARAMETER);
      ACE_TRY_CHECK;
    }
#if (TAO_HAS_MINIMUM_CORBA == 0)
  ACE_CATCH (PortableServer::ForwardRequest, forward_request)
    {
      forward_obj =
        CORBA::Object::_duplicate (forward_request.forward_reference.in ());
      return;
    }
#else
  ACE_CATCHANY
    {
      ACE_UNUSED_ARG (forward_obj);
      ACE_RE_THROW;
    }
#endif /* TAO_HAS_MINIMUM_CORBA */
  ACE_ENDTRY;
  ACE_CHECK;
}

//
//        End Strategized Proxy Broker Implementation
///////////////////////////////////////////////////////////////////////

// TAO_IDL - Generated from
// be/be_visitor_interface/interface_ss.cpp:648

TAO::Collocation_Proxy_Broker *
Event_Forwarder__TAO_StructuredProxyPushSupplier_Proxy_Broker_Factory_function (CORBA::Object_ptr)
{
  return
    ::POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker::the_TAO_StructuredProxyPushSupplier_Strategized_Proxy_Broker ();
}

int
Event_Forwarder__TAO_StructuredProxyPushSupplier_Proxy_Broker_Factory_Initializer (size_t)
{
  Event_Forwarder__TAO_StructuredProxyPushSupplier_Proxy_Broker_Factory_function_pointer = 
    Event_Forwarder__TAO_StructuredProxyPushSupplier_Proxy_Broker_Factory_function;
  
  return 0;
}

static int
Event_Forwarder__TAO_StructuredProxyPushSupplier_Proxy_Broker_Stub_Factory_Initializer_Scarecrow =
  Event_Forwarder__TAO_StructuredProxyPushSupplier_Proxy_Broker_Factory_Initializer (
      reinterpret_cast<
          size_t> (
          Event_Forwarder__TAO_StructuredProxyPushSupplier_Proxy_Broker_Factory_Initializer
        )
    );


///////////////////////////////////////////////////////////////////////
//                 ThruPOA Proxy  Implementation
//

// TAO_IDL - Generated from
// be/be_visitor_interface/thru_poa_proxy_impl_ss.cpp:37

POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl (void)
{}

// ThruPOA Implementation of the IDL interface methods

// TAO_IDL - Generated from 
// be/be_visitor_operation/thru_poa_proxy_impl_ss.cpp:52

void
POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::forward_structured (
    TAO_Abstract_ServantBase *servant,
    TAO::Argument ** args,
    int 
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  reinterpret_cast<
      POA_Event_Forwarder::StructuredProxyPushSupplier_ptr> (
      servant->_downcast (
          "IDL:Event_Forwarder/StructuredProxyPushSupplier:1.0"
        )
    )->forward_structured (
        ((TAO::Arg_Traits< ::CosNotification::StructuredEvent>::in_arg_val *) args[1])->arg ()
        ACE_ENV_ARG_PARAMETER
      );
  ACE_CHECK;
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/thru_poa_proxy_impl_ss.cpp:52

void
POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::forward_structured_no_filtering (
    TAO_Abstract_ServantBase *servant,
    TAO::Argument ** args,
    int 
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  reinterpret_cast<
      POA_Event_Forwarder::StructuredProxyPushSupplier_ptr> (
      servant->_downcast (
          "IDL:Event_Forwarder/StructuredProxyPushSupplier:1.0"
        )
    )->forward_structured_no_filtering (
        ((TAO::Arg_Traits< ::CosNotification::StructuredEvent>::in_arg_val *) args[1])->arg ()
        ACE_ENV_ARG_PARAMETER
      );
  ACE_CHECK;
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/thru_poa_proxy_impl_ss.cpp:52

void
POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::forward_any (
    TAO_Abstract_ServantBase *servant,
    TAO::Argument ** args,
    int 
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  reinterpret_cast<
      POA_Event_Forwarder::StructuredProxyPushSupplier_ptr> (
      servant->_downcast (
          "IDL:Event_Forwarder/StructuredProxyPushSupplier:1.0"
        )
    )->forward_any (
        ((TAO::Arg_Traits< CORBA::Any>::in_arg_val *) args[1])->arg ()
        ACE_ENV_ARG_PARAMETER
      );
  ACE_CHECK;
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/thru_poa_proxy_impl_ss.cpp:52

void
POA_Event_Forwarder::_TAO_StructuredProxyPushSupplier_ThruPOA_Proxy_Impl::forward_any_no_filtering (
    TAO_Abstract_ServantBase *servant,
    TAO::Argument ** args,
    int 
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  reinterpret_cast<
      POA_Event_Forwarder::StructuredProxyPushSupplier_ptr> (
      servant->_downcast (
          "IDL:Event_Forwarder/StructuredProxyPushSupplier:1.0"
        )
    )->forward_any_no_filtering (
        ((TAO::Arg_Traits< CORBA::Any>::in_arg_val *) args[1])->arg ()
        ACE_ENV_ARG_PARAMETER
      );
  ACE_CHECK;
}

//
//           End ThruPOA Proxy Implementation
///////////////////////////////////////////////////////////////////////

// TAO_IDL - Generated from 
// be/be_visitor_interface/interface_ss.cpp:97

POA_Event_Forwarder::StructuredProxyPushSupplier::StructuredProxyPushSupplier (void)
{
  this->optable_ = &tao_Event_Forwarder_StructuredProxyPushSupplier_optable;
}

POA_Event_Forwarder::StructuredProxyPushSupplier::StructuredProxyPushSupplier (const StructuredProxyPushSupplier& rhs)
  : TAO_Abstract_ServantBase (rhs),
    TAO_ServantBase (rhs),
    ACE_NESTED_CLASS (POA_CosNotification, QoSAdmin) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyFilter, FilterAdmin) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyChannelAdmin, ProxySupplier) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyComm, NotifySubscribe) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyComm, StructuredPushSupplier) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyChannelAdmin, StructuredProxyPushSupplier) (rhs)
{
}

POA_Event_Forwarder::StructuredProxyPushSupplier::~StructuredProxyPushSupplier (void)
{
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/operation_ss.cpp:98

void POA_Event_Forwarder::StructuredProxyPushSupplier::forward_structured_skel (
    TAO_ServerRequest &_tao_server_request,
    void *_tao_servant,
    void *_tao_servant_upcall
    ACE_ENV_ARG_DECL
  )
{
    TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl =
    static_cast<
        POA_Event_Forwarder::StructuredProxyPushSupplier *> (
        _tao_servant
      );
  _tao_server_request.argument_flag (0);
  
  ::CosNotification::StructuredEvent event;
  
  if (!(
      (_tao_in >> event)
      ))
    {
      TAO_InputCDR::throw_skel_exception (errno ACE_ENV_ARG_PARAMETER);
      ACE_CHECK;
    }
  
#if (TAO_HAS_INTERCEPTORS == 1)
  TAO_Object_Adapter::Servant_Upcall *_tao_upcall =
    static_cast<
        TAO_Object_Adapter::Servant_Upcall *> (
        _tao_servant_upcall
      );
    
  TAO_ServerRequestInterceptor_Adapter _tao_vfr (
      _tao_server_request.orb_core ()->server_request_interceptors (),
      _tao_server_request.interceptor_count ()
    );
  
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured _tao_ri (
      _tao_server_request,
      _tao_upcall,
      _tao_impl,
      
      event
      ACE_ENV_ARG_PARAMETER
    );
  
  ACE_TRY
    {
      {
        TAO::PICurrent_Guard _tao_pi_guard (_tao_ri.server_request (),
                                            true  /* Copy TSC to RSC */);
        
        _tao_vfr.receive_request (&_tao_ri ACE_ENV_ARG_PARAMETER);
        ACE_TRY_CHECK;
        
        if (!_tao_vfr.location_forwarded ())
          {
#endif /* TAO_HAS_INTERCEPTORS */
            
              _tao_impl->forward_structured (
                  event
                  ACE_ENV_ARG_PARAMETER
                );
            TAO_INTERCEPTOR_CHECK;
#if (TAO_HAS_INTERCEPTORS == 1)
          }
      }
      
      if (!_tao_vfr.location_forwarded ())
        {
          _tao_ri.reply_status (PortableInterceptor::SUCCESSFUL);
          _tao_vfr.send_reply (&_tao_ri ACE_ENV_ARG_PARAMETER);
          ACE_TRY_CHECK;
        }
    }
  ACE_CATCHANY
    {
      _tao_ri.exception (&ACE_ANY_EXCEPTION);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION
          || _tao_status == PortableInterceptor::USER_EXCEPTION)
        {
          ACE_RE_THROW;
        }
    }
  
# if defined (ACE_HAS_EXCEPTIONS) \
  && defined (ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS)
  ACE_CATCHALL
    {
      CORBA::UNKNOWN ex;
      
      _tao_ri.exception (&ex);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION)
        ACE_TRY_THROW (ex);
    }
# endif  /* ACE_HAS_EXCEPTIONS && ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS */
  ACE_ENDTRY;
  ACE_CHECK;
#endif /* TAO_HAS_INTERCEPTORS */
  
  _tao_server_request.init_reply ();
  
  // In case _tao_servant_upcall is not used in this function
  ACE_UNUSED_ARG (_tao_servant_upcall);
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/operation_ss.cpp:98

void POA_Event_Forwarder::StructuredProxyPushSupplier::forward_structured_no_filtering_skel (
    TAO_ServerRequest &_tao_server_request,
    void *_tao_servant,
    void *_tao_servant_upcall
    ACE_ENV_ARG_DECL
  )
{
    TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl =
    static_cast<
        POA_Event_Forwarder::StructuredProxyPushSupplier *> (
        _tao_servant
      );
  _tao_server_request.argument_flag (0);
  
  ::CosNotification::StructuredEvent event;
  
  if (!(
      (_tao_in >> event)
      ))
    {
      TAO_InputCDR::throw_skel_exception (errno ACE_ENV_ARG_PARAMETER);
      ACE_CHECK;
    }
  
#if (TAO_HAS_INTERCEPTORS == 1)
  TAO_Object_Adapter::Servant_Upcall *_tao_upcall =
    static_cast<
        TAO_Object_Adapter::Servant_Upcall *> (
        _tao_servant_upcall
      );
    
  TAO_ServerRequestInterceptor_Adapter _tao_vfr (
      _tao_server_request.orb_core ()->server_request_interceptors (),
      _tao_server_request.interceptor_count ()
    );
  
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_structured_no_filtering _tao_ri (
      _tao_server_request,
      _tao_upcall,
      _tao_impl,
      
      event
      ACE_ENV_ARG_PARAMETER
    );
  
  ACE_TRY
    {
      {
        TAO::PICurrent_Guard _tao_pi_guard (_tao_ri.server_request (),
                                            true  /* Copy TSC to RSC */);
        
        _tao_vfr.receive_request (&_tao_ri ACE_ENV_ARG_PARAMETER);
        ACE_TRY_CHECK;
        
        if (!_tao_vfr.location_forwarded ())
          {
#endif /* TAO_HAS_INTERCEPTORS */
            
              _tao_impl->forward_structured_no_filtering (
                  event
                  ACE_ENV_ARG_PARAMETER
                );
            TAO_INTERCEPTOR_CHECK;
#if (TAO_HAS_INTERCEPTORS == 1)
          }
      }
      
      if (!_tao_vfr.location_forwarded ())
        {
          _tao_ri.reply_status (PortableInterceptor::SUCCESSFUL);
          _tao_vfr.send_reply (&_tao_ri ACE_ENV_ARG_PARAMETER);
          ACE_TRY_CHECK;
        }
    }
  ACE_CATCHANY
    {
      _tao_ri.exception (&ACE_ANY_EXCEPTION);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION
          || _tao_status == PortableInterceptor::USER_EXCEPTION)
        {
          ACE_RE_THROW;
        }
    }
  
# if defined (ACE_HAS_EXCEPTIONS) \
  && defined (ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS)
  ACE_CATCHALL
    {
      CORBA::UNKNOWN ex;
      
      _tao_ri.exception (&ex);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION)
        ACE_TRY_THROW (ex);
    }
# endif  /* ACE_HAS_EXCEPTIONS && ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS */
  ACE_ENDTRY;
  ACE_CHECK;
#endif /* TAO_HAS_INTERCEPTORS */
  
  _tao_server_request.init_reply ();
  
  // In case _tao_servant_upcall is not used in this function
  ACE_UNUSED_ARG (_tao_servant_upcall);
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/operation_ss.cpp:98

void POA_Event_Forwarder::StructuredProxyPushSupplier::forward_any_skel (
    TAO_ServerRequest &_tao_server_request,
    void *_tao_servant,
    void *_tao_servant_upcall
    ACE_ENV_ARG_DECL
  )
{
    TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl =
    static_cast<
        POA_Event_Forwarder::StructuredProxyPushSupplier *> (
        _tao_servant
      );
  _tao_server_request.argument_flag (0);
  
  ::CORBA::Any event;
  
  if (!(
      (_tao_in >> event)
      ))
    {
      TAO_InputCDR::throw_skel_exception (errno ACE_ENV_ARG_PARAMETER);
      ACE_CHECK;
    }
  
#if (TAO_HAS_INTERCEPTORS == 1)
  TAO_Object_Adapter::Servant_Upcall *_tao_upcall =
    static_cast<
        TAO_Object_Adapter::Servant_Upcall *> (
        _tao_servant_upcall
      );
    
  TAO_ServerRequestInterceptor_Adapter _tao_vfr (
      _tao_server_request.orb_core ()->server_request_interceptors (),
      _tao_server_request.interceptor_count ()
    );
  
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any _tao_ri (
      _tao_server_request,
      _tao_upcall,
      _tao_impl,
      
      event
      ACE_ENV_ARG_PARAMETER
    );
  
  ACE_TRY
    {
      {
        TAO::PICurrent_Guard _tao_pi_guard (_tao_ri.server_request (),
                                            true  /* Copy TSC to RSC */);
        
        _tao_vfr.receive_request (&_tao_ri ACE_ENV_ARG_PARAMETER);
        ACE_TRY_CHECK;
        
        if (!_tao_vfr.location_forwarded ())
          {
#endif /* TAO_HAS_INTERCEPTORS */
            
              _tao_impl->forward_any (
                  event
                  ACE_ENV_ARG_PARAMETER
                );
            TAO_INTERCEPTOR_CHECK;
#if (TAO_HAS_INTERCEPTORS == 1)
          }
      }
      
      if (!_tao_vfr.location_forwarded ())
        {
          _tao_ri.reply_status (PortableInterceptor::SUCCESSFUL);
          _tao_vfr.send_reply (&_tao_ri ACE_ENV_ARG_PARAMETER);
          ACE_TRY_CHECK;
        }
    }
  ACE_CATCHANY
    {
      _tao_ri.exception (&ACE_ANY_EXCEPTION);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION
          || _tao_status == PortableInterceptor::USER_EXCEPTION)
        {
          ACE_RE_THROW;
        }
    }
  
# if defined (ACE_HAS_EXCEPTIONS) \
  && defined (ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS)
  ACE_CATCHALL
    {
      CORBA::UNKNOWN ex;
      
      _tao_ri.exception (&ex);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION)
        ACE_TRY_THROW (ex);
    }
# endif  /* ACE_HAS_EXCEPTIONS && ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS */
  ACE_ENDTRY;
  ACE_CHECK;
#endif /* TAO_HAS_INTERCEPTORS */
  
  _tao_server_request.init_reply ();
  
  // In case _tao_servant_upcall is not used in this function
  ACE_UNUSED_ARG (_tao_servant_upcall);
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/operation_ss.cpp:98

void POA_Event_Forwarder::StructuredProxyPushSupplier::forward_any_no_filtering_skel (
    TAO_ServerRequest &_tao_server_request,
    void *_tao_servant,
    void *_tao_servant_upcall
    ACE_ENV_ARG_DECL
  )
{
    TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl =
    static_cast<
        POA_Event_Forwarder::StructuredProxyPushSupplier *> (
        _tao_servant
      );
  _tao_server_request.argument_flag (0);
  
  ::CORBA::Any event;
  
  if (!(
      (_tao_in >> event)
      ))
    {
      TAO_InputCDR::throw_skel_exception (errno ACE_ENV_ARG_PARAMETER);
      ACE_CHECK;
    }
  
#if (TAO_HAS_INTERCEPTORS == 1)
  TAO_Object_Adapter::Servant_Upcall *_tao_upcall =
    static_cast<
        TAO_Object_Adapter::Servant_Upcall *> (
        _tao_servant_upcall
      );
    
  TAO_ServerRequestInterceptor_Adapter _tao_vfr (
      _tao_server_request.orb_core ()->server_request_interceptors (),
      _tao_server_request.interceptor_count ()
    );
  
  TAO_ServerRequestInfo_Event_Forwarder_StructuredProxyPushSupplier_forward_any_no_filtering _tao_ri (
      _tao_server_request,
      _tao_upcall,
      _tao_impl,
      
      event
      ACE_ENV_ARG_PARAMETER
    );
  
  ACE_TRY
    {
      {
        TAO::PICurrent_Guard _tao_pi_guard (_tao_ri.server_request (),
                                            true  /* Copy TSC to RSC */);
        
        _tao_vfr.receive_request (&_tao_ri ACE_ENV_ARG_PARAMETER);
        ACE_TRY_CHECK;
        
        if (!_tao_vfr.location_forwarded ())
          {
#endif /* TAO_HAS_INTERCEPTORS */
            
              _tao_impl->forward_any_no_filtering (
                  event
                  ACE_ENV_ARG_PARAMETER
                );
            TAO_INTERCEPTOR_CHECK;
#if (TAO_HAS_INTERCEPTORS == 1)
          }
      }
      
      if (!_tao_vfr.location_forwarded ())
        {
          _tao_ri.reply_status (PortableInterceptor::SUCCESSFUL);
          _tao_vfr.send_reply (&_tao_ri ACE_ENV_ARG_PARAMETER);
          ACE_TRY_CHECK;
        }
    }
  ACE_CATCHANY
    {
      _tao_ri.exception (&ACE_ANY_EXCEPTION);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION
          || _tao_status == PortableInterceptor::USER_EXCEPTION)
        {
          ACE_RE_THROW;
        }
    }
  
# if defined (ACE_HAS_EXCEPTIONS) \
  && defined (ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS)
  ACE_CATCHALL
    {
      CORBA::UNKNOWN ex;
      
      _tao_ri.exception (&ex);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION)
        ACE_TRY_THROW (ex);
    }
# endif  /* ACE_HAS_EXCEPTIONS && ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS */
  ACE_ENDTRY;
  ACE_CHECK;
#endif /* TAO_HAS_INTERCEPTORS */
  
  _tao_server_request.init_reply ();
  
  // In case _tao_servant_upcall is not used in this function
  ACE_UNUSED_ARG (_tao_servant_upcall);
}

// TAO_IDL - Generated from 
// be/be_visitor_interface/interface_ss.cpp:162

void POA_Event_Forwarder::StructuredProxyPushSupplier::_is_a_skel (
    TAO_ServerRequest &_tao_server_request, 
    void * _tao_servant,
    void * /* Servant_Upcall */
    ACE_ENV_ARG_DECL
  )
{
  TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
  
  POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl =
    (POA_Event_Forwarder::StructuredProxyPushSupplier *) _tao_servant;
  
  CORBA::Boolean _tao_retval = 0;
  CORBA::String_var value;
  
  if (!(_tao_in >> value.out ()))
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
  
  _tao_retval = _tao_impl->_is_a (value.in () ACE_ENV_ARG_PARAMETER);
  ACE_CHECK;
  
  _tao_server_request.init_reply ();
  TAO_OutputCDR &_tao_out = _tao_server_request.outgoing ();
  
  if (!(_tao_out << CORBA::Any::from_boolean (_tao_retval)))
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
}

void POA_Event_Forwarder::StructuredProxyPushSupplier::_non_existent_skel (
    TAO_ServerRequest &_tao_server_request, 
    void * _tao_servant,
    void * /* Servant_Upcall */
    ACE_ENV_ARG_DECL
  )
{
  POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl =
    (POA_Event_Forwarder::StructuredProxyPushSupplier *) _tao_servant;
  
  CORBA::Boolean _tao_retval =
    _tao_impl->_non_existent (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK;
  
  _tao_server_request.init_reply ();
  TAO_OutputCDR &_tao_out = _tao_server_request.outgoing ();
  
  if (!(_tao_out << CORBA::Any::from_boolean (_tao_retval)))
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
}

void POA_Event_Forwarder::StructuredProxyPushSupplier::_interface_skel (
    TAO_ServerRequest &_tao_server_request, 
    void * _tao_servant,
    void * /* Servant_Upcall */
    ACE_ENV_ARG_DECL
  )
{
  TAO_IFR_Client_Adapter *_tao_adapter =
    ACE_Dynamic_Service<TAO_IFR_Client_Adapter>::instance (
        TAO_ORB_Core::ifr_client_adapter_name ()
      );
    
  if (_tao_adapter == 0)
    {
      ACE_THROW (CORBA::INTF_REPOS ());
    }
  
  POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl =
    (POA_Event_Forwarder::StructuredProxyPushSupplier *) _tao_servant;
  
  CORBA::InterfaceDef_ptr _tao_retval = 
    _tao_impl->_get_interface (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK;
  
  _tao_server_request.init_reply ();
  TAO_OutputCDR &_tao_out = _tao_server_request.outgoing ();
  
  CORBA::Boolean _tao_result =
    _tao_adapter->interfacedef_cdr_insert (
        _tao_out,
        _tao_retval
      );
  
  _tao_adapter->dispose (_tao_retval);
  
  if (_tao_result == 0)
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
}

void POA_Event_Forwarder::StructuredProxyPushSupplier::_component_skel (
    TAO_ServerRequest &_tao_server_request, 
    void * _tao_object_reference,
    void * /* Servant_Upcall */
    ACE_ENV_ARG_DECL
  )
{
  POA_Event_Forwarder::StructuredProxyPushSupplier *_tao_impl =
    (POA_Event_Forwarder::StructuredProxyPushSupplier *) _tao_object_reference;
  
  CORBA::Object_var _tao_retval =
    _tao_impl->_get_component (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK;
  
  _tao_server_request.init_reply ();
  TAO_OutputCDR &_tao_out = _tao_server_request.outgoing ();
  
  if (!(_tao_out << _tao_retval.in ()))
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
}

CORBA::Boolean POA_Event_Forwarder::StructuredProxyPushSupplier::_is_a (
    const char* value
    ACE_ENV_ARG_DECL_NOT_USED
  )
{
  if (
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotification/QoSAdmin:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyFilter/FilterAdmin:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyChannelAdmin/ProxySupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyComm/NotifySubscribe:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyComm/StructuredPushSupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyChannelAdmin/StructuredProxyPushSupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:Event_Forwarder/StructuredProxyPushSupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CORBA/Object:1.0"
        )
     )
    {
      return 1;
    }
  else
    {
      return 0;
    }
}

void* POA_Event_Forwarder::StructuredProxyPushSupplier::_downcast (
    const char* logical_type_id
  )
{
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotification/QoSAdmin:1.0") == 0)
    {
      return static_cast<POA_CosNotification::QoSAdmin_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyFilter/FilterAdmin:1.0") == 0)
    {
      return static_cast<POA_CosNotifyFilter::FilterAdmin_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyChannelAdmin/ProxySupplier:1.0") == 0)
    {
      return static_cast<POA_CosNotifyChannelAdmin::ProxySupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyComm/NotifySubscribe:1.0") == 0)
    {
      return static_cast<POA_CosNotifyComm::NotifySubscribe_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyComm/StructuredPushSupplier:1.0") == 0)
    {
      return static_cast<POA_CosNotifyComm::StructuredPushSupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyChannelAdmin/StructuredProxyPushSupplier:1.0") == 0)
    {
      return static_cast<POA_CosNotifyChannelAdmin::StructuredProxyPushSupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:Event_Forwarder/StructuredProxyPushSupplier:1.0") == 0)
    {
      return static_cast<POA_Event_Forwarder::StructuredProxyPushSupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CORBA/Object:1.0") == 0)
    {
      return static_cast<PortableServer::Servant> (this);
    }
  
  return 0;
}

const char* POA_Event_Forwarder::StructuredProxyPushSupplier::_interface_repository_id (void) const
{
  return "IDL:Event_Forwarder/StructuredProxyPushSupplier:1.0";
}

// TAO_IDL - Generated from
// be/be_visitor_interface/interface_ss.cpp:584

void POA_Event_Forwarder::StructuredProxyPushSupplier::_dispatch (
    TAO_ServerRequest &req,
    void *servant_upcall
    ACE_ENV_ARG_DECL
  )
{
  this->synchronous_upcall_dispatch (req,
                                     servant_upcall,
                                     this
                                     ACE_ENV_ARG_PARAMETER);
}

// TAO_IDL - Generated from
// be/be_visitor_interface/interface_ss.cpp:526

Event_Forwarder::StructuredProxyPushSupplier *
POA_Event_Forwarder::StructuredProxyPushSupplier::_this (ACE_ENV_SINGLE_ARG_DECL)
{
  TAO_Stub *stub = this->_create_stub (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  TAO_Stub_Auto_Ptr safe_stub (stub);
  CORBA::Object_ptr tmp = CORBA::Object::_nil ();
  
  if (stub->servant_orb_var ()->orb_core ()->optimize_collocation_objects ())
    {
      ACE_NEW_RETURN (
          tmp,
          CORBA::Object (stub, 1, this),
          0
        );
    }
  else
    {
      ACE_NEW_RETURN (
          tmp,
          CORBA::Object (stub, 0, this),
          0
        );
    }
  
  CORBA::Object_var obj = tmp;
  (void) safe_stub.release ();
  
  typedef ::Event_Forwarder::StructuredProxyPushSupplier STUB_SCOPED_NAME;
  return
    TAO::Narrow_Utils<STUB_SCOPED_NAME>::unchecked_narrow (
        obj.in (),
        Event_Forwarder__TAO_StructuredProxyPushSupplier_Proxy_Broker_Factory_function_pointer
      );
}

// TAO_IDL - Generated from
// be/be_interface.cpp:1539

class TAO_Event_Forwarder_ProxyPushSupplier_Perfect_Hash_OpTable
  : public TAO_Perfect_Hash_OpTable
{
private:
  unsigned int hash (const char *str, unsigned int len);

public:
  const TAO_operation_db_entry * lookup (const char *str, unsigned int len);
};

/* C++ code produced by gperf version 2.8 (ACE version) */
/* Command-line: /work/a/ports/devel/ace+tao/work/ACE_wrappers/bin/gperf -m -M -J -c -C -D -E -T -f 0 -F 0,0,0 -a -o -t -p -K opname_ -L C++ -Z TAO_Event_Forwarder_ProxyPushSupplier_Perfect_Hash_OpTable -N lookup  */
unsigned int
TAO_Event_Forwarder_ProxyPushSupplier_Perfect_Hash_OpTable::hash (const char *str, unsigned int len)
{
  static const unsigned char asso_values[] =
    {
#if defined (ACE_MVS)
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51,  0,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 30,
     51, 20, 10,  0,  0, 15, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 15,
     30, 51, 51,  0, 51, 51, 51, 51, 51, 51,
     51, 51,  0, 13, 51, 25, 51, 51,  5, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51,
#else
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51, 51, 51, 51, 51, 51,
     51, 51, 51, 51, 51,  0, 51, 30, 51, 20,
     10,  0,  0, 15, 51, 51, 51, 51, 51, 51,
     15, 30, 51, 51,  0,  0, 13, 51, 25, 51,
     51,  5, 51, 51, 51, 51, 51, 51,
#endif /* ACE_MVS */
    };
  return len + asso_values[(int) str[len - 1]] + asso_values[(int) str[0]];
}

const class TAO_operation_db_entry *
TAO_Event_Forwarder_ProxyPushSupplier_Perfect_Hash_OpTable::lookup (const char *str, unsigned int len)
{
  enum
    {
      TOTAL_KEYWORDS = 29,
      MIN_WORD_LENGTH = 5,
      MAX_WORD_LENGTH = 31,
      MIN_HASH_VALUE = 7,
      MAX_HASH_VALUE = 50,
      HASH_VALUE_RANGE = 44,
      DUPLICATES = 4,
      WORDLIST_SIZE = 36
    };

  static const class TAO_operation_db_entry  wordlist[] =
    {
      {"",0,0,0},{"",0,0,0},{"",0,0,0},{"",0,0,0},{"",0,0,0},{"",0,0,0},{"",0,0,0},
      {"set_qos", &POA_Event_Forwarder::ProxyPushSupplier::set_qos_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::set_qos, 0},
      {"_interface", &POA_Event_Forwarder::ProxyPushSupplier::_interface_skel, 0, 0},
      {"_get_MyType", &POA_Event_Forwarder::ProxyPushSupplier::_get_MyType_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::_get_MyType, 0},
      {"remove_filter", &POA_Event_Forwarder::ProxyPushSupplier::remove_filter_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::remove_filter, 0},
      {"forward_any", &POA_Event_Forwarder::ProxyPushSupplier::forward_any_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::forward_any, 0},
      {"remove_all_filters", &POA_Event_Forwarder::ProxyPushSupplier::remove_all_filters_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::remove_all_filters, 0},
      {"subscription_change", &POA_Event_Forwarder::ProxyPushSupplier::subscription_change_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::subscription_change, 0},
      {"_get_priority_filter", &POA_Event_Forwarder::ProxyPushSupplier::_get_priority_filter_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::_get_priority_filter, 0},
      {"_set_lifetime_filter", &POA_Event_Forwarder::ProxyPushSupplier::_set_lifetime_filter_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::_set_lifetime_filter, 0},
      {"_get_lifetime_filter", &POA_Event_Forwarder::ProxyPushSupplier::_get_lifetime_filter_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::_get_lifetime_filter, 0},
      {"_set_priority_filter", &POA_Event_Forwarder::ProxyPushSupplier::_set_priority_filter_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::_set_priority_filter, 0},
      {"get_qos", &POA_Event_Forwarder::ProxyPushSupplier::get_qos_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::get_qos, 0},
      {"_component", &POA_Event_Forwarder::ProxyPushSupplier::_component_skel, 0, 0},
      {"get_filter", &POA_Event_Forwarder::ProxyPushSupplier::get_filter_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::get_filter, 0},
      {"_non_existent", &POA_Event_Forwarder::ProxyPushSupplier::_non_existent_skel, 0, 0},
      {"_get_MyAdmin", &POA_Event_Forwarder::ProxyPushSupplier::_get_MyAdmin_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::_get_MyAdmin, 0},
      {"forward_structured", &POA_Event_Forwarder::ProxyPushSupplier::forward_structured_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::forward_structured, 0},
      {"get_all_filters", &POA_Event_Forwarder::ProxyPushSupplier::get_all_filters_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::get_all_filters, 0},
      {"resume_connection", &POA_Event_Forwarder::ProxyPushSupplier::resume_connection_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::resume_connection, 0},
      {"suspend_connection", &POA_Event_Forwarder::ProxyPushSupplier::suspend_connection_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::suspend_connection, 0},
      {"disconnect_push_supplier", &POA_Event_Forwarder::ProxyPushSupplier::disconnect_push_supplier_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::disconnect_push_supplier, 0},
      {"_is_a", &POA_Event_Forwarder::ProxyPushSupplier::_is_a_skel, 0, 0},
      {"validate_qos", &POA_Event_Forwarder::ProxyPushSupplier::validate_qos_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::validate_qos, 0},
      {"forward_any_no_filtering", &POA_Event_Forwarder::ProxyPushSupplier::forward_any_no_filtering_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::forward_any_no_filtering, 0},
      {"add_filter", &POA_Event_Forwarder::ProxyPushSupplier::add_filter_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::add_filter, 0},
      {"validate_event_qos", &POA_Event_Forwarder::ProxyPushSupplier::validate_event_qos_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::validate_event_qos, 0},
      {"connect_any_push_consumer", &POA_Event_Forwarder::ProxyPushSupplier::connect_any_push_consumer_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::connect_any_push_consumer, 0},
      {"forward_structured_no_filtering", &POA_Event_Forwarder::ProxyPushSupplier::forward_structured_no_filtering_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::forward_structured_no_filtering, 0},
      {"obtain_offered_types", &POA_Event_Forwarder::ProxyPushSupplier::obtain_offered_types_skel, &POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::obtain_offered_types, 0},
    };

  static const signed char lookup[] =
    {
       -1,  -1,  -1,  -1,  -1,  -1,  -1,   7,  -1,  -1,   8,   9,  -1,  10, 
      -14,  -4,  11,  -1,  12,  13, -56,  -1,  18,  19,  -1,  20,  21,  22, 
       23,  -1,  24,  -1,  25,  26,  27,  28,  -1,  29,  -1,  30,  31,  -1, 
       -1,  32,  -1,  33,  34,  -1,  -1,  -1,  35, 
    };

  if (len <= MAX_WORD_LENGTH && len >= MIN_WORD_LENGTH)
    {
      unsigned int key = hash (str, len);

      if (key <= MAX_HASH_VALUE && key >= MIN_HASH_VALUE)
        {
          int slot = lookup[key];

          if (slot >= 0 && slot < WORDLIST_SIZE)
            {
              const char *s = wordlist[slot].opname_;

              if (*str == *s && !strncmp (str + 1, s + 1, len - 1))
                return &wordlist[slot];
            }
          else if (slot < 0 && slot >= -MAX_HASH_VALUE)
            return 0;
          else
            {
              unsigned int offset = key + slot + (slot > 0 ? -MAX_HASH_VALUE : MAX_HASH_VALUE);
              const class TAO_operation_db_entry  *base = &wordlist[-lookup[offset]];
              const class TAO_operation_db_entry  *ptr = base + -lookup[offset + 1];

              while (--ptr >= base)
                if (*str == *ptr->opname_ && !strncmp (str + 1, ptr->opname_ + 1, len - 1))
                  return ptr;
            }
        }
    }
  return 0;
}

static TAO_Event_Forwarder_ProxyPushSupplier_Perfect_Hash_OpTable tao_Event_Forwarder_ProxyPushSupplier_optable;

// TAO_IDL - Generated from
// be/be_visitor_interface/interceptors_ss.cpp:53

#if (TAO_HAS_INTERCEPTORS == 1)

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:74

class TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured : public TAO_ServerRequestInfo
{
public:
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured (
      TAO_ServerRequest &_tao_server_request,
      TAO_Object_Adapter::Servant_Upcall *tao_servant_upcall,
      POA_Event_Forwarder::ProxyPushSupplier *tao_impl,
      const ::CosNotification::StructuredEvent & event
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    );
  
  virtual Dynamic::ParameterList * arguments (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual Dynamic::ExceptionList * exceptions (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Any * result (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual char * target_most_derived_interface (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Boolean target_is_a (
      const char * id
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
private:
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured (
      const TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured &
    );
  
  void operator= (
      const TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured &
    );
  
private:
  POA_Event_Forwarder::ProxyPushSupplier *_tao_impl;
  
  const ::CosNotification::StructuredEvent & event_;
};

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:438

TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured::TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured (
    TAO_ServerRequest &_tao_server_request,
    TAO_Object_Adapter::Servant_Upcall *_tao_servant_upcall,
    POA_Event_Forwarder::ProxyPushSupplier *tao_impl,
    const ::CosNotification::StructuredEvent & event
    ACE_ENV_ARG_DECL_NOT_USED
  )
  : TAO_ServerRequestInfo (_tao_server_request, _tao_servant_upcall),
    _tao_impl (tao_impl),
    event_ (event)
{}

Dynamic::ParameterList *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured::arguments (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the argument list on demand.
  Dynamic::ParameterList *parameter_list =
    TAO_RequestInfo_Util::make_parameter_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  Dynamic::ParameterList_var safe_parameter_list = parameter_list;
  parameter_list->length (1);
  CORBA::ULong len = 0;
  
  (*parameter_list)[len].argument <<=  this->event_;
  (*parameter_list)[len].mode = CORBA::PARAM_IN;
  len++;
  
  return safe_parameter_list._retn ();
}

Dynamic::ExceptionList *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured::exceptions (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the exception list on demand.
  Dynamic::ExceptionList *exception_list =
    TAO_RequestInfo_Util::make_exception_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return exception_list;
}

CORBA::Any * 
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured::result (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the result on demand.
  CORBA::Boolean tk_void_any = 1;
  CORBA::Any *result_any =
    TAO_RequestInfo_Util::make_any (tk_void_any ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return result_any;
}

char *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured::target_most_derived_interface (
    ACE_ENV_SINGLE_ARG_DECL_NOT_USED
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return
    CORBA::string_dup (this->_tao_impl->_interface_repository_id ());
}

CORBA::Boolean
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured::target_is_a (
    const char * id
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return this->_tao_impl->_is_a (id ACE_ENV_ARG_PARAMETER);
}

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:74

class TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering : public TAO_ServerRequestInfo
{
public:
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering (
      TAO_ServerRequest &_tao_server_request,
      TAO_Object_Adapter::Servant_Upcall *tao_servant_upcall,
      POA_Event_Forwarder::ProxyPushSupplier *tao_impl,
      const ::CosNotification::StructuredEvent & event
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    );
  
  virtual Dynamic::ParameterList * arguments (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual Dynamic::ExceptionList * exceptions (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Any * result (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual char * target_most_derived_interface (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Boolean target_is_a (
      const char * id
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
private:
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering (
      const TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering &
    );
  
  void operator= (
      const TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering &
    );
  
private:
  POA_Event_Forwarder::ProxyPushSupplier *_tao_impl;
  
  const ::CosNotification::StructuredEvent & event_;
};

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:438

TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering::TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering (
    TAO_ServerRequest &_tao_server_request,
    TAO_Object_Adapter::Servant_Upcall *_tao_servant_upcall,
    POA_Event_Forwarder::ProxyPushSupplier *tao_impl,
    const ::CosNotification::StructuredEvent & event
    ACE_ENV_ARG_DECL_NOT_USED
  )
  : TAO_ServerRequestInfo (_tao_server_request, _tao_servant_upcall),
    _tao_impl (tao_impl),
    event_ (event)
{}

Dynamic::ParameterList *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering::arguments (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the argument list on demand.
  Dynamic::ParameterList *parameter_list =
    TAO_RequestInfo_Util::make_parameter_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  Dynamic::ParameterList_var safe_parameter_list = parameter_list;
  parameter_list->length (1);
  CORBA::ULong len = 0;
  
  (*parameter_list)[len].argument <<=  this->event_;
  (*parameter_list)[len].mode = CORBA::PARAM_IN;
  len++;
  
  return safe_parameter_list._retn ();
}

Dynamic::ExceptionList *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering::exceptions (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the exception list on demand.
  Dynamic::ExceptionList *exception_list =
    TAO_RequestInfo_Util::make_exception_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return exception_list;
}

CORBA::Any * 
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering::result (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the result on demand.
  CORBA::Boolean tk_void_any = 1;
  CORBA::Any *result_any =
    TAO_RequestInfo_Util::make_any (tk_void_any ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return result_any;
}

char *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering::target_most_derived_interface (
    ACE_ENV_SINGLE_ARG_DECL_NOT_USED
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return
    CORBA::string_dup (this->_tao_impl->_interface_repository_id ());
}

CORBA::Boolean
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering::target_is_a (
    const char * id
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return this->_tao_impl->_is_a (id ACE_ENV_ARG_PARAMETER);
}

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:74

class TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any : public TAO_ServerRequestInfo
{
public:
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any (
      TAO_ServerRequest &_tao_server_request,
      TAO_Object_Adapter::Servant_Upcall *tao_servant_upcall,
      POA_Event_Forwarder::ProxyPushSupplier *tao_impl,
      const ::CORBA::Any & event
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    );
  
  virtual Dynamic::ParameterList * arguments (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual Dynamic::ExceptionList * exceptions (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Any * result (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual char * target_most_derived_interface (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Boolean target_is_a (
      const char * id
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
private:
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any (
      const TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any &
    );
  
  void operator= (
      const TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any &
    );
  
private:
  POA_Event_Forwarder::ProxyPushSupplier *_tao_impl;
  
  const ::CORBA::Any & event_;
};

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:438

TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any::TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any (
    TAO_ServerRequest &_tao_server_request,
    TAO_Object_Adapter::Servant_Upcall *_tao_servant_upcall,
    POA_Event_Forwarder::ProxyPushSupplier *tao_impl,
    const ::CORBA::Any & event
    ACE_ENV_ARG_DECL_NOT_USED
  )
  : TAO_ServerRequestInfo (_tao_server_request, _tao_servant_upcall),
    _tao_impl (tao_impl),
    event_ (event)
{}

Dynamic::ParameterList *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any::arguments (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the argument list on demand.
  Dynamic::ParameterList *parameter_list =
    TAO_RequestInfo_Util::make_parameter_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  Dynamic::ParameterList_var safe_parameter_list = parameter_list;
  parameter_list->length (1);
  CORBA::ULong len = 0;
  
  (*parameter_list)[len].argument <<= event_;
  (*parameter_list)[len].mode = CORBA::PARAM_IN;
  len++;
  
  return safe_parameter_list._retn ();
}

Dynamic::ExceptionList *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any::exceptions (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the exception list on demand.
  Dynamic::ExceptionList *exception_list =
    TAO_RequestInfo_Util::make_exception_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return exception_list;
}

CORBA::Any * 
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any::result (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the result on demand.
  CORBA::Boolean tk_void_any = 1;
  CORBA::Any *result_any =
    TAO_RequestInfo_Util::make_any (tk_void_any ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return result_any;
}

char *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any::target_most_derived_interface (
    ACE_ENV_SINGLE_ARG_DECL_NOT_USED
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return
    CORBA::string_dup (this->_tao_impl->_interface_repository_id ());
}

CORBA::Boolean
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any::target_is_a (
    const char * id
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return this->_tao_impl->_is_a (id ACE_ENV_ARG_PARAMETER);
}

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:74

class TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering : public TAO_ServerRequestInfo
{
public:
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering (
      TAO_ServerRequest &_tao_server_request,
      TAO_Object_Adapter::Servant_Upcall *tao_servant_upcall,
      POA_Event_Forwarder::ProxyPushSupplier *tao_impl,
      const ::CORBA::Any & event
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    );
  
  virtual Dynamic::ParameterList * arguments (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual Dynamic::ExceptionList * exceptions (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Any * result (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual char * target_most_derived_interface (
      ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
  virtual CORBA::Boolean target_is_a (
      const char * id
      ACE_ENV_ARG_DECL_WITH_DEFAULTS
    )
    ACE_THROW_SPEC ((CORBA::SystemException));
  
private:
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering (
      const TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering &
    );
  
  void operator= (
      const TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering &
    );
  
private:
  POA_Event_Forwarder::ProxyPushSupplier *_tao_impl;
  
  const ::CORBA::Any & event_;
};

// TAO_IDL - Generated from
// be/be_visitor_operation/interceptors_ss.cpp:438

TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering::TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering (
    TAO_ServerRequest &_tao_server_request,
    TAO_Object_Adapter::Servant_Upcall *_tao_servant_upcall,
    POA_Event_Forwarder::ProxyPushSupplier *tao_impl,
    const ::CORBA::Any & event
    ACE_ENV_ARG_DECL_NOT_USED
  )
  : TAO_ServerRequestInfo (_tao_server_request, _tao_servant_upcall),
    _tao_impl (tao_impl),
    event_ (event)
{}

Dynamic::ParameterList *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering::arguments (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the argument list on demand.
  Dynamic::ParameterList *parameter_list =
    TAO_RequestInfo_Util::make_parameter_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  Dynamic::ParameterList_var safe_parameter_list = parameter_list;
  parameter_list->length (1);
  CORBA::ULong len = 0;
  
  (*parameter_list)[len].argument <<= event_;
  (*parameter_list)[len].mode = CORBA::PARAM_IN;
  len++;
  
  return safe_parameter_list._retn ();
}

Dynamic::ExceptionList *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering::exceptions (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the exception list on demand.
  Dynamic::ExceptionList *exception_list =
    TAO_RequestInfo_Util::make_exception_list (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return exception_list;
}

CORBA::Any * 
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering::result (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  // Generate the result on demand.
  CORBA::Boolean tk_void_any = 1;
  CORBA::Any *result_any =
    TAO_RequestInfo_Util::make_any (tk_void_any ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  return result_any;
}

char *
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering::target_most_derived_interface (
    ACE_ENV_SINGLE_ARG_DECL_NOT_USED
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return
    CORBA::string_dup (this->_tao_impl->_interface_repository_id ());
}

CORBA::Boolean
TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering::target_is_a (
    const char * id
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  return this->_tao_impl->_is_a (id ACE_ENV_ARG_PARAMETER);
}

#endif /* TAO_HAS_INTERCEPTORS */

///////////////////////////////////////////////////////////////////////
//            Strategized Proxy Broker Implementation
//

// TAO_IDL - Generated from
// be/be_visitor_interface/strategized_proxy_broker_ss.cpp:40

// Factory function Implementation.
POA_Event_Forwarder::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker *
POA_Event_Forwarder::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker::the_TAO_ProxyPushSupplier_Strategized_Proxy_Broker (void)
{
  static POA_Event_Forwarder::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker
  strategized_proxy_broker;
  
  return &strategized_proxy_broker;
}

POA_Event_Forwarder::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker (void)
{
}

POA_Event_Forwarder::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker::~_TAO_ProxyPushSupplier_Strategized_Proxy_Broker (void)
{
}

TAO::Collocation_Strategy
POA_Event_Forwarder::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker::get_strategy (
    CORBA::Object_ptr obj
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::SystemException))
{
  TAO::Collocation_Strategy strategy =
    TAO_ORB_Core::collocation_strategy (obj ACE_ENV_ARG_PARAMETER);
  ACE_CHECK_RETURN (TAO::TAO_CS_REMOTE_STRATEGY);
  
  return strategy;
}

void
POA_Event_Forwarder::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker::dispatch (
    CORBA::Object_ptr obj,
    CORBA::Object_out forward_obj,
    TAO::Argument ** args,
    int num_args,
    const char * op,
    size_t op_len,
    TAO::Collocation_Strategy strategy
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((CORBA::Exception))
{
  TAO_Object_Adapter::Servant_Upcall servant_upcall (
      obj->_stubobj ()->servant_orb_var ()->orb_core ()
    );
  
  TAO_Collocated_Skeleton collocated_skel;
  TAO_Abstract_ServantBase *servant = 0;
  
  if (strategy == TAO::TAO_CS_THRU_POA_STRATEGY)
    {
      servant_upcall.prepare_for_upcall (
          obj->_stubobj ()->object_key (),
          op,
          forward_obj
          ACE_ENV_ARG_PARAMETER
        );
      ACE_CHECK;
      
      servant_upcall.pre_invoke_collocated_request (
          ACE_ENV_SINGLE_ARG_PARAMETER
        );
      ACE_CHECK;
      
      servant = servant_upcall.servant ();
    }
  else
    {
      servant = obj->_servant ();
    }
  
  int status = servant->_find (op,
                               collocated_skel,
                               strategy,
                               op_len);
  
  if (status == -1)
    {
      ACE_THROW (CORBA::BAD_OPERATION ());
    }
  
  ACE_TRY
    {
      collocated_skel (servant,
                       args,
                       num_args
                       ACE_ENV_ARG_PARAMETER);
      ACE_TRY_CHECK;
    }
#if (TAO_HAS_MINIMUM_CORBA == 0)
  ACE_CATCH (PortableServer::ForwardRequest, forward_request)
    {
      forward_obj =
        CORBA::Object::_duplicate (forward_request.forward_reference.in ());
      return;
    }
#else
  ACE_CATCHANY
    {
      ACE_UNUSED_ARG (forward_obj);
      ACE_RE_THROW;
    }
#endif /* TAO_HAS_MINIMUM_CORBA */
  ACE_ENDTRY;
  ACE_CHECK;
}

//
//        End Strategized Proxy Broker Implementation
///////////////////////////////////////////////////////////////////////

// TAO_IDL - Generated from
// be/be_visitor_interface/interface_ss.cpp:648

TAO::Collocation_Proxy_Broker *
Event_Forwarder__TAO_ProxyPushSupplier_Proxy_Broker_Factory_function (CORBA::Object_ptr)
{
  return
    ::POA_Event_Forwarder::_TAO_ProxyPushSupplier_Strategized_Proxy_Broker::the_TAO_ProxyPushSupplier_Strategized_Proxy_Broker ();
}

int
Event_Forwarder__TAO_ProxyPushSupplier_Proxy_Broker_Factory_Initializer (size_t)
{
  Event_Forwarder__TAO_ProxyPushSupplier_Proxy_Broker_Factory_function_pointer = 
    Event_Forwarder__TAO_ProxyPushSupplier_Proxy_Broker_Factory_function;
  
  return 0;
}

static int
Event_Forwarder__TAO_ProxyPushSupplier_Proxy_Broker_Stub_Factory_Initializer_Scarecrow =
  Event_Forwarder__TAO_ProxyPushSupplier_Proxy_Broker_Factory_Initializer (
      reinterpret_cast<
          size_t> (
          Event_Forwarder__TAO_ProxyPushSupplier_Proxy_Broker_Factory_Initializer
        )
    );


///////////////////////////////////////////////////////////////////////
//                 ThruPOA Proxy  Implementation
//

// TAO_IDL - Generated from
// be/be_visitor_interface/thru_poa_proxy_impl_ss.cpp:37

POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl (void)
{}

// ThruPOA Implementation of the IDL interface methods

// TAO_IDL - Generated from 
// be/be_visitor_operation/thru_poa_proxy_impl_ss.cpp:52

void
POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::forward_structured (
    TAO_Abstract_ServantBase *servant,
    TAO::Argument ** args,
    int 
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  reinterpret_cast<
      POA_Event_Forwarder::ProxyPushSupplier_ptr> (
      servant->_downcast (
          "IDL:Event_Forwarder/ProxyPushSupplier:1.0"
        )
    )->forward_structured (
        ((TAO::Arg_Traits< ::CosNotification::StructuredEvent>::in_arg_val *) args[1])->arg ()
        ACE_ENV_ARG_PARAMETER
      );
  ACE_CHECK;
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/thru_poa_proxy_impl_ss.cpp:52

void
POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::forward_structured_no_filtering (
    TAO_Abstract_ServantBase *servant,
    TAO::Argument ** args,
    int 
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  reinterpret_cast<
      POA_Event_Forwarder::ProxyPushSupplier_ptr> (
      servant->_downcast (
          "IDL:Event_Forwarder/ProxyPushSupplier:1.0"
        )
    )->forward_structured_no_filtering (
        ((TAO::Arg_Traits< ::CosNotification::StructuredEvent>::in_arg_val *) args[1])->arg ()
        ACE_ENV_ARG_PARAMETER
      );
  ACE_CHECK;
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/thru_poa_proxy_impl_ss.cpp:52

void
POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::forward_any (
    TAO_Abstract_ServantBase *servant,
    TAO::Argument ** args,
    int 
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  reinterpret_cast<
      POA_Event_Forwarder::ProxyPushSupplier_ptr> (
      servant->_downcast (
          "IDL:Event_Forwarder/ProxyPushSupplier:1.0"
        )
    )->forward_any (
        ((TAO::Arg_Traits< CORBA::Any>::in_arg_val *) args[1])->arg ()
        ACE_ENV_ARG_PARAMETER
      );
  ACE_CHECK;
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/thru_poa_proxy_impl_ss.cpp:52

void
POA_Event_Forwarder::_TAO_ProxyPushSupplier_ThruPOA_Proxy_Impl::forward_any_no_filtering (
    TAO_Abstract_ServantBase *servant,
    TAO::Argument ** args,
    int 
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  reinterpret_cast<
      POA_Event_Forwarder::ProxyPushSupplier_ptr> (
      servant->_downcast (
          "IDL:Event_Forwarder/ProxyPushSupplier:1.0"
        )
    )->forward_any_no_filtering (
        ((TAO::Arg_Traits< CORBA::Any>::in_arg_val *) args[1])->arg ()
        ACE_ENV_ARG_PARAMETER
      );
  ACE_CHECK;
}

//
//           End ThruPOA Proxy Implementation
///////////////////////////////////////////////////////////////////////

// TAO_IDL - Generated from 
// be/be_visitor_interface/interface_ss.cpp:97

POA_Event_Forwarder::ProxyPushSupplier::ProxyPushSupplier (void)
{
  this->optable_ = &tao_Event_Forwarder_ProxyPushSupplier_optable;
}

POA_Event_Forwarder::ProxyPushSupplier::ProxyPushSupplier (const ProxyPushSupplier& rhs)
  : TAO_Abstract_ServantBase (rhs),
    TAO_ServantBase (rhs),
    ACE_NESTED_CLASS (POA_CosNotification, QoSAdmin) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyFilter, FilterAdmin) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyChannelAdmin, ProxySupplier) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyComm, NotifySubscribe) (rhs),
    ACE_NESTED_CLASS (POA_CosEventComm, PushSupplier) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyComm, PushSupplier) (rhs),
    ACE_NESTED_CLASS (POA_CosNotifyChannelAdmin, ProxyPushSupplier) (rhs)
{
}

POA_Event_Forwarder::ProxyPushSupplier::~ProxyPushSupplier (void)
{
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/operation_ss.cpp:98

void POA_Event_Forwarder::ProxyPushSupplier::forward_structured_skel (
    TAO_ServerRequest &_tao_server_request,
    void *_tao_servant,
    void *_tao_servant_upcall
    ACE_ENV_ARG_DECL
  )
{
    TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
POA_Event_Forwarder::ProxyPushSupplier *_tao_impl =
    static_cast<
        POA_Event_Forwarder::ProxyPushSupplier *> (
        _tao_servant
      );
  _tao_server_request.argument_flag (0);
  
  ::CosNotification::StructuredEvent event;
  
  if (!(
      (_tao_in >> event)
      ))
    {
      TAO_InputCDR::throw_skel_exception (errno ACE_ENV_ARG_PARAMETER);
      ACE_CHECK;
    }
  
#if (TAO_HAS_INTERCEPTORS == 1)
  TAO_Object_Adapter::Servant_Upcall *_tao_upcall =
    static_cast<
        TAO_Object_Adapter::Servant_Upcall *> (
        _tao_servant_upcall
      );
    
  TAO_ServerRequestInterceptor_Adapter _tao_vfr (
      _tao_server_request.orb_core ()->server_request_interceptors (),
      _tao_server_request.interceptor_count ()
    );
  
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured _tao_ri (
      _tao_server_request,
      _tao_upcall,
      _tao_impl,
      
      event
      ACE_ENV_ARG_PARAMETER
    );
  
  ACE_TRY
    {
      {
        TAO::PICurrent_Guard _tao_pi_guard (_tao_ri.server_request (),
                                            true  /* Copy TSC to RSC */);
        
        _tao_vfr.receive_request (&_tao_ri ACE_ENV_ARG_PARAMETER);
        ACE_TRY_CHECK;
        
        if (!_tao_vfr.location_forwarded ())
          {
#endif /* TAO_HAS_INTERCEPTORS */
            
              _tao_impl->forward_structured (
                  event
                  ACE_ENV_ARG_PARAMETER
                );
            TAO_INTERCEPTOR_CHECK;
#if (TAO_HAS_INTERCEPTORS == 1)
          }
      }
      
      if (!_tao_vfr.location_forwarded ())
        {
          _tao_ri.reply_status (PortableInterceptor::SUCCESSFUL);
          _tao_vfr.send_reply (&_tao_ri ACE_ENV_ARG_PARAMETER);
          ACE_TRY_CHECK;
        }
    }
  ACE_CATCHANY
    {
      _tao_ri.exception (&ACE_ANY_EXCEPTION);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION
          || _tao_status == PortableInterceptor::USER_EXCEPTION)
        {
          ACE_RE_THROW;
        }
    }
  
# if defined (ACE_HAS_EXCEPTIONS) \
  && defined (ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS)
  ACE_CATCHALL
    {
      CORBA::UNKNOWN ex;
      
      _tao_ri.exception (&ex);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION)
        ACE_TRY_THROW (ex);
    }
# endif  /* ACE_HAS_EXCEPTIONS && ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS */
  ACE_ENDTRY;
  ACE_CHECK;
#endif /* TAO_HAS_INTERCEPTORS */
  
  _tao_server_request.init_reply ();
  
  // In case _tao_servant_upcall is not used in this function
  ACE_UNUSED_ARG (_tao_servant_upcall);
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/operation_ss.cpp:98

void POA_Event_Forwarder::ProxyPushSupplier::forward_structured_no_filtering_skel (
    TAO_ServerRequest &_tao_server_request,
    void *_tao_servant,
    void *_tao_servant_upcall
    ACE_ENV_ARG_DECL
  )
{
    TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
POA_Event_Forwarder::ProxyPushSupplier *_tao_impl =
    static_cast<
        POA_Event_Forwarder::ProxyPushSupplier *> (
        _tao_servant
      );
  _tao_server_request.argument_flag (0);
  
  ::CosNotification::StructuredEvent event;
  
  if (!(
      (_tao_in >> event)
      ))
    {
      TAO_InputCDR::throw_skel_exception (errno ACE_ENV_ARG_PARAMETER);
      ACE_CHECK;
    }
  
#if (TAO_HAS_INTERCEPTORS == 1)
  TAO_Object_Adapter::Servant_Upcall *_tao_upcall =
    static_cast<
        TAO_Object_Adapter::Servant_Upcall *> (
        _tao_servant_upcall
      );
    
  TAO_ServerRequestInterceptor_Adapter _tao_vfr (
      _tao_server_request.orb_core ()->server_request_interceptors (),
      _tao_server_request.interceptor_count ()
    );
  
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_structured_no_filtering _tao_ri (
      _tao_server_request,
      _tao_upcall,
      _tao_impl,
      
      event
      ACE_ENV_ARG_PARAMETER
    );
  
  ACE_TRY
    {
      {
        TAO::PICurrent_Guard _tao_pi_guard (_tao_ri.server_request (),
                                            true  /* Copy TSC to RSC */);
        
        _tao_vfr.receive_request (&_tao_ri ACE_ENV_ARG_PARAMETER);
        ACE_TRY_CHECK;
        
        if (!_tao_vfr.location_forwarded ())
          {
#endif /* TAO_HAS_INTERCEPTORS */
            
              _tao_impl->forward_structured_no_filtering (
                  event
                  ACE_ENV_ARG_PARAMETER
                );
            TAO_INTERCEPTOR_CHECK;
#if (TAO_HAS_INTERCEPTORS == 1)
          }
      }
      
      if (!_tao_vfr.location_forwarded ())
        {
          _tao_ri.reply_status (PortableInterceptor::SUCCESSFUL);
          _tao_vfr.send_reply (&_tao_ri ACE_ENV_ARG_PARAMETER);
          ACE_TRY_CHECK;
        }
    }
  ACE_CATCHANY
    {
      _tao_ri.exception (&ACE_ANY_EXCEPTION);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION
          || _tao_status == PortableInterceptor::USER_EXCEPTION)
        {
          ACE_RE_THROW;
        }
    }
  
# if defined (ACE_HAS_EXCEPTIONS) \
  && defined (ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS)
  ACE_CATCHALL
    {
      CORBA::UNKNOWN ex;
      
      _tao_ri.exception (&ex);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION)
        ACE_TRY_THROW (ex);
    }
# endif  /* ACE_HAS_EXCEPTIONS && ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS */
  ACE_ENDTRY;
  ACE_CHECK;
#endif /* TAO_HAS_INTERCEPTORS */
  
  _tao_server_request.init_reply ();
  
  // In case _tao_servant_upcall is not used in this function
  ACE_UNUSED_ARG (_tao_servant_upcall);
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/operation_ss.cpp:98

void POA_Event_Forwarder::ProxyPushSupplier::forward_any_skel (
    TAO_ServerRequest &_tao_server_request,
    void *_tao_servant,
    void *_tao_servant_upcall
    ACE_ENV_ARG_DECL
  )
{
    TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
POA_Event_Forwarder::ProxyPushSupplier *_tao_impl =
    static_cast<
        POA_Event_Forwarder::ProxyPushSupplier *> (
        _tao_servant
      );
  _tao_server_request.argument_flag (0);
  
  ::CORBA::Any event;
  
  if (!(
      (_tao_in >> event)
      ))
    {
      TAO_InputCDR::throw_skel_exception (errno ACE_ENV_ARG_PARAMETER);
      ACE_CHECK;
    }
  
#if (TAO_HAS_INTERCEPTORS == 1)
  TAO_Object_Adapter::Servant_Upcall *_tao_upcall =
    static_cast<
        TAO_Object_Adapter::Servant_Upcall *> (
        _tao_servant_upcall
      );
    
  TAO_ServerRequestInterceptor_Adapter _tao_vfr (
      _tao_server_request.orb_core ()->server_request_interceptors (),
      _tao_server_request.interceptor_count ()
    );
  
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any _tao_ri (
      _tao_server_request,
      _tao_upcall,
      _tao_impl,
      
      event
      ACE_ENV_ARG_PARAMETER
    );
  
  ACE_TRY
    {
      {
        TAO::PICurrent_Guard _tao_pi_guard (_tao_ri.server_request (),
                                            true  /* Copy TSC to RSC */);
        
        _tao_vfr.receive_request (&_tao_ri ACE_ENV_ARG_PARAMETER);
        ACE_TRY_CHECK;
        
        if (!_tao_vfr.location_forwarded ())
          {
#endif /* TAO_HAS_INTERCEPTORS */
            
              _tao_impl->forward_any (
                  event
                  ACE_ENV_ARG_PARAMETER
                );
            TAO_INTERCEPTOR_CHECK;
#if (TAO_HAS_INTERCEPTORS == 1)
          }
      }
      
      if (!_tao_vfr.location_forwarded ())
        {
          _tao_ri.reply_status (PortableInterceptor::SUCCESSFUL);
          _tao_vfr.send_reply (&_tao_ri ACE_ENV_ARG_PARAMETER);
          ACE_TRY_CHECK;
        }
    }
  ACE_CATCHANY
    {
      _tao_ri.exception (&ACE_ANY_EXCEPTION);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION
          || _tao_status == PortableInterceptor::USER_EXCEPTION)
        {
          ACE_RE_THROW;
        }
    }
  
# if defined (ACE_HAS_EXCEPTIONS) \
  && defined (ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS)
  ACE_CATCHALL
    {
      CORBA::UNKNOWN ex;
      
      _tao_ri.exception (&ex);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION)
        ACE_TRY_THROW (ex);
    }
# endif  /* ACE_HAS_EXCEPTIONS && ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS */
  ACE_ENDTRY;
  ACE_CHECK;
#endif /* TAO_HAS_INTERCEPTORS */
  
  _tao_server_request.init_reply ();
  
  // In case _tao_servant_upcall is not used in this function
  ACE_UNUSED_ARG (_tao_servant_upcall);
}

// TAO_IDL - Generated from 
// be/be_visitor_operation/operation_ss.cpp:98

void POA_Event_Forwarder::ProxyPushSupplier::forward_any_no_filtering_skel (
    TAO_ServerRequest &_tao_server_request,
    void *_tao_servant,
    void *_tao_servant_upcall
    ACE_ENV_ARG_DECL
  )
{
    TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
POA_Event_Forwarder::ProxyPushSupplier *_tao_impl =
    static_cast<
        POA_Event_Forwarder::ProxyPushSupplier *> (
        _tao_servant
      );
  _tao_server_request.argument_flag (0);
  
  ::CORBA::Any event;
  
  if (!(
      (_tao_in >> event)
      ))
    {
      TAO_InputCDR::throw_skel_exception (errno ACE_ENV_ARG_PARAMETER);
      ACE_CHECK;
    }
  
#if (TAO_HAS_INTERCEPTORS == 1)
  TAO_Object_Adapter::Servant_Upcall *_tao_upcall =
    static_cast<
        TAO_Object_Adapter::Servant_Upcall *> (
        _tao_servant_upcall
      );
    
  TAO_ServerRequestInterceptor_Adapter _tao_vfr (
      _tao_server_request.orb_core ()->server_request_interceptors (),
      _tao_server_request.interceptor_count ()
    );
  
  TAO_ServerRequestInfo_Event_Forwarder_ProxyPushSupplier_forward_any_no_filtering _tao_ri (
      _tao_server_request,
      _tao_upcall,
      _tao_impl,
      
      event
      ACE_ENV_ARG_PARAMETER
    );
  
  ACE_TRY
    {
      {
        TAO::PICurrent_Guard _tao_pi_guard (_tao_ri.server_request (),
                                            true  /* Copy TSC to RSC */);
        
        _tao_vfr.receive_request (&_tao_ri ACE_ENV_ARG_PARAMETER);
        ACE_TRY_CHECK;
        
        if (!_tao_vfr.location_forwarded ())
          {
#endif /* TAO_HAS_INTERCEPTORS */
            
              _tao_impl->forward_any_no_filtering (
                  event
                  ACE_ENV_ARG_PARAMETER
                );
            TAO_INTERCEPTOR_CHECK;
#if (TAO_HAS_INTERCEPTORS == 1)
          }
      }
      
      if (!_tao_vfr.location_forwarded ())
        {
          _tao_ri.reply_status (PortableInterceptor::SUCCESSFUL);
          _tao_vfr.send_reply (&_tao_ri ACE_ENV_ARG_PARAMETER);
          ACE_TRY_CHECK;
        }
    }
  ACE_CATCHANY
    {
      _tao_ri.exception (&ACE_ANY_EXCEPTION);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION
          || _tao_status == PortableInterceptor::USER_EXCEPTION)
        {
          ACE_RE_THROW;
        }
    }
  
# if defined (ACE_HAS_EXCEPTIONS) \
  && defined (ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS)
  ACE_CATCHALL
    {
      CORBA::UNKNOWN ex;
      
      _tao_ri.exception (&ex);
      _tao_vfr.send_exception (
          &_tao_ri
          ACE_ENV_ARG_PARAMETER
        );
      ACE_TRY_CHECK;
      
      PortableInterceptor::ReplyStatus _tao_status =
        _tao_ri.reply_status (ACE_ENV_SINGLE_ARG_PARAMETER);
      ACE_TRY_CHECK;
      
      if (_tao_status == PortableInterceptor::SYSTEM_EXCEPTION)
        ACE_TRY_THROW (ex);
    }
# endif  /* ACE_HAS_EXCEPTIONS && ACE_HAS_BROKEN_UNEXPECTED_EXCEPTIONS */
  ACE_ENDTRY;
  ACE_CHECK;
#endif /* TAO_HAS_INTERCEPTORS */
  
  _tao_server_request.init_reply ();
  
  // In case _tao_servant_upcall is not used in this function
  ACE_UNUSED_ARG (_tao_servant_upcall);
}

// TAO_IDL - Generated from 
// be/be_visitor_interface/interface_ss.cpp:162

void POA_Event_Forwarder::ProxyPushSupplier::_is_a_skel (
    TAO_ServerRequest &_tao_server_request, 
    void * _tao_servant,
    void * /* Servant_Upcall */
    ACE_ENV_ARG_DECL
  )
{
  TAO_InputCDR &_tao_in = _tao_server_request.incoming ();
  
  POA_Event_Forwarder::ProxyPushSupplier *_tao_impl =
    (POA_Event_Forwarder::ProxyPushSupplier *) _tao_servant;
  
  CORBA::Boolean _tao_retval = 0;
  CORBA::String_var value;
  
  if (!(_tao_in >> value.out ()))
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
  
  _tao_retval = _tao_impl->_is_a (value.in () ACE_ENV_ARG_PARAMETER);
  ACE_CHECK;
  
  _tao_server_request.init_reply ();
  TAO_OutputCDR &_tao_out = _tao_server_request.outgoing ();
  
  if (!(_tao_out << CORBA::Any::from_boolean (_tao_retval)))
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
}

void POA_Event_Forwarder::ProxyPushSupplier::_non_existent_skel (
    TAO_ServerRequest &_tao_server_request, 
    void * _tao_servant,
    void * /* Servant_Upcall */
    ACE_ENV_ARG_DECL
  )
{
  POA_Event_Forwarder::ProxyPushSupplier *_tao_impl =
    (POA_Event_Forwarder::ProxyPushSupplier *) _tao_servant;
  
  CORBA::Boolean _tao_retval =
    _tao_impl->_non_existent (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK;
  
  _tao_server_request.init_reply ();
  TAO_OutputCDR &_tao_out = _tao_server_request.outgoing ();
  
  if (!(_tao_out << CORBA::Any::from_boolean (_tao_retval)))
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
}

void POA_Event_Forwarder::ProxyPushSupplier::_interface_skel (
    TAO_ServerRequest &_tao_server_request, 
    void * _tao_servant,
    void * /* Servant_Upcall */
    ACE_ENV_ARG_DECL
  )
{
  TAO_IFR_Client_Adapter *_tao_adapter =
    ACE_Dynamic_Service<TAO_IFR_Client_Adapter>::instance (
        TAO_ORB_Core::ifr_client_adapter_name ()
      );
    
  if (_tao_adapter == 0)
    {
      ACE_THROW (CORBA::INTF_REPOS ());
    }
  
  POA_Event_Forwarder::ProxyPushSupplier *_tao_impl =
    (POA_Event_Forwarder::ProxyPushSupplier *) _tao_servant;
  
  CORBA::InterfaceDef_ptr _tao_retval = 
    _tao_impl->_get_interface (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK;
  
  _tao_server_request.init_reply ();
  TAO_OutputCDR &_tao_out = _tao_server_request.outgoing ();
  
  CORBA::Boolean _tao_result =
    _tao_adapter->interfacedef_cdr_insert (
        _tao_out,
        _tao_retval
      );
  
  _tao_adapter->dispose (_tao_retval);
  
  if (_tao_result == 0)
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
}

void POA_Event_Forwarder::ProxyPushSupplier::_component_skel (
    TAO_ServerRequest &_tao_server_request, 
    void * _tao_object_reference,
    void * /* Servant_Upcall */
    ACE_ENV_ARG_DECL
  )
{
  POA_Event_Forwarder::ProxyPushSupplier *_tao_impl =
    (POA_Event_Forwarder::ProxyPushSupplier *) _tao_object_reference;
  
  CORBA::Object_var _tao_retval =
    _tao_impl->_get_component (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK;
  
  _tao_server_request.init_reply ();
  TAO_OutputCDR &_tao_out = _tao_server_request.outgoing ();
  
  if (!(_tao_out << _tao_retval.in ()))
    {
      ACE_THROW (CORBA::MARSHAL ());
    }
}

CORBA::Boolean POA_Event_Forwarder::ProxyPushSupplier::_is_a (
    const char* value
    ACE_ENV_ARG_DECL_NOT_USED
  )
{
  if (
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotification/QoSAdmin:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyFilter/FilterAdmin:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyChannelAdmin/ProxySupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyComm/NotifySubscribe:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosEventComm/PushSupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyComm/PushSupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CosNotifyChannelAdmin/ProxyPushSupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:Event_Forwarder/ProxyPushSupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CORBA/Object:1.0"
        )
     )
    {
      return 1;
    }
  else
    {
      return 0;
    }
}

void* POA_Event_Forwarder::ProxyPushSupplier::_downcast (
    const char* logical_type_id
  )
{
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotification/QoSAdmin:1.0") == 0)
    {
      return static_cast<POA_CosNotification::QoSAdmin_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyFilter/FilterAdmin:1.0") == 0)
    {
      return static_cast<POA_CosNotifyFilter::FilterAdmin_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyChannelAdmin/ProxySupplier:1.0") == 0)
    {
      return static_cast<POA_CosNotifyChannelAdmin::ProxySupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyComm/NotifySubscribe:1.0") == 0)
    {
      return static_cast<POA_CosNotifyComm::NotifySubscribe_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosEventComm/PushSupplier:1.0") == 0)
    {
      return static_cast<POA_CosEventComm::PushSupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyComm/PushSupplier:1.0") == 0)
    {
      return static_cast<POA_CosNotifyComm::PushSupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CosNotifyChannelAdmin/ProxyPushSupplier:1.0") == 0)
    {
      return static_cast<POA_CosNotifyChannelAdmin::ProxyPushSupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:Event_Forwarder/ProxyPushSupplier:1.0") == 0)
    {
      return static_cast<POA_Event_Forwarder::ProxyPushSupplier_ptr> (this);
    }
  
  if (ACE_OS::strcmp (logical_type_id,
                      "IDL:omg.org/CORBA/Object:1.0") == 0)
    {
      return static_cast<PortableServer::Servant> (this);
    }
  
  return 0;
}

const char* POA_Event_Forwarder::ProxyPushSupplier::_interface_repository_id (void) const
{
  return "IDL:Event_Forwarder/ProxyPushSupplier:1.0";
}

// TAO_IDL - Generated from
// be/be_visitor_interface/interface_ss.cpp:584

void POA_Event_Forwarder::ProxyPushSupplier::_dispatch (
    TAO_ServerRequest &req,
    void *servant_upcall
    ACE_ENV_ARG_DECL
  )
{
  this->synchronous_upcall_dispatch (req,
                                     servant_upcall,
                                     this
                                     ACE_ENV_ARG_PARAMETER);
}

// TAO_IDL - Generated from
// be/be_visitor_interface/interface_ss.cpp:526

Event_Forwarder::ProxyPushSupplier *
POA_Event_Forwarder::ProxyPushSupplier::_this (ACE_ENV_SINGLE_ARG_DECL)
{
  TAO_Stub *stub = this->_create_stub (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK_RETURN (0);
  
  TAO_Stub_Auto_Ptr safe_stub (stub);
  CORBA::Object_ptr tmp = CORBA::Object::_nil ();
  
  if (stub->servant_orb_var ()->orb_core ()->optimize_collocation_objects ())
    {
      ACE_NEW_RETURN (
          tmp,
          CORBA::Object (stub, 1, this),
          0
        );
    }
  else
    {
      ACE_NEW_RETURN (
          tmp,
          CORBA::Object (stub, 0, this),
          0
        );
    }
  
  CORBA::Object_var obj = tmp;
  (void) safe_stub.release ();
  
  typedef ::Event_Forwarder::ProxyPushSupplier STUB_SCOPED_NAME;
  return
    TAO::Narrow_Utils<STUB_SCOPED_NAME>::unchecked_narrow (
        obj.in (),
        Event_Forwarder__TAO_ProxyPushSupplier_Proxy_Broker_Factory_function_pointer
      );
}

#endif /* ifndef */
