// -*- 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:303


#include "RtecEventCommC.h"
#include "tao/CDR.h"
#include "tao/Exception_Data.h"
#include "tao/Invocation_Adapter.h"
#include "tao/Object_T.h"
#include "tao/Typecode.h"
#include "tao/Any_Impl_T.h"
#include "tao/Any_Dual_Impl_T.h"
#include "tao/Basic_Arguments.h"
#include "tao/Var_Size_Argument_T.h"
#include "ace/OS_NS_string.h"

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

#if !defined (__ACE_INLINE__)
#include "RtecEventCommC.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:379

#if !defined (_RTECEVENTCOMM_EVENTSET__ARG_TRAITS_CS_)
#define _RTECEVENTCOMM_EVENTSET__ARG_TRAITS_CS_
  
  ACE_TEMPLATE_SPECIALIZATION
  class TAO_RTEvent_Export Arg_Traits<RtecEventComm::EventSet>
    : public
        Var_Size_Arg_Traits_T<
            RtecEventComm::EventSet,
            RtecEventComm::EventSet_var,
            RtecEventComm::EventSet_out
          >
  {
  };

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


// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_EventData[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  32,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f4576), 
  ACE_NTOHL (0x656e7444), 
  ACE_NTOHL (0x6174613a), 
  ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventData:1.0
    10,
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74446174), 
  ACE_NTOHL (0x61000000),  // name = EventData
    CORBA::tk_struct, // typecode kind
  184, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    22,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74446174), 
    ACE_NTOHL (0x613a312e), 
    ACE_NTOHL (0x30000000),  // repository ID = IDL:RtecEventData:1.0
        14,
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74446174), 
    ACE_NTOHL (0x61000000),  // name = RtecEventData
    3, // member count
        5,
    ACE_NTOHL (0x70616431), 
    ACE_NTOHL (0x0),  // name = pad1
        CORBA::tk_long,

    8,
    ACE_NTOHL (0x7061796c), 
    ACE_NTOHL (0x6f616400),  // name = payload
        CORBA::tk_alias, // typecode kind for typedefs
    72, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      21,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74506179), 
      ACE_NTOHL (0x6c6f6164), 
      ACE_NTOHL (0x3a312e30), 
      ACE_NTOHL (0x0),  // repository ID = IDL:EventPayload:1.0
            13,
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74506179), 
      ACE_NTOHL (0x6c6f6164), 
      ACE_NTOHL (0x0),  // name = EventPayload
            CORBA::tk_sequence, // typecode kind
      12, // encapsulation length
        TAO_ENCAP_BYTE_ORDER, // byte order
        CORBA::tk_octet,

        0U,


    10,
    ACE_NTOHL (0x616e795f), 
    ACE_NTOHL (0x76616c75), 
    ACE_NTOHL (0x65000000),  // name = any_value
        CORBA::tk_any,


};

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_EventData (
    CORBA::tk_alias,
    sizeof (_oc_RtecEventComm_EventData),
    (char *) &_oc_RtecEventComm_EventData,
    0,
    sizeof (RtecEventComm::EventData)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_EventData =
    &_tc_TAO_tc_RtecEventComm_EventData;
}

// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_Time[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  27,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f5469), 
  ACE_NTOHL (0x6d653a31), 
  ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
    5,
  ACE_NTOHL (0x54696d65), 
  ACE_NTOHL (0x0),  // name = Time
    CORBA::tk_alias, // typecode kind for typedefs
  56, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    31,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x6f6d672e), 
    ACE_NTOHL (0x6f72672f), 
    ACE_NTOHL (0x54696d65), 
    ACE_NTOHL (0x42617365), 
    ACE_NTOHL (0x2f54696d), 
    ACE_NTOHL (0x65543a31), 
    ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
        6,
    ACE_NTOHL (0x54696d65), 
    ACE_NTOHL (0x54000000),  // name = TimeT
        CORBA::tk_ulonglong,


};

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_Time (
    CORBA::tk_alias,
    sizeof (_oc_RtecEventComm_Time),
    (char *) &_oc_RtecEventComm_Time,
    0,
    sizeof (RtecEventComm::Time)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_Time =
    &_tc_TAO_tc_RtecEventComm_Time;
}

// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_EventSourceID[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  36,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f4576), 
  ACE_NTOHL (0x656e7453), 
  ACE_NTOHL (0x6f757263), 
  ACE_NTOHL (0x6549443a), 
  ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventSourceID:1.0
    14,
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74536f75), 
  ACE_NTOHL (0x72636549), 
  ACE_NTOHL (0x44000000),  // name = EventSourceID
    CORBA::tk_long,

};

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_EventSourceID (
    CORBA::tk_alias,
    sizeof (_oc_RtecEventComm_EventSourceID),
    (char *) &_oc_RtecEventComm_EventSourceID,
    0,
    sizeof (RtecEventComm::EventSourceID)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_EventSourceID =
    &_tc_TAO_tc_RtecEventComm_EventSourceID;
}

// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_EventType[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  32,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f4576), 
  ACE_NTOHL (0x656e7454), 
  ACE_NTOHL (0x7970653a), 
  ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventType:1.0
    10,
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74547970), 
  ACE_NTOHL (0x65000000),  // name = EventType
    CORBA::tk_long,

};

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_EventType (
    CORBA::tk_alias,
    sizeof (_oc_RtecEventComm_EventType),
    (char *) &_oc_RtecEventComm_EventType,
    0,
    sizeof (RtecEventComm::EventType)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_EventType =
    &_tc_TAO_tc_RtecEventComm_EventType;
}

// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_EventHeader[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  34,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f4576), 
  ACE_NTOHL (0x656e7448), 
  ACE_NTOHL (0x65616465), 
  ACE_NTOHL (0x723a312e), 
  ACE_NTOHL (0x30000000),  // repository ID = IDL:RtecEventComm/EventHeader:1.0
    12,
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74486561), 
  ACE_NTOHL (0x64657200),  // name = EventHeader
  6, // member count
    5,
  ACE_NTOHL (0x74797065), 
  ACE_NTOHL (0x0),  // name = type
    CORBA::tk_alias, // typecode kind for typedefs
  60, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    32,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74436f6d), 
    ACE_NTOHL (0x6d2f4576), 
    ACE_NTOHL (0x656e7454), 
    ACE_NTOHL (0x7970653a), 
    ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventType:1.0
        10,
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74547970), 
    ACE_NTOHL (0x65000000),  // name = EventType
        CORBA::tk_long,


  7,
  ACE_NTOHL (0x736f7572), 
  ACE_NTOHL (0x63650000),  // name = source
    CORBA::tk_alias, // typecode kind for typedefs
  68, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    36,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74436f6d), 
    ACE_NTOHL (0x6d2f4576), 
    ACE_NTOHL (0x656e7453), 
    ACE_NTOHL (0x6f757263), 
    ACE_NTOHL (0x6549443a), 
    ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventSourceID:1.0
        14,
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74536f75), 
    ACE_NTOHL (0x72636549), 
    ACE_NTOHL (0x44000000),  // name = EventSourceID
        CORBA::tk_long,


  4,
  ACE_NTOHL (0x74746c00),  // name = ttl
    CORBA::tk_long,

  14,
  ACE_NTOHL (0x63726561), 
  ACE_NTOHL (0x74696f6e), 
  ACE_NTOHL (0x5f74696d), 
  ACE_NTOHL (0x65000000),  // name = creation_time
    CORBA::tk_alias, // typecode kind for typedefs
  112, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    27,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74436f6d), 
    ACE_NTOHL (0x6d2f5469), 
    ACE_NTOHL (0x6d653a31), 
    ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
        5,
    ACE_NTOHL (0x54696d65), 
    ACE_NTOHL (0x0),  // name = Time
        CORBA::tk_alias, // typecode kind for typedefs
    56, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      31,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x6f6d672e), 
      ACE_NTOHL (0x6f72672f), 
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x42617365), 
      ACE_NTOHL (0x2f54696d), 
      ACE_NTOHL (0x65543a31), 
      ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
            6,
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x54000000),  // name = TimeT
            CORBA::tk_ulonglong,



  13,
  ACE_NTOHL (0x65635f72), 
  ACE_NTOHL (0x6563765f), 
  ACE_NTOHL (0x74696d65), 
  ACE_NTOHL (0x0),  // name = ec_recv_time
    CORBA::tk_alias, // typecode kind for typedefs
  112, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    27,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74436f6d), 
    ACE_NTOHL (0x6d2f5469), 
    ACE_NTOHL (0x6d653a31), 
    ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
        5,
    ACE_NTOHL (0x54696d65), 
    ACE_NTOHL (0x0),  // name = Time
        CORBA::tk_alias, // typecode kind for typedefs
    56, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      31,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x6f6d672e), 
      ACE_NTOHL (0x6f72672f), 
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x42617365), 
      ACE_NTOHL (0x2f54696d), 
      ACE_NTOHL (0x65543a31), 
      ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
            6,
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x54000000),  // name = TimeT
            CORBA::tk_ulonglong,



  13,
  ACE_NTOHL (0x65635f73), 
  ACE_NTOHL (0x656e645f), 
  ACE_NTOHL (0x74696d65), 
  ACE_NTOHL (0x0),  // name = ec_send_time
    CORBA::tk_alias, // typecode kind for typedefs
  112, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    27,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74436f6d), 
    ACE_NTOHL (0x6d2f5469), 
    ACE_NTOHL (0x6d653a31), 
    ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
        5,
    ACE_NTOHL (0x54696d65), 
    ACE_NTOHL (0x0),  // name = Time
        CORBA::tk_alias, // typecode kind for typedefs
    56, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      31,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x6f6d672e), 
      ACE_NTOHL (0x6f72672f), 
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x42617365), 
      ACE_NTOHL (0x2f54696d), 
      ACE_NTOHL (0x65543a31), 
      ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
            6,
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x54000000),  // name = TimeT
            CORBA::tk_ulonglong,



};

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_EventHeader (
    CORBA::tk_struct,
    sizeof (_oc_RtecEventComm_EventHeader),
    (char *) &_oc_RtecEventComm_EventHeader,
    0,
    sizeof (RtecEventComm::EventHeader)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_EventHeader =
    &_tc_TAO_tc_RtecEventComm_EventHeader;
}

// TAO_IDL - Generated from 
// be/be_visitor_structure/structure_cs.cpp:66

void 
RtecEventComm::EventHeader::_tao_any_destructor (
    void *_tao_void_pointer
  )
{
  EventHeader *_tao_tmp_pointer =
    static_cast<EventHeader *> (_tao_void_pointer);
  delete _tao_tmp_pointer;
}

// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_Event[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  28,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f4576), 
  ACE_NTOHL (0x656e743a), 
  ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/Event:1.0
    6,
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74000000),  // name = Event
  2, // member count
    7,
  ACE_NTOHL (0x68656164), 
  ACE_NTOHL (0x65720000),  // name = header
    CORBA::tk_struct, // typecode kind
  664, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    34,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74436f6d), 
    ACE_NTOHL (0x6d2f4576), 
    ACE_NTOHL (0x656e7448), 
    ACE_NTOHL (0x65616465), 
    ACE_NTOHL (0x723a312e), 
    ACE_NTOHL (0x30000000),  // repository ID = IDL:RtecEventComm/EventHeader:1.0
        12,
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74486561), 
    ACE_NTOHL (0x64657200),  // name = EventHeader
    6, // member count
        5,
    ACE_NTOHL (0x74797065), 
    ACE_NTOHL (0x0),  // name = type
        CORBA::tk_alias, // typecode kind for typedefs
    60, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      32,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x52746563), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74436f6d), 
      ACE_NTOHL (0x6d2f4576), 
      ACE_NTOHL (0x656e7454), 
      ACE_NTOHL (0x7970653a), 
      ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventType:1.0
            10,
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74547970), 
      ACE_NTOHL (0x65000000),  // name = EventType
            CORBA::tk_long,


    7,
    ACE_NTOHL (0x736f7572), 
    ACE_NTOHL (0x63650000),  // name = source
        CORBA::tk_alias, // typecode kind for typedefs
    68, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      36,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x52746563), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74436f6d), 
      ACE_NTOHL (0x6d2f4576), 
      ACE_NTOHL (0x656e7453), 
      ACE_NTOHL (0x6f757263), 
      ACE_NTOHL (0x6549443a), 
      ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventSourceID:1.0
            14,
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74536f75), 
      ACE_NTOHL (0x72636549), 
      ACE_NTOHL (0x44000000),  // name = EventSourceID
            CORBA::tk_long,


    4,
    ACE_NTOHL (0x74746c00),  // name = ttl
        CORBA::tk_long,

    14,
    ACE_NTOHL (0x63726561), 
    ACE_NTOHL (0x74696f6e), 
    ACE_NTOHL (0x5f74696d), 
    ACE_NTOHL (0x65000000),  // name = creation_time
        CORBA::tk_alias, // typecode kind for typedefs
    112, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      27,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x52746563), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74436f6d), 
      ACE_NTOHL (0x6d2f5469), 
      ACE_NTOHL (0x6d653a31), 
      ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
            5,
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x0),  // name = Time
            CORBA::tk_alias, // typecode kind for typedefs
      56, // encapsulation length
        TAO_ENCAP_BYTE_ORDER, // byte order
        31,
        ACE_NTOHL (0x49444c3a), 
        ACE_NTOHL (0x6f6d672e), 
        ACE_NTOHL (0x6f72672f), 
        ACE_NTOHL (0x54696d65), 
        ACE_NTOHL (0x42617365), 
        ACE_NTOHL (0x2f54696d), 
        ACE_NTOHL (0x65543a31), 
        ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
                6,
        ACE_NTOHL (0x54696d65), 
        ACE_NTOHL (0x54000000),  // name = TimeT
                CORBA::tk_ulonglong,



    13,
    ACE_NTOHL (0x65635f72), 
    ACE_NTOHL (0x6563765f), 
    ACE_NTOHL (0x74696d65), 
    ACE_NTOHL (0x0),  // name = ec_recv_time
        CORBA::tk_alias, // typecode kind for typedefs
    112, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      27,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x52746563), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74436f6d), 
      ACE_NTOHL (0x6d2f5469), 
      ACE_NTOHL (0x6d653a31), 
      ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
            5,
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x0),  // name = Time
            CORBA::tk_alias, // typecode kind for typedefs
      56, // encapsulation length
        TAO_ENCAP_BYTE_ORDER, // byte order
        31,
        ACE_NTOHL (0x49444c3a), 
        ACE_NTOHL (0x6f6d672e), 
        ACE_NTOHL (0x6f72672f), 
        ACE_NTOHL (0x54696d65), 
        ACE_NTOHL (0x42617365), 
        ACE_NTOHL (0x2f54696d), 
        ACE_NTOHL (0x65543a31), 
        ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
                6,
        ACE_NTOHL (0x54696d65), 
        ACE_NTOHL (0x54000000),  // name = TimeT
                CORBA::tk_ulonglong,



    13,
    ACE_NTOHL (0x65635f73), 
    ACE_NTOHL (0x656e645f), 
    ACE_NTOHL (0x74696d65), 
    ACE_NTOHL (0x0),  // name = ec_send_time
        CORBA::tk_alias, // typecode kind for typedefs
    112, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      27,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x52746563), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74436f6d), 
      ACE_NTOHL (0x6d2f5469), 
      ACE_NTOHL (0x6d653a31), 
      ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
            5,
      ACE_NTOHL (0x54696d65), 
      ACE_NTOHL (0x0),  // name = Time
            CORBA::tk_alias, // typecode kind for typedefs
      56, // encapsulation length
        TAO_ENCAP_BYTE_ORDER, // byte order
        31,
        ACE_NTOHL (0x49444c3a), 
        ACE_NTOHL (0x6f6d672e), 
        ACE_NTOHL (0x6f72672f), 
        ACE_NTOHL (0x54696d65), 
        ACE_NTOHL (0x42617365), 
        ACE_NTOHL (0x2f54696d), 
        ACE_NTOHL (0x65543a31), 
        ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
                6,
        ACE_NTOHL (0x54696d65), 
        ACE_NTOHL (0x54000000),  // name = TimeT
                CORBA::tk_ulonglong,




  5,
  ACE_NTOHL (0x64617461), 
  ACE_NTOHL (0x0),  // name = data
    CORBA::tk_alias, // typecode kind for typedefs
  248, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    32,
    ACE_NTOHL (0x49444c3a), 
    ACE_NTOHL (0x52746563), 
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74436f6d), 
    ACE_NTOHL (0x6d2f4576), 
    ACE_NTOHL (0x656e7444), 
    ACE_NTOHL (0x6174613a), 
    ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventData:1.0
        10,
    ACE_NTOHL (0x4576656e), 
    ACE_NTOHL (0x74446174), 
    ACE_NTOHL (0x61000000),  // name = EventData
        CORBA::tk_struct, // typecode kind
    184, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      22,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x52746563), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74446174), 
      ACE_NTOHL (0x613a312e), 
      ACE_NTOHL (0x30000000),  // repository ID = IDL:RtecEventData:1.0
            14,
      ACE_NTOHL (0x52746563), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74446174), 
      ACE_NTOHL (0x61000000),  // name = RtecEventData
      3, // member count
            5,
      ACE_NTOHL (0x70616431), 
      ACE_NTOHL (0x0),  // name = pad1
            CORBA::tk_long,

      8,
      ACE_NTOHL (0x7061796c), 
      ACE_NTOHL (0x6f616400),  // name = payload
            CORBA::tk_alias, // typecode kind for typedefs
      72, // encapsulation length
        TAO_ENCAP_BYTE_ORDER, // byte order
        21,
        ACE_NTOHL (0x49444c3a), 
        ACE_NTOHL (0x4576656e), 
        ACE_NTOHL (0x74506179), 
        ACE_NTOHL (0x6c6f6164), 
        ACE_NTOHL (0x3a312e30), 
        ACE_NTOHL (0x0),  // repository ID = IDL:EventPayload:1.0
                13,
        ACE_NTOHL (0x4576656e), 
        ACE_NTOHL (0x74506179), 
        ACE_NTOHL (0x6c6f6164), 
        ACE_NTOHL (0x0),  // name = EventPayload
                CORBA::tk_sequence, // typecode kind
        12, // encapsulation length
          TAO_ENCAP_BYTE_ORDER, // byte order
          CORBA::tk_octet,

          0U,


      10,
      ACE_NTOHL (0x616e795f), 
      ACE_NTOHL (0x76616c75), 
      ACE_NTOHL (0x65000000),  // name = any_value
            CORBA::tk_any,



};

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_Event (
    CORBA::tk_struct,
    sizeof (_oc_RtecEventComm_Event),
    (char *) &_oc_RtecEventComm_Event,
    0,
    sizeof (RtecEventComm::Event)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_Event =
    &_tc_TAO_tc_RtecEventComm_Event;
}

// TAO_IDL - Generated from 
// be/be_visitor_structure/structure_cs.cpp:66

void 
RtecEventComm::Event::_tao_any_destructor (
    void *_tao_void_pointer
  )
{
  Event *_tao_tmp_pointer =
    static_cast<Event *> (_tao_void_pointer);
  delete _tao_tmp_pointer;
}

// TAO_IDL - Generated from 
// be/be_visitor_sequence/sequence_cs.cpp:65

#if !defined (_RTECEVENTCOMM_EVENTSET_CS_)
#define _RTECEVENTCOMM_EVENTSET_CS_

RtecEventComm::EventSet::EventSet (void)
{}

RtecEventComm::EventSet::EventSet (
    CORBA::ULong max
  )
  : TAO_Unbounded_Sequence<
        RtecEventComm::Event
      >
    (max)
{}

RtecEventComm::EventSet::EventSet (
    CORBA::ULong max,
    CORBA::ULong length,
    RtecEventComm::Event * buffer,
    CORBA::Boolean release
  )
  : TAO_Unbounded_Sequence<
        RtecEventComm::Event
      >
    (max, length, buffer, release)
{}

RtecEventComm::EventSet::EventSet (
    const EventSet &seq
  )
  : TAO_Unbounded_Sequence<
        RtecEventComm::Event
      >
    (seq)
{}

RtecEventComm::EventSet::~EventSet (void)
{}

void RtecEventComm::EventSet::_tao_any_destructor (
    void * _tao_void_pointer
  )
{
  EventSet * _tao_tmp_pointer =
    static_cast<EventSet *> (_tao_void_pointer);
  delete _tao_tmp_pointer;
}

#endif /* end #if !defined */

// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_EventSet[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  31,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f4576), 
  ACE_NTOHL (0x656e7453), 
  ACE_NTOHL (0x65743a31), 
  ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/EventSet:1.0
    9,
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74536574), 
  ACE_NTOHL (0x0),  // name = EventSet
    CORBA::tk_sequence, // typecode kind
  1020, // encapsulation length
    TAO_ENCAP_BYTE_ORDER, // byte order
    CORBA::tk_struct, // typecode kind
    1004, // encapsulation length
      TAO_ENCAP_BYTE_ORDER, // byte order
      28,
      ACE_NTOHL (0x49444c3a), 
      ACE_NTOHL (0x52746563), 
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74436f6d), 
      ACE_NTOHL (0x6d2f4576), 
      ACE_NTOHL (0x656e743a), 
      ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/Event:1.0
            6,
      ACE_NTOHL (0x4576656e), 
      ACE_NTOHL (0x74000000),  // name = Event
      2, // member count
            7,
      ACE_NTOHL (0x68656164), 
      ACE_NTOHL (0x65720000),  // name = header
            CORBA::tk_struct, // typecode kind
      664, // encapsulation length
        TAO_ENCAP_BYTE_ORDER, // byte order
        34,
        ACE_NTOHL (0x49444c3a), 
        ACE_NTOHL (0x52746563), 
        ACE_NTOHL (0x4576656e), 
        ACE_NTOHL (0x74436f6d), 
        ACE_NTOHL (0x6d2f4576), 
        ACE_NTOHL (0x656e7448), 
        ACE_NTOHL (0x65616465), 
        ACE_NTOHL (0x723a312e), 
        ACE_NTOHL (0x30000000),  // repository ID = IDL:RtecEventComm/EventHeader:1.0
                12,
        ACE_NTOHL (0x4576656e), 
        ACE_NTOHL (0x74486561), 
        ACE_NTOHL (0x64657200),  // name = EventHeader
        6, // member count
                5,
        ACE_NTOHL (0x74797065), 
        ACE_NTOHL (0x0),  // name = type
                CORBA::tk_alias, // typecode kind for typedefs
        60, // encapsulation length
          TAO_ENCAP_BYTE_ORDER, // byte order
          32,
          ACE_NTOHL (0x49444c3a), 
          ACE_NTOHL (0x52746563), 
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74436f6d), 
          ACE_NTOHL (0x6d2f4576), 
          ACE_NTOHL (0x656e7454), 
          ACE_NTOHL (0x7970653a), 
          ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventType:1.0
                    10,
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74547970), 
          ACE_NTOHL (0x65000000),  // name = EventType
                    CORBA::tk_long,


        7,
        ACE_NTOHL (0x736f7572), 
        ACE_NTOHL (0x63650000),  // name = source
                CORBA::tk_alias, // typecode kind for typedefs
        68, // encapsulation length
          TAO_ENCAP_BYTE_ORDER, // byte order
          36,
          ACE_NTOHL (0x49444c3a), 
          ACE_NTOHL (0x52746563), 
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74436f6d), 
          ACE_NTOHL (0x6d2f4576), 
          ACE_NTOHL (0x656e7453), 
          ACE_NTOHL (0x6f757263), 
          ACE_NTOHL (0x6549443a), 
          ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventSourceID:1.0
                    14,
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74536f75), 
          ACE_NTOHL (0x72636549), 
          ACE_NTOHL (0x44000000),  // name = EventSourceID
                    CORBA::tk_long,


        4,
        ACE_NTOHL (0x74746c00),  // name = ttl
                CORBA::tk_long,

        14,
        ACE_NTOHL (0x63726561), 
        ACE_NTOHL (0x74696f6e), 
        ACE_NTOHL (0x5f74696d), 
        ACE_NTOHL (0x65000000),  // name = creation_time
                CORBA::tk_alias, // typecode kind for typedefs
        112, // encapsulation length
          TAO_ENCAP_BYTE_ORDER, // byte order
          27,
          ACE_NTOHL (0x49444c3a), 
          ACE_NTOHL (0x52746563), 
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74436f6d), 
          ACE_NTOHL (0x6d2f5469), 
          ACE_NTOHL (0x6d653a31), 
          ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
                    5,
          ACE_NTOHL (0x54696d65), 
          ACE_NTOHL (0x0),  // name = Time
                    CORBA::tk_alias, // typecode kind for typedefs
          56, // encapsulation length
            TAO_ENCAP_BYTE_ORDER, // byte order
            31,
            ACE_NTOHL (0x49444c3a), 
            ACE_NTOHL (0x6f6d672e), 
            ACE_NTOHL (0x6f72672f), 
            ACE_NTOHL (0x54696d65), 
            ACE_NTOHL (0x42617365), 
            ACE_NTOHL (0x2f54696d), 
            ACE_NTOHL (0x65543a31), 
            ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
                        6,
            ACE_NTOHL (0x54696d65), 
            ACE_NTOHL (0x54000000),  // name = TimeT
                        CORBA::tk_ulonglong,



        13,
        ACE_NTOHL (0x65635f72), 
        ACE_NTOHL (0x6563765f), 
        ACE_NTOHL (0x74696d65), 
        ACE_NTOHL (0x0),  // name = ec_recv_time
                CORBA::tk_alias, // typecode kind for typedefs
        112, // encapsulation length
          TAO_ENCAP_BYTE_ORDER, // byte order
          27,
          ACE_NTOHL (0x49444c3a), 
          ACE_NTOHL (0x52746563), 
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74436f6d), 
          ACE_NTOHL (0x6d2f5469), 
          ACE_NTOHL (0x6d653a31), 
          ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
                    5,
          ACE_NTOHL (0x54696d65), 
          ACE_NTOHL (0x0),  // name = Time
                    CORBA::tk_alias, // typecode kind for typedefs
          56, // encapsulation length
            TAO_ENCAP_BYTE_ORDER, // byte order
            31,
            ACE_NTOHL (0x49444c3a), 
            ACE_NTOHL (0x6f6d672e), 
            ACE_NTOHL (0x6f72672f), 
            ACE_NTOHL (0x54696d65), 
            ACE_NTOHL (0x42617365), 
            ACE_NTOHL (0x2f54696d), 
            ACE_NTOHL (0x65543a31), 
            ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
                        6,
            ACE_NTOHL (0x54696d65), 
            ACE_NTOHL (0x54000000),  // name = TimeT
                        CORBA::tk_ulonglong,



        13,
        ACE_NTOHL (0x65635f73), 
        ACE_NTOHL (0x656e645f), 
        ACE_NTOHL (0x74696d65), 
        ACE_NTOHL (0x0),  // name = ec_send_time
                CORBA::tk_alias, // typecode kind for typedefs
        112, // encapsulation length
          TAO_ENCAP_BYTE_ORDER, // byte order
          27,
          ACE_NTOHL (0x49444c3a), 
          ACE_NTOHL (0x52746563), 
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74436f6d), 
          ACE_NTOHL (0x6d2f5469), 
          ACE_NTOHL (0x6d653a31), 
          ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/Time:1.0
                    5,
          ACE_NTOHL (0x54696d65), 
          ACE_NTOHL (0x0),  // name = Time
                    CORBA::tk_alias, // typecode kind for typedefs
          56, // encapsulation length
            TAO_ENCAP_BYTE_ORDER, // byte order
            31,
            ACE_NTOHL (0x49444c3a), 
            ACE_NTOHL (0x6f6d672e), 
            ACE_NTOHL (0x6f72672f), 
            ACE_NTOHL (0x54696d65), 
            ACE_NTOHL (0x42617365), 
            ACE_NTOHL (0x2f54696d), 
            ACE_NTOHL (0x65543a31), 
            ACE_NTOHL (0x2e300000),  // repository ID = IDL:omg.org/TimeBase/TimeT:1.0
                        6,
            ACE_NTOHL (0x54696d65), 
            ACE_NTOHL (0x54000000),  // name = TimeT
                        CORBA::tk_ulonglong,




      5,
      ACE_NTOHL (0x64617461), 
      ACE_NTOHL (0x0),  // name = data
            CORBA::tk_alias, // typecode kind for typedefs
      248, // encapsulation length
        TAO_ENCAP_BYTE_ORDER, // byte order
        32,
        ACE_NTOHL (0x49444c3a), 
        ACE_NTOHL (0x52746563), 
        ACE_NTOHL (0x4576656e), 
        ACE_NTOHL (0x74436f6d), 
        ACE_NTOHL (0x6d2f4576), 
        ACE_NTOHL (0x656e7444), 
        ACE_NTOHL (0x6174613a), 
        ACE_NTOHL (0x312e3000),  // repository ID = IDL:RtecEventComm/EventData:1.0
                10,
        ACE_NTOHL (0x4576656e), 
        ACE_NTOHL (0x74446174), 
        ACE_NTOHL (0x61000000),  // name = EventData
                CORBA::tk_struct, // typecode kind
        184, // encapsulation length
          TAO_ENCAP_BYTE_ORDER, // byte order
          22,
          ACE_NTOHL (0x49444c3a), 
          ACE_NTOHL (0x52746563), 
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74446174), 
          ACE_NTOHL (0x613a312e), 
          ACE_NTOHL (0x30000000),  // repository ID = IDL:RtecEventData:1.0
                    14,
          ACE_NTOHL (0x52746563), 
          ACE_NTOHL (0x4576656e), 
          ACE_NTOHL (0x74446174), 
          ACE_NTOHL (0x61000000),  // name = RtecEventData
          3, // member count
                    5,
          ACE_NTOHL (0x70616431), 
          ACE_NTOHL (0x0),  // name = pad1
                    CORBA::tk_long,

          8,
          ACE_NTOHL (0x7061796c), 
          ACE_NTOHL (0x6f616400),  // name = payload
                    CORBA::tk_alias, // typecode kind for typedefs
          72, // encapsulation length
            TAO_ENCAP_BYTE_ORDER, // byte order
            21,
            ACE_NTOHL (0x49444c3a), 
            ACE_NTOHL (0x4576656e), 
            ACE_NTOHL (0x74506179), 
            ACE_NTOHL (0x6c6f6164), 
            ACE_NTOHL (0x3a312e30), 
            ACE_NTOHL (0x0),  // repository ID = IDL:EventPayload:1.0
                        13,
            ACE_NTOHL (0x4576656e), 
            ACE_NTOHL (0x74506179), 
            ACE_NTOHL (0x6c6f6164), 
            ACE_NTOHL (0x0),  // name = EventPayload
                        CORBA::tk_sequence, // typecode kind
            12, // encapsulation length
              TAO_ENCAP_BYTE_ORDER, // byte order
              CORBA::tk_octet,

              0U,


          10,
          ACE_NTOHL (0x616e795f), 
          ACE_NTOHL (0x76616c75), 
          ACE_NTOHL (0x65000000),  // name = any_value
                    CORBA::tk_any,




    0U,

};

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_EventSet (
    CORBA::tk_alias,
    sizeof (_oc_RtecEventComm_EventSet),
    (char *) &_oc_RtecEventComm_EventSet,
    0,
    sizeof (RtecEventComm::EventSet)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_EventSet =
    &_tc_TAO_tc_RtecEventComm_EventSet;
}

// TAO_IDL - Generated from
// be/be_visitor_interface/interface_cs.cpp:60

// Traits specializations for RtecEventComm::PushConsumer.

ACE_TEMPLATE_CLASS_MEMBER_SPECIALIZATION
RtecEventComm::PushConsumer_ptr
TAO::Objref_Traits<RtecEventComm::PushConsumer>::tao_duplicate (
    RtecEventComm::PushConsumer_ptr p
  )
{
  return RtecEventComm::PushConsumer::_duplicate (p);
}

ACE_TEMPLATE_CLASS_MEMBER_SPECIALIZATION
void
TAO::Objref_Traits<RtecEventComm::PushConsumer>::tao_release (
    RtecEventComm::PushConsumer_ptr p
  )
{
  CORBA::release (p);
}

ACE_TEMPLATE_CLASS_MEMBER_SPECIALIZATION
RtecEventComm::PushConsumer_ptr
TAO::Objref_Traits<RtecEventComm::PushConsumer>::tao_nil (void)
{
  return RtecEventComm::PushConsumer::_nil ();
}

ACE_TEMPLATE_CLASS_MEMBER_SPECIALIZATION
CORBA::Boolean
TAO::Objref_Traits<RtecEventComm::PushConsumer>::tao_marshal (
    RtecEventComm::PushConsumer_ptr p,
    TAO_OutputCDR & cdr
  )
{
  return CORBA::Object::marshal (p, cdr);
}

// Function pointer for collocation factory initialization.
TAO::Collocation_Proxy_Broker * 
(*RtecEventComm__TAO_PushConsumer_Proxy_Broker_Factory_function_pointer) (
    CORBA::Object_ptr obj
  ) = 0;

// TAO_IDL - Generated from
// be/be_visitor_operation/operation_cs.cpp:78

void RtecEventComm::PushConsumer::push (
    const ::RtecEventComm::EventSet & data
    ACE_ENV_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  if (!this->is_evaluated ())
    {
      ACE_NESTED_CLASS (CORBA, Object)::tao_object_initialize (this);
    }
  
  if (this->the_TAO_PushConsumer_Proxy_Broker_ == 0)
    {
      RtecEventComm_PushConsumer_setup_collocation ();
    }
  
  TAO::Arg_Traits< void>::ret_val _tao_retval;
  TAO::Arg_Traits< ::RtecEventComm::EventSet>::in_arg_val _tao_data (data);
  
  TAO::Argument *_the_tao_operation_signature [] =
    {
      &_tao_retval,
      &_tao_data
    };
  
  TAO::Invocation_Adapter _tao_call (
      this,
      _the_tao_operation_signature,
      2,
      "push",
      4,
      this->the_TAO_PushConsumer_Proxy_Broker_,
      TAO::TAO_ONEWAY_INVOCATION
    );
  
  _tao_call.invoke (0, 0 ACE_ENV_ARG_PARAMETER);
  ACE_CHECK;
}

// TAO_IDL - Generated from
// be/be_visitor_operation/operation_cs.cpp:78

void RtecEventComm::PushConsumer::disconnect_push_consumer (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  if (!this->is_evaluated ())
    {
      ACE_NESTED_CLASS (CORBA, Object)::tao_object_initialize (this);
    }
  
  if (this->the_TAO_PushConsumer_Proxy_Broker_ == 0)
    {
      RtecEventComm_PushConsumer_setup_collocation ();
    }
  
  TAO::Arg_Traits< void>::ret_val _tao_retval;
  
  TAO::Argument *_the_tao_operation_signature [] =
    {
      &_tao_retval
    };
  
  TAO::Invocation_Adapter _tao_call (
      this,
      _the_tao_operation_signature,
      1,
      "disconnect_push_consumer",
      24,
      this->the_TAO_PushConsumer_Proxy_Broker_
    );
  
  _tao_call.invoke (0, 0 ACE_ENV_ARG_PARAMETER);
  ACE_CHECK;
}

RtecEventComm::PushConsumer::PushConsumer (void)
 : the_TAO_PushConsumer_Proxy_Broker_ (0)
{
  this->RtecEventComm_PushConsumer_setup_collocation ();
}

void
RtecEventComm::PushConsumer::RtecEventComm_PushConsumer_setup_collocation ()
{
  if (::RtecEventComm__TAO_PushConsumer_Proxy_Broker_Factory_function_pointer)
    {
      this->the_TAO_PushConsumer_Proxy_Broker_ =
        ::RtecEventComm__TAO_PushConsumer_Proxy_Broker_Factory_function_pointer (this);
    }
}

RtecEventComm::PushConsumer::~PushConsumer (void)
{}

void 
RtecEventComm::PushConsumer::_tao_any_destructor (void *_tao_void_pointer)
{
  PushConsumer *_tao_tmp_pointer =
    static_cast<PushConsumer *> (_tao_void_pointer);
  CORBA::release (_tao_tmp_pointer);
}

RtecEventComm::PushConsumer_ptr
RtecEventComm::PushConsumer::_narrow (
    CORBA::Object_ptr _tao_objref
    ACE_ENV_ARG_DECL
  )
{
  return
    TAO::Narrow_Utils<PushConsumer>::narrow (
        _tao_objref,
        "IDL:RtecEventComm/PushConsumer:1.0",
        RtecEventComm__TAO_PushConsumer_Proxy_Broker_Factory_function_pointer
        ACE_ENV_ARG_PARAMETER
      );
}

RtecEventComm::PushConsumer_ptr
RtecEventComm::PushConsumer::_unchecked_narrow (
    CORBA::Object_ptr _tao_objref
    ACE_ENV_ARG_DECL
  )
{
  return
    TAO::Narrow_Utils<PushConsumer>::unchecked_narrow (
        _tao_objref,
        "IDL:RtecEventComm/PushConsumer:1.0",
        RtecEventComm__TAO_PushConsumer_Proxy_Broker_Factory_function_pointer
        ACE_ENV_ARG_PARAMETER
      );
}

RtecEventComm::PushConsumer_ptr
RtecEventComm::PushConsumer::_duplicate (PushConsumer_ptr obj)
{
  if (! CORBA::is_nil (obj))
    {
      obj->_add_ref ();
    }
  
  return obj;
}

CORBA::Boolean
RtecEventComm::PushConsumer::_is_a (
    const char *value
    ACE_ENV_ARG_DECL
  )
{
  if (
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:RtecEventComm/PushConsumer:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CORBA/Object:1.0"
        )
     )
    {
      return 1; // success using local knowledge
    }
  else
    {
      return this->ACE_NESTED_CLASS (CORBA, Object)::_is_a (
          value
          ACE_ENV_ARG_PARAMETER
        );
    }
}

const char* RtecEventComm::PushConsumer::_interface_repository_id (void) const
{
  return "IDL:RtecEventComm/PushConsumer:1.0";
}

CORBA::Boolean
RtecEventComm::PushConsumer::marshal (TAO_OutputCDR &cdr)
{
  return (cdr << this);
}

// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_PushConsumer[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  35,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f5075), 
  ACE_NTOHL (0x7368436f), 
  ACE_NTOHL (0x6e73756d), 
  ACE_NTOHL (0x65723a31), 
  ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/PushConsumer:1.0
    13,
  ACE_NTOHL (0x50757368), 
  ACE_NTOHL (0x436f6e73), 
  ACE_NTOHL (0x756d6572), 
  ACE_NTOHL (0x0),  // name = PushConsumer
  };

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_PushConsumer (
    CORBA::tk_objref,
    sizeof (_oc_RtecEventComm_PushConsumer),
    (char *) &_oc_RtecEventComm_PushConsumer,
    0,
    sizeof (RtecEventComm::PushConsumer)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_PushConsumer =
    &_tc_TAO_tc_RtecEventComm_PushConsumer;
}

// TAO_IDL - Generated from
// be/be_visitor_interface/interface_cs.cpp:60

// Traits specializations for RtecEventComm::PushSupplier.

ACE_TEMPLATE_CLASS_MEMBER_SPECIALIZATION
RtecEventComm::PushSupplier_ptr
TAO::Objref_Traits<RtecEventComm::PushSupplier>::tao_duplicate (
    RtecEventComm::PushSupplier_ptr p
  )
{
  return RtecEventComm::PushSupplier::_duplicate (p);
}

ACE_TEMPLATE_CLASS_MEMBER_SPECIALIZATION
void
TAO::Objref_Traits<RtecEventComm::PushSupplier>::tao_release (
    RtecEventComm::PushSupplier_ptr p
  )
{
  CORBA::release (p);
}

ACE_TEMPLATE_CLASS_MEMBER_SPECIALIZATION
RtecEventComm::PushSupplier_ptr
TAO::Objref_Traits<RtecEventComm::PushSupplier>::tao_nil (void)
{
  return RtecEventComm::PushSupplier::_nil ();
}

ACE_TEMPLATE_CLASS_MEMBER_SPECIALIZATION
CORBA::Boolean
TAO::Objref_Traits<RtecEventComm::PushSupplier>::tao_marshal (
    RtecEventComm::PushSupplier_ptr p,
    TAO_OutputCDR & cdr
  )
{
  return CORBA::Object::marshal (p, cdr);
}

// Function pointer for collocation factory initialization.
TAO::Collocation_Proxy_Broker * 
(*RtecEventComm__TAO_PushSupplier_Proxy_Broker_Factory_function_pointer) (
    CORBA::Object_ptr obj
  ) = 0;

// TAO_IDL - Generated from
// be/be_visitor_operation/operation_cs.cpp:78

void RtecEventComm::PushSupplier::disconnect_push_supplier (
    ACE_ENV_SINGLE_ARG_DECL
  )
  ACE_THROW_SPEC ((
    CORBA::SystemException
  ))
{
  if (!this->is_evaluated ())
    {
      ACE_NESTED_CLASS (CORBA, Object)::tao_object_initialize (this);
    }
  
  if (this->the_TAO_PushSupplier_Proxy_Broker_ == 0)
    {
      RtecEventComm_PushSupplier_setup_collocation ();
    }
  
  TAO::Arg_Traits< void>::ret_val _tao_retval;
  
  TAO::Argument *_the_tao_operation_signature [] =
    {
      &_tao_retval
    };
  
  TAO::Invocation_Adapter _tao_call (
      this,
      _the_tao_operation_signature,
      1,
      "disconnect_push_supplier",
      24,
      this->the_TAO_PushSupplier_Proxy_Broker_
    );
  
  _tao_call.invoke (0, 0 ACE_ENV_ARG_PARAMETER);
  ACE_CHECK;
}

RtecEventComm::PushSupplier::PushSupplier (void)
 : the_TAO_PushSupplier_Proxy_Broker_ (0)
{
  this->RtecEventComm_PushSupplier_setup_collocation ();
}

void
RtecEventComm::PushSupplier::RtecEventComm_PushSupplier_setup_collocation ()
{
  if (::RtecEventComm__TAO_PushSupplier_Proxy_Broker_Factory_function_pointer)
    {
      this->the_TAO_PushSupplier_Proxy_Broker_ =
        ::RtecEventComm__TAO_PushSupplier_Proxy_Broker_Factory_function_pointer (this);
    }
}

RtecEventComm::PushSupplier::~PushSupplier (void)
{}

void 
RtecEventComm::PushSupplier::_tao_any_destructor (void *_tao_void_pointer)
{
  PushSupplier *_tao_tmp_pointer =
    static_cast<PushSupplier *> (_tao_void_pointer);
  CORBA::release (_tao_tmp_pointer);
}

RtecEventComm::PushSupplier_ptr
RtecEventComm::PushSupplier::_narrow (
    CORBA::Object_ptr _tao_objref
    ACE_ENV_ARG_DECL
  )
{
  return
    TAO::Narrow_Utils<PushSupplier>::narrow (
        _tao_objref,
        "IDL:RtecEventComm/PushSupplier:1.0",
        RtecEventComm__TAO_PushSupplier_Proxy_Broker_Factory_function_pointer
        ACE_ENV_ARG_PARAMETER
      );
}

RtecEventComm::PushSupplier_ptr
RtecEventComm::PushSupplier::_unchecked_narrow (
    CORBA::Object_ptr _tao_objref
    ACE_ENV_ARG_DECL
  )
{
  return
    TAO::Narrow_Utils<PushSupplier>::unchecked_narrow (
        _tao_objref,
        "IDL:RtecEventComm/PushSupplier:1.0",
        RtecEventComm__TAO_PushSupplier_Proxy_Broker_Factory_function_pointer
        ACE_ENV_ARG_PARAMETER
      );
}

RtecEventComm::PushSupplier_ptr
RtecEventComm::PushSupplier::_duplicate (PushSupplier_ptr obj)
{
  if (! CORBA::is_nil (obj))
    {
      obj->_add_ref ();
    }
  
  return obj;
}

CORBA::Boolean
RtecEventComm::PushSupplier::_is_a (
    const char *value
    ACE_ENV_ARG_DECL
  )
{
  if (
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:RtecEventComm/PushSupplier:1.0"
        ) ||
      !ACE_OS::strcmp (
          (char *)value,
          "IDL:omg.org/CORBA/Object:1.0"
        )
     )
    {
      return 1; // success using local knowledge
    }
  else
    {
      return this->ACE_NESTED_CLASS (CORBA, Object)::_is_a (
          value
          ACE_ENV_ARG_PARAMETER
        );
    }
}

const char* RtecEventComm::PushSupplier::_interface_repository_id (void) const
{
  return "IDL:RtecEventComm/PushSupplier:1.0";
}

CORBA::Boolean
RtecEventComm::PushSupplier::marshal (TAO_OutputCDR &cdr)
{
  return (cdr << this);
}

// TAO_IDL - Generated from
// be/be_visitor_typecode/typecode_defn.cpp:290

static const CORBA::Long _oc_RtecEventComm_PushSupplier[] =
{
    TAO_ENCAP_BYTE_ORDER, // byte order
  35,
  ACE_NTOHL (0x49444c3a), 
  ACE_NTOHL (0x52746563), 
  ACE_NTOHL (0x4576656e), 
  ACE_NTOHL (0x74436f6d), 
  ACE_NTOHL (0x6d2f5075), 
  ACE_NTOHL (0x73685375), 
  ACE_NTOHL (0x70706c69), 
  ACE_NTOHL (0x65723a31), 
  ACE_NTOHL (0x2e300000),  // repository ID = IDL:RtecEventComm/PushSupplier:1.0
    13,
  ACE_NTOHL (0x50757368), 
  ACE_NTOHL (0x53757070), 
  ACE_NTOHL (0x6c696572), 
  ACE_NTOHL (0x0),  // name = PushSupplier
  };

static CORBA::TypeCode _tc_TAO_tc_RtecEventComm_PushSupplier (
    CORBA::tk_objref,
    sizeof (_oc_RtecEventComm_PushSupplier),
    (char *) &_oc_RtecEventComm_PushSupplier,
    0,
    sizeof (RtecEventComm::PushSupplier)
  );

namespace RtecEventComm
{
  ::CORBA::TypeCode_ptr _tc_PushSupplier =
    &_tc_TAO_tc_RtecEventComm_PushSupplier;
}

// TAO_IDL - Generated from 
// be/be_visitor_structure/any_op_cs.cpp:54

// Copying insertion.
void operator<<= (
    CORBA::Any &_tao_any,
    const RtecEventComm::EventHeader &_tao_elem
  )
{
  TAO::Any_Dual_Impl_T<RtecEventComm::EventHeader>::insert_copy (
      _tao_any,
      RtecEventComm::EventHeader::_tao_any_destructor,
      RtecEventComm::_tc_EventHeader,
      _tao_elem
    );
}

// Non-copying insertion.
void operator<<= (
    CORBA::Any &_tao_any,
    RtecEventComm::EventHeader *_tao_elem
  )
{
  TAO::Any_Dual_Impl_T<RtecEventComm::EventHeader>::insert (
      _tao_any,
      RtecEventComm::EventHeader::_tao_any_destructor,
      RtecEventComm::_tc_EventHeader,
      _tao_elem
    );
}

// Extraction to non-const pointer (deprecated).
CORBA::Boolean operator>>= (
    const CORBA::Any &_tao_any,
    RtecEventComm::EventHeader *&_tao_elem
  )
{
  return _tao_any >>= const_cast<
      const RtecEventComm::EventHeader *&> (
      _tao_elem
    );
}

// Extraction to const pointer.
CORBA::Boolean operator>>= (
    const CORBA::Any &_tao_any,
    const RtecEventComm::EventHeader *&_tao_elem
  )
{
  return
    TAO::Any_Dual_Impl_T<RtecEventComm::EventHeader>::extract (
        _tao_any,
        RtecEventComm::EventHeader::_tao_any_destructor,
        RtecEventComm::_tc_EventHeader,
        _tao_elem
      );
}

// TAO_IDL - Generated from 
// be/be_visitor_structure/any_op_cs.cpp:54

// Copying insertion.
void operator<<= (
    CORBA::Any &_tao_any,
    const RtecEventComm::Event &_tao_elem
  )
{
  TAO::Any_Dual_Impl_T<RtecEventComm::Event>::insert_copy (
      _tao_any,
      RtecEventComm::Event::_tao_any_destructor,
      RtecEventComm::_tc_Event,
      _tao_elem
    );
}

// Non-copying insertion.
void operator<<= (
    CORBA::Any &_tao_any,
    RtecEventComm::Event *_tao_elem
  )
{
  TAO::Any_Dual_Impl_T<RtecEventComm::Event>::insert (
      _tao_any,
      RtecEventComm::Event::_tao_any_destructor,
      RtecEventComm::_tc_Event,
      _tao_elem
    );
}

// Extraction to non-const pointer (deprecated).
CORBA::Boolean operator>>= (
    const CORBA::Any &_tao_any,
    RtecEventComm::Event *&_tao_elem
  )
{
  return _tao_any >>= const_cast<
      const RtecEventComm::Event *&> (
      _tao_elem
    );
}

// Extraction to const pointer.
CORBA::Boolean operator>>= (
    const CORBA::Any &_tao_any,
    const RtecEventComm::Event *&_tao_elem
  )
{
  return
    TAO::Any_Dual_Impl_T<RtecEventComm::Event>::extract (
        _tao_any,
        RtecEventComm::Event::_tao_any_destructor,
        RtecEventComm::_tc_Event,
        _tao_elem
      );
}

// TAO_IDL - Generated from 
// be/be_visitor_sequence/any_op_cs.cpp:54

// Copying insertion.
void operator<<= (
    CORBA::Any &_tao_any,
    const RtecEventComm::EventSet &_tao_elem
  )
{
  TAO::Any_Dual_Impl_T<RtecEventComm::EventSet>::insert_copy (
      _tao_any,
      RtecEventComm::EventSet::_tao_any_destructor,
      RtecEventComm::_tc_EventSet,
      _tao_elem
    );
}

// Non-copying insertion.
void operator<<= (
    CORBA::Any &_tao_any,
    RtecEventComm::EventSet *_tao_elem
  )
{
  TAO::Any_Dual_Impl_T<RtecEventComm::EventSet>::insert (
      _tao_any,
      RtecEventComm::EventSet::_tao_any_destructor,
      RtecEventComm::_tc_EventSet,
      _tao_elem
    );
}

// Extraction to non-const pointer (deprecated).
CORBA::Boolean operator>>= (
    const CORBA::Any &_tao_any,
    RtecEventComm::EventSet *&_tao_elem
  )
{
  return _tao_any >>= const_cast<
      const RtecEventComm::EventSet *&> (
      _tao_elem
    );
}

// Extraction to const pointer.
CORBA::Boolean operator>>= (
    const CORBA::Any &_tao_any,
    const RtecEventComm::EventSet *&_tao_elem
  )
{
  return
    TAO::Any_Dual_Impl_T<RtecEventComm::EventSet>::extract (
        _tao_any,
        RtecEventComm::EventSet::_tao_any_destructor,
        RtecEventComm::_tc_EventSet,
        _tao_elem
      );
}

// TAO_IDL - Generated from
// be/be_visitor_interface/any_op_cs.cpp:50

ACE_TEMPLATE_SPECIALIZATION
CORBA::Boolean
TAO::Any_Impl_T<RtecEventComm::PushConsumer>::to_object (
    CORBA::Object_ptr &_tao_elem
  ) const
{
  _tao_elem = CORBA::Object::_duplicate (this->value_);
  return 1;
}

// Copying insertion.
void
operator<<= (
    CORBA::Any &_tao_any,
    RtecEventComm::PushConsumer_ptr _tao_elem
  )
{
  RtecEventComm::PushConsumer_ptr _tao_objptr =
    RtecEventComm::PushConsumer::_duplicate (_tao_elem);
  _tao_any <<= &_tao_objptr;
}

// Non-copying insertion.
void
operator<<= (
    CORBA::Any &_tao_any,
    RtecEventComm::PushConsumer_ptr *_tao_elem
  )
{
  TAO::Any_Impl_T<RtecEventComm::PushConsumer>::insert (
      _tao_any,
      RtecEventComm::PushConsumer::_tao_any_destructor,
      RtecEventComm::_tc_PushConsumer,
      *_tao_elem
    );
}

CORBA::Boolean
operator>>= (
    const CORBA::Any &_tao_any,
    RtecEventComm::PushConsumer_ptr &_tao_elem
  )
{
  return
    TAO::Any_Impl_T<RtecEventComm::PushConsumer>::extract (
        _tao_any,
        RtecEventComm::PushConsumer::_tao_any_destructor,
        RtecEventComm::_tc_PushConsumer,
        _tao_elem
      );
}

// TAO_IDL - Generated from
// be/be_visitor_interface/any_op_cs.cpp:50

ACE_TEMPLATE_SPECIALIZATION
CORBA::Boolean
TAO::Any_Impl_T<RtecEventComm::PushSupplier>::to_object (
    CORBA::Object_ptr &_tao_elem
  ) const
{
  _tao_elem = CORBA::Object::_duplicate (this->value_);
  return 1;
}

// Copying insertion.
void
operator<<= (
    CORBA::Any &_tao_any,
    RtecEventComm::PushSupplier_ptr _tao_elem
  )
{
  RtecEventComm::PushSupplier_ptr _tao_objptr =
    RtecEventComm::PushSupplier::_duplicate (_tao_elem);
  _tao_any <<= &_tao_objptr;
}

// Non-copying insertion.
void
operator<<= (
    CORBA::Any &_tao_any,
    RtecEventComm::PushSupplier_ptr *_tao_elem
  )
{
  TAO::Any_Impl_T<RtecEventComm::PushSupplier>::insert (
      _tao_any,
      RtecEventComm::PushSupplier::_tao_any_destructor,
      RtecEventComm::_tc_PushSupplier,
      *_tao_elem
    );
}

CORBA::Boolean
operator>>= (
    const CORBA::Any &_tao_any,
    RtecEventComm::PushSupplier_ptr &_tao_elem
  )
{
  return
    TAO::Any_Impl_T<RtecEventComm::PushSupplier>::extract (
        _tao_any,
        RtecEventComm::PushSupplier::_tao_any_destructor,
        RtecEventComm::_tc_PushSupplier,
        _tao_elem
      );
}

// TAO_IDL - Generated from
// be/be_visitor_structure/cdr_op_cs.cpp:61

CORBA::Boolean operator<< (
    TAO_OutputCDR &strm,
    const RtecEventComm::EventHeader &_tao_aggregate
  )
{
  return
    (strm << _tao_aggregate.type) &&
    (strm << _tao_aggregate.source) &&
    (strm << _tao_aggregate.ttl) &&
    (strm << _tao_aggregate.creation_time) &&
    (strm << _tao_aggregate.ec_recv_time) &&
    (strm << _tao_aggregate.ec_send_time);
}

CORBA::Boolean operator>> (
    TAO_InputCDR &strm,
    RtecEventComm::EventHeader &_tao_aggregate
  )
{
  return
    (strm >> _tao_aggregate.type) &&
    (strm >> _tao_aggregate.source) &&
    (strm >> _tao_aggregate.ttl) &&
    (strm >> _tao_aggregate.creation_time) &&
    (strm >> _tao_aggregate.ec_recv_time) &&
    (strm >> _tao_aggregate.ec_send_time);
}

// TAO_IDL - Generated from
// be/be_visitor_structure/cdr_op_cs.cpp:61

CORBA::Boolean operator<< (
    TAO_OutputCDR &strm,
    const RtecEventComm::Event &_tao_aggregate
  )
{
  return
    (strm << _tao_aggregate.header) &&
    (strm << _tao_aggregate.data);
}

CORBA::Boolean operator>> (
    TAO_InputCDR &strm,
    RtecEventComm::Event &_tao_aggregate
  )
{
  return
    (strm >> _tao_aggregate.header) &&
    (strm >> _tao_aggregate.data);
}

// TAO_IDL - Generated from
// be/be_visitor_sequence/cdr_op_cs.cpp:96

#if !defined _TAO_CDR_OP_RtecEventComm_EventSet_CPP_
#define _TAO_CDR_OP_RtecEventComm_EventSet_CPP_

CORBA::Boolean operator<< (
    TAO_OutputCDR &strm,
    const RtecEventComm::EventSet &_tao_sequence
  )
{
  const CORBA::ULong _tao_seq_len = _tao_sequence.length ();
  
  if (strm << _tao_seq_len)
    {
      // Encode all elements.
      CORBA::Boolean _tao_marshal_flag = 1;
      
      for (CORBA::ULong i = 0; i < _tao_seq_len && _tao_marshal_flag; ++i)
        {
          _tao_marshal_flag = (strm << _tao_sequence[i]);
        }
      
      return _tao_marshal_flag;
    }
  
  return 0;
}

CORBA::Boolean operator>> (
    TAO_InputCDR &strm,
    RtecEventComm::EventSet &_tao_sequence
  )
{
  CORBA::ULong _tao_seq_len;
  
  if (strm >> _tao_seq_len)
    {
      // Add a check to the length of the sequence
      // to make sure it does not exceed the length
      // of the stream. (See bug 58.)
      if (_tao_seq_len > strm.length ())
        {
          return 0;
        }
      
      // Set the length of the sequence.
      _tao_sequence.length (_tao_seq_len);
      
      // If length is 0 we return true.
      if (0 >= _tao_seq_len) 
        {
          return 1;
        }
      
      // Retrieve all the elements.
      CORBA::Boolean _tao_marshal_flag = 1;
      
      for (CORBA::ULong i = 0; i < _tao_seq_len && _tao_marshal_flag; ++i)
        {
          _tao_marshal_flag = (strm >> _tao_sequence[i]);
        }
      
      return _tao_marshal_flag;
    
    }
  
  return 0;
}

#endif /* _TAO_CDR_OP_RtecEventComm_EventSet_CPP_ */

// TAO_IDL - Generated from
// be/be_visitor_interface/cdr_op_cs.cpp:63

CORBA::Boolean operator<< (
    TAO_OutputCDR &strm,
    const RtecEventComm::PushConsumer_ptr _tao_objref
  )
{
  CORBA::Object_ptr _tao_corba_obj = _tao_objref;
  return (strm << _tao_corba_obj);
}

CORBA::Boolean operator>> (
    TAO_InputCDR &strm,
    RtecEventComm::PushConsumer_ptr &_tao_objref
  )
{
  CORBA::Object_var obj;
  
  if ((strm >> obj.inout ()) == 0)
    {
      return 0;
    }
  
  typedef ::RtecEventComm::PushConsumer RHS_SCOPED_NAME;
  
  // Narrow to the right type.
  _tao_objref =
    TAO::Narrow_Utils<RHS_SCOPED_NAME>::unchecked_narrow (
        obj.in (),
        RtecEventComm__TAO_PushConsumer_Proxy_Broker_Factory_function_pointer
      );
    
  return 1;
}

// TAO_IDL - Generated from
// be/be_visitor_interface/cdr_op_cs.cpp:63

CORBA::Boolean operator<< (
    TAO_OutputCDR &strm,
    const RtecEventComm::PushSupplier_ptr _tao_objref
  )
{
  CORBA::Object_ptr _tao_corba_obj = _tao_objref;
  return (strm << _tao_corba_obj);
}

CORBA::Boolean operator>> (
    TAO_InputCDR &strm,
    RtecEventComm::PushSupplier_ptr &_tao_objref
  )
{
  CORBA::Object_var obj;
  
  if ((strm >> obj.inout ()) == 0)
    {
      return 0;
    }
  
  typedef ::RtecEventComm::PushSupplier RHS_SCOPED_NAME;
  
  // Narrow to the right type.
  _tao_objref =
    TAO::Narrow_Utils<RHS_SCOPED_NAME>::unchecked_narrow (
        obj.in (),
        RtecEventComm__TAO_PushSupplier_Proxy_Broker_Factory_function_pointer
      );
    
  return 1;
}

