pragma Style_Checks ("NM32766");

---------------------------------------------------
--  This file has been generated automatically from
--  /work/a/ports/net/polyorb/work/polyorb-2.9.0/idls/cos/notification/CosNotifyChannelAdmin.idl
--  by IAC (IDL to Ada Compiler) 2.9.0 (rev. unknown).
---------------------------------------------------
--  NOTE: If you modify this file by hand, your
--  changes will be lost when you re-run the
--  IDL to Ada compiler.
---------------------------------------------------

with PolyORB.Any.NVList;
with PolyORB.Types;
with CORBA.Object.Helper;
with CORBA.Object;
with PolyORB.Any;
with CosNotifyComm.SequencePullSupplier.Helper;
with PolyORB.Requests;
with CORBA.ExceptionList;
with CosEventChannelAdmin.Helper;
with PolyORB.CORBA_P.Interceptors_Hooks;
with PolyORB.CORBA_P.Exceptions;
with CosNotifyChannelAdmin.Helper;
with CosNotification.Helper;
with CosNotifyComm.Helper;
with CosNotification.QoSAdmin;
with CosNotifyFilter.FilterAdmin;
with CosNotifyComm.SequencePullConsumer;
with CosNotifyComm.NotifyPublish;

package body CosNotifyChannelAdmin.SequenceProxyPullConsumer is

   connect_sequence_pull_supplier_Arg_Name_pull_supplier_Ü : constant PolyORB.Types.Identifier :=
     PolyORB.Types.To_PolyORB_String
        ("pull_supplier");

   connect_sequence_pull_supplier_Result_Name_Ü : constant PolyORB.Types.Identifier :=
     PolyORB.Types.To_PolyORB_String
        ("Result");

   ---------------------------------------------
   -- connect_sequence_pull_supplier_Result_Ü --
   ---------------------------------------------

   function connect_sequence_pull_supplier_Result_Ü return PolyORB.Any.NamedValue is
      pragma Inline (connect_sequence_pull_supplier_Result_Ü);
   begin
      return (Name => connect_sequence_pull_supplier_Result_Name_Ü,
      Argument => CORBA.Internals.Get_Empty_Any
        (CORBA.TC_Void),
      Arg_Modes => 0);
   end connect_sequence_pull_supplier_Result_Ü;

   ------------------------------------
   -- connect_sequence_pull_supplier --
   ------------------------------------

   procedure connect_sequence_pull_supplier
     (Self : Ref;
      pull_supplier : CosNotifyComm.SequencePullSupplier.Ref)
   is
      Argument_List_Ü : PolyORB.Any.NVList.Ref;
      Arg_CC_pull_supplier_Ü : aliased PolyORB.Any.Content'Class :=
        CORBA.Object.Helper.Wrap
           (CORBA.Object.Ref
              (pull_supplier)'Unrestricted_Access);
      Arg_Any_pull_supplier_Ü : constant CORBA.Any :=
        CORBA.Internals.Get_Wrapper_Any
           (CosNotifyComm.SequencePullSupplier.Helper.TC_SequencePullSupplier,
            Arg_CC_pull_supplier_Ü'Unchecked_Access);
      Request_Ü : aliased PolyORB.Requests.Request;
      Exception_List_Ü : CORBA.ExceptionList.Ref;
      Result_Nv_Ü : PolyORB.Any.NamedValue :=
        connect_sequence_pull_supplier_Result_Ü;
   begin
      if CORBA.Object.Is_Nil
        (CORBA.Object.Ref
           (Self))
      then
         CORBA.Raise_Inv_Objref
           (CORBA.Default_Sys_Member);
      end if;
      --  Create the Argument list
      PolyORB.Any.NVList.Create
        (Argument_List_Ü);
      --  Fill the Argument list
      PolyORB.Any.NVList.Add_Item
        (Argument_List_Ü,
         connect_sequence_pull_supplier_Arg_Name_pull_supplier_Ü,
         PolyORB.Any.Any
           (Arg_Any_pull_supplier_Ü),
         PolyORB.Any.ARG_IN);
      --  Create the Exception list
      CORBA.ExceptionList.Create_List
        (Exception_List_Ü);
      CORBA.ExceptionList.Add
        (Exception_List_Ü,
         CosEventChannelAdmin.Helper.TC_AlreadyConnected);
      CORBA.ExceptionList.Add
        (Exception_List_Ü,
         CosEventChannelAdmin.Helper.TC_TypeError);
      --  Creating the request
      PolyORB.Requests.Setup_Request
        (Req => Request_Ü,
         Target => CORBA.Object.Internals.To_PolyORB_Ref
           (CORBA.Object.Ref
              (Self)),
         Operation => "connect_sequence_pull_supplier",
         Arg_List => Argument_List_Ü,
         Result => Result_Nv_Ü,
         Exc_List => CORBA.ExceptionList.Internals.To_PolyORB_Ref
           (Exception_List_Ü));
      --  Invoking the request (synchronously or asynchronously)
      PolyORB.CORBA_P.Interceptors_Hooks.Client_Invoke
        (Request_Ü'Access,
         PolyORB.Requests.Flags
           (0));
      --  Raise exception, if needed
      PolyORB.CORBA_P.Exceptions.Request_Raise_Occurrence
        (Request_Ü);
   end connect_sequence_pull_supplier;

   suspend_connection_Result_Name_Ü : constant PolyORB.Types.Identifier :=
     PolyORB.Types.To_PolyORB_String
        ("Result");

   ---------------------------------
   -- suspend_connection_Result_Ü --
   ---------------------------------

   function suspend_connection_Result_Ü return PolyORB.Any.NamedValue is
      pragma Inline (suspend_connection_Result_Ü);
   begin
      return (Name => suspend_connection_Result_Name_Ü,
      Argument => CORBA.Internals.Get_Empty_Any
        (CORBA.TC_Void),
      Arg_Modes => 0);
   end suspend_connection_Result_Ü;

   ------------------------
   -- suspend_connection --
   ------------------------

   procedure suspend_connection
     (Self : Ref)
   is
      Argument_List_Ü : PolyORB.Any.NVList.Ref;
      Request_Ü : aliased PolyORB.Requests.Request;
      Exception_List_Ü : CORBA.ExceptionList.Ref;
      Result_Nv_Ü : PolyORB.Any.NamedValue :=
        suspend_connection_Result_Ü;
   begin
      if CORBA.Object.Is_Nil
        (CORBA.Object.Ref
           (Self))
      then
         CORBA.Raise_Inv_Objref
           (CORBA.Default_Sys_Member);
      end if;
      --  Create the Argument list
      PolyORB.Any.NVList.Create
        (Argument_List_Ü);
      --  Create the Exception list
      CORBA.ExceptionList.Create_List
        (Exception_List_Ü);
      CORBA.ExceptionList.Add
        (Exception_List_Ü,
         CosNotifyChannelAdmin.Helper.TC_ConnectionAlreadyInactive);
      CORBA.ExceptionList.Add
        (Exception_List_Ü,
         CosNotifyChannelAdmin.Helper.TC_NotConnected);
      --  Creating the request
      PolyORB.Requests.Setup_Request
        (Req => Request_Ü,
         Target => CORBA.Object.Internals.To_PolyORB_Ref
           (CORBA.Object.Ref
              (Self)),
         Operation => "suspend_connection",
         Arg_List => Argument_List_Ü,
         Result => Result_Nv_Ü,
         Exc_List => CORBA.ExceptionList.Internals.To_PolyORB_Ref
           (Exception_List_Ü));
      --  Invoking the request (synchronously or asynchronously)
      PolyORB.CORBA_P.Interceptors_Hooks.Client_Invoke
        (Request_Ü'Access,
         PolyORB.Requests.Flags
           (0));
      --  Raise exception, if needed
      PolyORB.CORBA_P.Exceptions.Request_Raise_Occurrence
        (Request_Ü);
   end suspend_connection;

   resume_connection_Result_Name_Ü : constant PolyORB.Types.Identifier :=
     PolyORB.Types.To_PolyORB_String
        ("Result");

   --------------------------------
   -- resume_connection_Result_Ü --
   --------------------------------

   function resume_connection_Result_Ü return PolyORB.Any.NamedValue is
      pragma Inline (resume_connection_Result_Ü);
   begin
      return (Name => resume_connection_Result_Name_Ü,
      Argument => CORBA.Internals.Get_Empty_Any
        (CORBA.TC_Void),
      Arg_Modes => 0);
   end resume_connection_Result_Ü;

   -----------------------
   -- resume_connection --
   -----------------------

   procedure resume_connection
     (Self : Ref)
   is
      Argument_List_Ü : PolyORB.Any.NVList.Ref;
      Request_Ü : aliased PolyORB.Requests.Request;
      Exception_List_Ü : CORBA.ExceptionList.Ref;
      Result_Nv_Ü : PolyORB.Any.NamedValue :=
        resume_connection_Result_Ü;
   begin
      if CORBA.Object.Is_Nil
        (CORBA.Object.Ref
           (Self))
      then
         CORBA.Raise_Inv_Objref
           (CORBA.Default_Sys_Member);
      end if;
      --  Create the Argument list
      PolyORB.Any.NVList.Create
        (Argument_List_Ü);
      --  Create the Exception list
      CORBA.ExceptionList.Create_List
        (Exception_List_Ü);
      CORBA.ExceptionList.Add
        (Exception_List_Ü,
         CosNotifyChannelAdmin.Helper.TC_ConnectionAlreadyActive);
      CORBA.ExceptionList.Add
        (Exception_List_Ü,
         CosNotifyChannelAdmin.Helper.TC_NotConnected);
      --  Creating the request
      PolyORB.Requests.Setup_Request
        (Req => Request_Ü,
         Target => CORBA.Object.Internals.To_PolyORB_Ref
           (CORBA.Object.Ref
              (Self)),
         Operation => "resume_connection",
         Arg_List => Argument_List_Ü,
         Result => Result_Nv_Ü,
         Exc_List => CORBA.ExceptionList.Internals.To_PolyORB_Ref
           (Exception_List_Ü));
      --  Invoking the request (synchronously or asynchronously)
      PolyORB.CORBA_P.Interceptors_Hooks.Client_Invoke
        (Request_Ü'Access,
         PolyORB.Requests.Flags
           (0));
      --  Raise exception, if needed
      PolyORB.CORBA_P.Exceptions.Request_Raise_Occurrence
        (Request_Ü);
   end resume_connection;

   disconnect_sequence_pull_consumer_Result_Name_Ü : constant PolyORB.Types.Identifier :=
     PolyORB.Types.To_PolyORB_String
        ("Result");

   ------------------------------------------------
   -- disconnect_sequence_pull_consumer_Result_Ü --
   ------------------------------------------------

   function disconnect_sequence_pull_consumer_Result_Ü return PolyORB.Any.NamedValue is
      pragma Inline (disconnect_sequence_pull_consumer_Result_Ü);
   begin
      return (Name => disconnect_sequence_pull_consumer_Result_Name_Ü,
      Argument => CORBA.Internals.Get_Empty_Any
        (CORBA.TC_Void),
      Arg_Modes => 0);
   end disconnect_sequence_pull_consumer_Result_Ü;

   ---------------------------------------
   -- disconnect_sequence_pull_consumer --
   ---------------------------------------

   procedure disconnect_sequence_pull_consumer
     (Self : Ref)
   is
      Argument_List_Ü : PolyORB.Any.NVList.Ref;
      Request_Ü : aliased PolyORB.Requests.Request;
      Result_Nv_Ü : PolyORB.Any.NamedValue :=
        disconnect_sequence_pull_consumer_Result_Ü;
   begin
      if CORBA.Object.Is_Nil
        (CORBA.Object.Ref
           (Self))
      then
         CORBA.Raise_Inv_Objref
           (CORBA.Default_Sys_Member);
      end if;
      --  Create the Argument list
      PolyORB.Any.NVList.Create
        (Argument_List_Ü);
      --  Creating the request
      PolyORB.Requests.Setup_Request
        (Req => Request_Ü,
         Target => CORBA.Object.Internals.To_PolyORB_Ref
           (CORBA.Object.Ref
              (Self)),
         Operation => "disconnect_sequence_pull_consumer",
         Arg_List => Argument_List_Ü,
         Result => Result_Nv_Ü);
      --  Invoking the request (synchronously or asynchronously)
      PolyORB.CORBA_P.Interceptors_Hooks.Client_Invoke
        (Request_Ü'Access,
         PolyORB.Requests.Flags
           (0));
      --  Raise exception, if needed
      PolyORB.CORBA_P.Exceptions.Request_Raise_Occurrence
        (Request_Ü);
   end disconnect_sequence_pull_consumer;

   offer_change_Arg_Name_added_Ü : constant PolyORB.Types.Identifier :=
     PolyORB.Types.To_PolyORB_String
        ("added");

   offer_change_Arg_Name_removed_Ü : constant PolyORB.Types.Identifier :=
     PolyORB.Types.To_PolyORB_String
        ("removed");

   offer_change_Result_Name_Ü : constant PolyORB.Types.Identifier :=
     PolyORB.Types.To_PolyORB_String
        ("Result");

   ---------------------------
   -- offer_change_Result_Ü --
   ---------------------------

   function offer_change_Result_Ü return PolyORB.Any.NamedValue is
      pragma Inline (offer_change_Result_Ü);
   begin
      return (Name => offer_change_Result_Name_Ü,
      Argument => CORBA.Internals.Get_Empty_Any
        (CORBA.TC_Void),
      Arg_Modes => 0);
   end offer_change_Result_Ü;

   ------------------
   -- offer_change --
   ------------------

   procedure offer_change
     (Self : Ref;
      added : CosNotification.EventTypeSeq;
      removed : CosNotification.EventTypeSeq)
   is
      Argument_List_Ü : PolyORB.Any.NVList.Ref;
      Arg_CC_added_Ü : aliased PolyORB.Any.Content'Class :=
        CosNotification.Helper.Internals.Wrap
           (CosNotification.IDL_SEQUENCE_CosNotification_EventType.Sequence
              (added)'Unrestricted_Access);
      Arg_Any_added_Ü : constant CORBA.Any :=
        CORBA.Internals.Get_Wrapper_Any
           (CosNotification.Helper.TC_EventTypeSeq,
            Arg_CC_added_Ü'Unchecked_Access);
      Arg_CC_removed_Ü : aliased PolyORB.Any.Content'Class :=
        CosNotification.Helper.Internals.Wrap
           (CosNotification.IDL_SEQUENCE_CosNotification_EventType.Sequence
              (removed)'Unrestricted_Access);
      Arg_Any_removed_Ü : constant CORBA.Any :=
        CORBA.Internals.Get_Wrapper_Any
           (CosNotification.Helper.TC_EventTypeSeq,
            Arg_CC_removed_Ü'Unchecked_Access);
      Request_Ü : aliased PolyORB.Requests.Request;
      Exception_List_Ü : CORBA.ExceptionList.Ref;
      Result_Nv_Ü : PolyORB.Any.NamedValue :=
        offer_change_Result_Ü;
   begin
      if CORBA.Object.Is_Nil
        (CORBA.Object.Ref
           (Self))
      then
         CORBA.Raise_Inv_Objref
           (CORBA.Default_Sys_Member);
      end if;
      --  Create the Argument list
      PolyORB.Any.NVList.Create
        (Argument_List_Ü);
      --  Fill the Argument list
      PolyORB.Any.NVList.Add_Item
        (Argument_List_Ü,
         offer_change_Arg_Name_added_Ü,
         PolyORB.Any.Any
           (Arg_Any_added_Ü),
         PolyORB.Any.ARG_IN);
      PolyORB.Any.NVList.Add_Item
        (Argument_List_Ü,
         offer_change_Arg_Name_removed_Ü,
         PolyORB.Any.Any
           (Arg_Any_removed_Ü),
         PolyORB.Any.ARG_IN);
      --  Create the Exception list
      CORBA.ExceptionList.Create_List
        (Exception_List_Ü);
      CORBA.ExceptionList.Add
        (Exception_List_Ü,
         CosNotifyComm.Helper.TC_InvalidEventType);
      --  Creating the request
      PolyORB.Requests.Setup_Request
        (Req => Request_Ü,
         Target => CORBA.Object.Internals.To_PolyORB_Ref
           (CORBA.Object.Ref
              (Self)),
         Operation => "offer_change",
         Arg_List => Argument_List_Ü,
         Result => Result_Nv_Ü,
         Exc_List => CORBA.ExceptionList.Internals.To_PolyORB_Ref
           (Exception_List_Ü));
      --  Invoking the request (synchronously or asynchronously)
      PolyORB.CORBA_P.Interceptors_Hooks.Client_Invoke
        (Request_Ü'Access,
         PolyORB.Requests.Flags
           (0));
      --  Raise exception, if needed
      PolyORB.CORBA_P.Exceptions.Request_Raise_Occurrence
        (Request_Ü);
   end offer_change;

   ----------
   -- Is_A --
   ----------

   function Is_A
     (Self : Ref;
      Logical_Type_Id : PolyORB.Std.String)
     return CORBA.Boolean
   is
   begin
      return (False
         or else (Is_A
           (Logical_Type_Id)
            or else CORBA.Object.Is_A
              (CORBA.Object.Ref
                 (Self),
               Logical_Type_Id)));
   end Is_A;

   ----------
   -- Is_A --
   ----------

   function Is_A
     (Logical_Type_Id : PolyORB.Std.String)
     return CORBA.Boolean
   is
   begin
      return (((CORBA.Is_Equivalent
        (Logical_Type_Id,
         CosNotifyChannelAdmin.SequenceProxyPullConsumer.Repository_Id)
         or else CORBA.Is_Equivalent
           (Logical_Type_Id,
            "IDL:omg.org/CORBA/Object:1.0"))
         or else (((CORBA.Is_Equivalent
           (Logical_Type_Id,
            CosNotifyChannelAdmin.ProxyConsumer.Repository_Id)
            or else (CORBA.Is_Equivalent
              (Logical_Type_Id,
               CosNotification.QoSAdmin.Repository_Id)
               or else CORBA.Is_Equivalent
                 (Logical_Type_Id,
                  CosNotifyFilter.FilterAdmin.Repository_Id)))
            or else CORBA.Is_Equivalent
              (Logical_Type_Id,
               CosNotifyComm.SequencePullConsumer.Repository_Id))
            or else CORBA.Is_Equivalent
              (Logical_Type_Id,
               CosNotifyComm.NotifyPublish.Repository_Id)))
         or else False);
   end Is_A;

end CosNotifyChannelAdmin.SequenceProxyPullConsumer;
