# Python stubs generated by omniidl from /home/duncan/inst/share/idl/omniORB/COS/CosNotifyChannelAdmin.idl

import omniORB, _omnipy
from omniORB import CORBA, PortableServer
_0_CORBA = CORBA

_omnipy.checkVersion(2,0, __file__)

# #include "CosNotification.idl"
import CosNotification_idl
_0_CosNotification = omniORB.openModule("CosNotification")
_0_CosNotification__POA = omniORB.openModule("CosNotification__POA")
# #include "CosEventComm.idl"
import CosEventComm_idl
_0_CosEventComm = omniORB.openModule("CosEventComm")
_0_CosEventComm__POA = omniORB.openModule("CosEventComm__POA")
# #include "CosNotifyComm.idl"
import CosNotifyComm_idl
_0_CosNotifyComm = omniORB.openModule("CosNotifyComm")
_0_CosNotifyComm__POA = omniORB.openModule("CosNotifyComm__POA")
# #include "CosNotifyFilter.idl"
import CosNotifyFilter_idl
_0_CosNotifyFilter = omniORB.openModule("CosNotifyFilter")
_0_CosNotifyFilter__POA = omniORB.openModule("CosNotifyFilter__POA")
# #include "CosEventChannelAdmin.idl"
import CosEventChannelAdmin_idl
_0_CosEventChannelAdmin = omniORB.openModule("CosEventChannelAdmin")
_0_CosEventChannelAdmin__POA = omniORB.openModule("CosEventChannelAdmin__POA")

#
# Start of module "CosNotifyChannelAdmin"
#
__name__ = "CosNotifyChannelAdmin"
_0_CosNotifyChannelAdmin = omniORB.openModule("CosNotifyChannelAdmin", r"/home/duncan/inst/share/idl/omniORB/COS/CosNotifyChannelAdmin.idl")
_0_CosNotifyChannelAdmin__POA = omniORB.openModule("CosNotifyChannelAdmin__POA", r"/home/duncan/inst/share/idl/omniORB/COS/CosNotifyChannelAdmin.idl")


# exception ConnectionAlreadyActive
_0_CosNotifyChannelAdmin.ConnectionAlreadyActive = omniORB.newEmptyClass()
class ConnectionAlreadyActive (CORBA.UserException):
    _NP_RepositoryId = "IDL:omg.org/CosNotifyChannelAdmin/ConnectionAlreadyActive:1.0"


_0_CosNotifyChannelAdmin.ConnectionAlreadyActive = ConnectionAlreadyActive
_0_CosNotifyChannelAdmin._d_ConnectionAlreadyActive  = (omniORB.tcInternal.tv_except, ConnectionAlreadyActive, ConnectionAlreadyActive._NP_RepositoryId, "ConnectionAlreadyActive")
_0_CosNotifyChannelAdmin._tc_ConnectionAlreadyActive = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_ConnectionAlreadyActive)
omniORB.registerType(ConnectionAlreadyActive._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_ConnectionAlreadyActive, _0_CosNotifyChannelAdmin._tc_ConnectionAlreadyActive)
del ConnectionAlreadyActive

# exception ConnectionAlreadyInactive
_0_CosNotifyChannelAdmin.ConnectionAlreadyInactive = omniORB.newEmptyClass()
class ConnectionAlreadyInactive (CORBA.UserException):
    _NP_RepositoryId = "IDL:omg.org/CosNotifyChannelAdmin/ConnectionAlreadyInactive:1.0"


_0_CosNotifyChannelAdmin.ConnectionAlreadyInactive = ConnectionAlreadyInactive
_0_CosNotifyChannelAdmin._d_ConnectionAlreadyInactive  = (omniORB.tcInternal.tv_except, ConnectionAlreadyInactive, ConnectionAlreadyInactive._NP_RepositoryId, "ConnectionAlreadyInactive")
_0_CosNotifyChannelAdmin._tc_ConnectionAlreadyInactive = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_ConnectionAlreadyInactive)
omniORB.registerType(ConnectionAlreadyInactive._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_ConnectionAlreadyInactive, _0_CosNotifyChannelAdmin._tc_ConnectionAlreadyInactive)
del ConnectionAlreadyInactive

# exception NotConnected
_0_CosNotifyChannelAdmin.NotConnected = omniORB.newEmptyClass()
class NotConnected (CORBA.UserException):
    _NP_RepositoryId = "IDL:omg.org/CosNotifyChannelAdmin/NotConnected:1.0"


_0_CosNotifyChannelAdmin.NotConnected = NotConnected
_0_CosNotifyChannelAdmin._d_NotConnected  = (omniORB.tcInternal.tv_except, NotConnected, NotConnected._NP_RepositoryId, "NotConnected")
_0_CosNotifyChannelAdmin._tc_NotConnected = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_NotConnected)
omniORB.registerType(NotConnected._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_NotConnected, _0_CosNotifyChannelAdmin._tc_NotConnected)
del NotConnected

# interface ConsumerAdmin;
_0_CosNotifyChannelAdmin._d_ConsumerAdmin = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/ConsumerAdmin:1.0", "ConsumerAdmin")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ConsumerAdmin:1.0"] = _0_CosNotifyChannelAdmin._d_ConsumerAdmin

# interface SupplierAdmin;
_0_CosNotifyChannelAdmin._d_SupplierAdmin = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/SupplierAdmin:1.0", "SupplierAdmin")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/SupplierAdmin:1.0"] = _0_CosNotifyChannelAdmin._d_SupplierAdmin

# interface EventChannel;
_0_CosNotifyChannelAdmin._d_EventChannel = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/EventChannel:1.0", "EventChannel")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/EventChannel:1.0"] = _0_CosNotifyChannelAdmin._d_EventChannel

# interface EventChannelFactory;
_0_CosNotifyChannelAdmin._d_EventChannelFactory = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/EventChannelFactory:1.0", "EventChannelFactory")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/EventChannelFactory:1.0"] = _0_CosNotifyChannelAdmin._d_EventChannelFactory

# enum ProxyType
_0_CosNotifyChannelAdmin.PUSH_ANY = omniORB.EnumItem("PUSH_ANY", 0)
_0_CosNotifyChannelAdmin.PULL_ANY = omniORB.EnumItem("PULL_ANY", 1)
_0_CosNotifyChannelAdmin.PUSH_STRUCTURED = omniORB.EnumItem("PUSH_STRUCTURED", 2)
_0_CosNotifyChannelAdmin.PULL_STRUCTURED = omniORB.EnumItem("PULL_STRUCTURED", 3)
_0_CosNotifyChannelAdmin.PUSH_SEQUENCE = omniORB.EnumItem("PUSH_SEQUENCE", 4)
_0_CosNotifyChannelAdmin.PULL_SEQUENCE = omniORB.EnumItem("PULL_SEQUENCE", 5)
_0_CosNotifyChannelAdmin.PUSH_TYPED = omniORB.EnumItem("PUSH_TYPED", 6)
_0_CosNotifyChannelAdmin.PULL_TYPED = omniORB.EnumItem("PULL_TYPED", 7)
_0_CosNotifyChannelAdmin.ProxyType = omniORB.Enum("IDL:omg.org/CosNotifyChannelAdmin/ProxyType:1.0", (_0_CosNotifyChannelAdmin.PUSH_ANY, _0_CosNotifyChannelAdmin.PULL_ANY, _0_CosNotifyChannelAdmin.PUSH_STRUCTURED, _0_CosNotifyChannelAdmin.PULL_STRUCTURED, _0_CosNotifyChannelAdmin.PUSH_SEQUENCE, _0_CosNotifyChannelAdmin.PULL_SEQUENCE, _0_CosNotifyChannelAdmin.PUSH_TYPED, _0_CosNotifyChannelAdmin.PULL_TYPED,))

_0_CosNotifyChannelAdmin._d_ProxyType  = (omniORB.tcInternal.tv_enum, _0_CosNotifyChannelAdmin.ProxyType._NP_RepositoryId, "ProxyType", _0_CosNotifyChannelAdmin.ProxyType._items)
_0_CosNotifyChannelAdmin._tc_ProxyType = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_ProxyType)
omniORB.registerType(_0_CosNotifyChannelAdmin.ProxyType._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_ProxyType, _0_CosNotifyChannelAdmin._tc_ProxyType)

# enum ObtainInfoMode
_0_CosNotifyChannelAdmin.ALL_NOW_UPDATES_OFF = omniORB.EnumItem("ALL_NOW_UPDATES_OFF", 0)
_0_CosNotifyChannelAdmin.ALL_NOW_UPDATES_ON = omniORB.EnumItem("ALL_NOW_UPDATES_ON", 1)
_0_CosNotifyChannelAdmin.NONE_NOW_UPDATES_OFF = omniORB.EnumItem("NONE_NOW_UPDATES_OFF", 2)
_0_CosNotifyChannelAdmin.NONE_NOW_UPDATES_ON = omniORB.EnumItem("NONE_NOW_UPDATES_ON", 3)
_0_CosNotifyChannelAdmin.ObtainInfoMode = omniORB.Enum("IDL:omg.org/CosNotifyChannelAdmin/ObtainInfoMode:1.0", (_0_CosNotifyChannelAdmin.ALL_NOW_UPDATES_OFF, _0_CosNotifyChannelAdmin.ALL_NOW_UPDATES_ON, _0_CosNotifyChannelAdmin.NONE_NOW_UPDATES_OFF, _0_CosNotifyChannelAdmin.NONE_NOW_UPDATES_ON,))

_0_CosNotifyChannelAdmin._d_ObtainInfoMode  = (omniORB.tcInternal.tv_enum, _0_CosNotifyChannelAdmin.ObtainInfoMode._NP_RepositoryId, "ObtainInfoMode", _0_CosNotifyChannelAdmin.ObtainInfoMode._items)
_0_CosNotifyChannelAdmin._tc_ObtainInfoMode = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_ObtainInfoMode)
omniORB.registerType(_0_CosNotifyChannelAdmin.ObtainInfoMode._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_ObtainInfoMode, _0_CosNotifyChannelAdmin._tc_ObtainInfoMode)

# interface ProxyConsumer
_0_CosNotifyChannelAdmin._d_ProxyConsumer = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/ProxyConsumer:1.0", "ProxyConsumer")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ProxyConsumer:1.0"] = _0_CosNotifyChannelAdmin._d_ProxyConsumer
_0_CosNotifyChannelAdmin.ProxyConsumer = omniORB.newEmptyClass()
class ProxyConsumer (_0_CosNotification.QoSAdmin, _0_CosNotifyFilter.FilterAdmin):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin._d_ProxyConsumer[1]

    def __init__(self, *args, **kw):
        raise RuntimeError("Cannot construct objects of this type.")

    _nil = CORBA.Object._nil


_0_CosNotifyChannelAdmin.ProxyConsumer = ProxyConsumer
_0_CosNotifyChannelAdmin._tc_ProxyConsumer = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_ProxyConsumer)
omniORB.registerType(ProxyConsumer._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_ProxyConsumer, _0_CosNotifyChannelAdmin._tc_ProxyConsumer)

# ProxyConsumer operations and attributes
ProxyConsumer._d__get_MyType = ((),(omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ProxyType:1.0"],),None)
ProxyConsumer._d__get_MyAdmin = ((),(omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/SupplierAdmin:1.0"],),None)
ProxyConsumer._d_obtain_subscription_types = ((omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ObtainInfoMode:1.0"], ), (omniORB.typeMapping["IDL:omg.org/CosNotification/EventTypeSeq:1.0"], ), None)
ProxyConsumer._d_validate_event_qos = ((omniORB.typeMapping["IDL:omg.org/CosNotification/QoSProperties:1.0"], ), (omniORB.typeMapping["IDL:omg.org/CosNotification/NamedPropertyRangeSeq:1.0"], ), {_0_CosNotification.UnsupportedQoS._NP_RepositoryId: _0_CosNotification._d_UnsupportedQoS})

# ProxyConsumer object reference
class _objref_ProxyConsumer (_0_CosNotification._objref_QoSAdmin, _0_CosNotifyFilter._objref_FilterAdmin):
    _NP_RepositoryId = ProxyConsumer._NP_RepositoryId

    def __init__(self):
        _0_CosNotification._objref_QoSAdmin.__init__(self)
        _0_CosNotifyFilter._objref_FilterAdmin.__init__(self)

    def _get_MyType(self, *args):
        return _omnipy.invoke(self, "_get_MyType", _0_CosNotifyChannelAdmin.ProxyConsumer._d__get_MyType, args)

    def _get_MyAdmin(self, *args):
        return _omnipy.invoke(self, "_get_MyAdmin", _0_CosNotifyChannelAdmin.ProxyConsumer._d__get_MyAdmin, args)

    def obtain_subscription_types(self, *args):
        return _omnipy.invoke(self, "obtain_subscription_types", _0_CosNotifyChannelAdmin.ProxyConsumer._d_obtain_subscription_types, args)

    def validate_event_qos(self, *args):
        return _omnipy.invoke(self, "validate_event_qos", _0_CosNotifyChannelAdmin.ProxyConsumer._d_validate_event_qos, args)

    __methods__ = ["_get_MyType", "_get_MyAdmin", "obtain_subscription_types", "validate_event_qos"] + _0_CosNotification._objref_QoSAdmin.__methods__ + _0_CosNotifyFilter._objref_FilterAdmin.__methods__

omniORB.registerObjref(ProxyConsumer._NP_RepositoryId, _objref_ProxyConsumer)
_0_CosNotifyChannelAdmin._objref_ProxyConsumer = _objref_ProxyConsumer
del ProxyConsumer, _objref_ProxyConsumer

# ProxyConsumer skeleton
__name__ = "CosNotifyChannelAdmin__POA"
class ProxyConsumer (_0_CosNotification__POA.QoSAdmin, _0_CosNotifyFilter__POA.FilterAdmin):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin.ProxyConsumer._NP_RepositoryId


    _omni_op_d = {"_get_MyType": _0_CosNotifyChannelAdmin.ProxyConsumer._d__get_MyType, "_get_MyAdmin": _0_CosNotifyChannelAdmin.ProxyConsumer._d__get_MyAdmin, "obtain_subscription_types": _0_CosNotifyChannelAdmin.ProxyConsumer._d_obtain_subscription_types, "validate_event_qos": _0_CosNotifyChannelAdmin.ProxyConsumer._d_validate_event_qos}
    _omni_op_d.update(_0_CosNotification__POA.QoSAdmin._omni_op_d)
    _omni_op_d.update(_0_CosNotifyFilter__POA.FilterAdmin._omni_op_d)

ProxyConsumer._omni_skeleton = ProxyConsumer
_0_CosNotifyChannelAdmin__POA.ProxyConsumer = ProxyConsumer
del ProxyConsumer
__name__ = "CosNotifyChannelAdmin"

# interface ProxySupplier
_0_CosNotifyChannelAdmin._d_ProxySupplier = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/ProxySupplier:1.0", "ProxySupplier")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ProxySupplier:1.0"] = _0_CosNotifyChannelAdmin._d_ProxySupplier
_0_CosNotifyChannelAdmin.ProxySupplier = omniORB.newEmptyClass()
class ProxySupplier (_0_CosNotification.QoSAdmin, _0_CosNotifyFilter.FilterAdmin):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin._d_ProxySupplier[1]

    def __init__(self, *args, **kw):
        raise RuntimeError("Cannot construct objects of this type.")

    _nil = CORBA.Object._nil


_0_CosNotifyChannelAdmin.ProxySupplier = ProxySupplier
_0_CosNotifyChannelAdmin._tc_ProxySupplier = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_ProxySupplier)
omniORB.registerType(ProxySupplier._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_ProxySupplier, _0_CosNotifyChannelAdmin._tc_ProxySupplier)

# ProxySupplier operations and attributes
ProxySupplier._d__get_MyType = ((),(omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ProxyType:1.0"],),None)
ProxySupplier._d__get_MyAdmin = ((),(omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ConsumerAdmin:1.0"],),None)
ProxySupplier._d__get_priority_filter = ((),(omniORB.typeMapping["IDL:omg.org/CosNotifyFilter/MappingFilter:1.0"],),None)
ProxySupplier._d__set_priority_filter = ((omniORB.typeMapping["IDL:omg.org/CosNotifyFilter/MappingFilter:1.0"],),(),None)
ProxySupplier._d__get_lifetime_filter = ((),(omniORB.typeMapping["IDL:omg.org/CosNotifyFilter/MappingFilter:1.0"],),None)
ProxySupplier._d__set_lifetime_filter = ((omniORB.typeMapping["IDL:omg.org/CosNotifyFilter/MappingFilter:1.0"],),(),None)
ProxySupplier._d_obtain_offered_types = ((omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ObtainInfoMode:1.0"], ), (omniORB.typeMapping["IDL:omg.org/CosNotification/EventTypeSeq:1.0"], ), None)
ProxySupplier._d_validate_event_qos = ((omniORB.typeMapping["IDL:omg.org/CosNotification/QoSProperties:1.0"], ), (omniORB.typeMapping["IDL:omg.org/CosNotification/NamedPropertyRangeSeq:1.0"], ), {_0_CosNotification.UnsupportedQoS._NP_RepositoryId: _0_CosNotification._d_UnsupportedQoS})

# ProxySupplier object reference
class _objref_ProxySupplier (_0_CosNotification._objref_QoSAdmin, _0_CosNotifyFilter._objref_FilterAdmin):
    _NP_RepositoryId = ProxySupplier._NP_RepositoryId

    def __init__(self):
        _0_CosNotification._objref_QoSAdmin.__init__(self)
        _0_CosNotifyFilter._objref_FilterAdmin.__init__(self)

    def _get_MyType(self, *args):
        return _omnipy.invoke(self, "_get_MyType", _0_CosNotifyChannelAdmin.ProxySupplier._d__get_MyType, args)

    def _get_MyAdmin(self, *args):
        return _omnipy.invoke(self, "_get_MyAdmin", _0_CosNotifyChannelAdmin.ProxySupplier._d__get_MyAdmin, args)

    def _get_priority_filter(self, *args):
        return _omnipy.invoke(self, "_get_priority_filter", _0_CosNotifyChannelAdmin.ProxySupplier._d__get_priority_filter, args)

    def _set_priority_filter(self, *args):
        return _omnipy.invoke(self, "_set_priority_filter", _0_CosNotifyChannelAdmin.ProxySupplier._d__set_priority_filter, args)

    def _get_lifetime_filter(self, *args):
        return _omnipy.invoke(self, "_get_lifetime_filter", _0_CosNotifyChannelAdmin.ProxySupplier._d__get_lifetime_filter, args)

    def _set_lifetime_filter(self, *args):
        return _omnipy.invoke(self, "_set_lifetime_filter", _0_CosNotifyChannelAdmin.ProxySupplier._d__set_lifetime_filter, args)

    def obtain_offered_types(self, *args):
        return _omnipy.invoke(self, "obtain_offered_types", _0_CosNotifyChannelAdmin.ProxySupplier._d_obtain_offered_types, args)

    def validate_event_qos(self, *args):
        return _omnipy.invoke(self, "validate_event_qos", _0_CosNotifyChannelAdmin.ProxySupplier._d_validate_event_qos, args)

    __methods__ = ["_get_MyType", "_get_MyAdmin", "_get_priority_filter", "_set_priority_filter", "_get_lifetime_filter", "_set_lifetime_filter", "obtain_offered_types", "validate_event_qos"] + _0_CosNotification._objref_QoSAdmin.__methods__ + _0_CosNotifyFilter._objref_FilterAdmin.__methods__

omniORB.registerObjref(ProxySupplier._NP_RepositoryId, _objref_ProxySupplier)
_0_CosNotifyChannelAdmin._objref_ProxySupplier = _objref_ProxySupplier
del ProxySupplier, _objref_ProxySupplier

# ProxySupplier skeleton
__name__ = "CosNotifyChannelAdmin__POA"
class ProxySupplier (_0_CosNotification__POA.QoSAdmin, _0_CosNotifyFilter__POA.FilterAdmin):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin.ProxySupplier._NP_RepositoryId


    _omni_op_d = {"_get_MyType": _0_CosNotifyChannelAdmin.ProxySupplier._d__get_MyType, "_get_MyAdmin": _0_CosNotifyChannelAdmin.ProxySupplier._d__get_MyAdmin, "_get_priority_filter": _0_CosNotifyChannelAdmin.ProxySupplier._d__get_priority_filter, "_set_priority_filter": _0_CosNotifyChannelAdmin.ProxySupplier._d__set_priority_filter, "_get_lifetime_filter": _0_CosNotifyChannelAdmin.ProxySupplier._d__get_lifetime_filter, "_set_lifetime_filter": _0_CosNotifyChannelAdmin.ProxySupplier._d__set_lifetime_filter, "obtain_offered_types": _0_CosNotifyChannelAdmin.ProxySupplier._d_obtain_offered_types, "validate_event_qos": _0_CosNotifyChannelAdmin.ProxySupplier._d_validate_event_qos}
    _omni_op_d.update(_0_CosNotification__POA.QoSAdmin._omni_op_d)
    _omni_op_d.update(_0_CosNotifyFilter__POA.FilterAdmin._omni_op_d)

ProxySupplier._omni_skeleton = ProxySupplier
_0_CosNotifyChannelAdmin__POA.ProxySupplier = ProxySupplier
del ProxySupplier
__name__ = "CosNotifyChannelAdmin"

# interface ProxyPushConsumer
_0_CosNotifyChannelAdmin._d_ProxyPushConsumer = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/ProxyPushConsumer:1.0", "ProxyPushConsumer")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ProxyPushConsumer:1.0"] = _0_CosNotifyChannelAdmin._d_ProxyPushConsumer
_0_CosNotifyChannelAdmin.ProxyPushConsumer = omniORB.newEmptyClass()
class ProxyPushConsumer (_0_CosNotifyChannelAdmin.ProxyConsumer, _0_CosNotifyComm.PushConsumer):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin._d_ProxyPushConsumer[1]

    def __init__(self, *args, **kw):
        raise RuntimeError("Cannot construct objects of this type.")

    _nil = CORBA.Object._nil


_0_CosNotifyChannelAdmin.ProxyPushConsumer = ProxyPushConsumer
_0_CosNotifyChannelAdmin._tc_ProxyPushConsumer = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_ProxyPushConsumer)
omniORB.registerType(ProxyPushConsumer._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_ProxyPushConsumer, _0_CosNotifyChannelAdmin._tc_ProxyPushConsumer)

# ProxyPushConsumer operations and attributes
ProxyPushConsumer._d_connect_any_push_supplier = ((omniORB.typeMapping["IDL:omg.org/CosEventComm/PushSupplier:1.0"], ), (), {_0_CosEventChannelAdmin.AlreadyConnected._NP_RepositoryId: _0_CosEventChannelAdmin._d_AlreadyConnected})

# ProxyPushConsumer object reference
class _objref_ProxyPushConsumer (_0_CosNotifyChannelAdmin._objref_ProxyConsumer, _0_CosNotifyComm._objref_PushConsumer):
    _NP_RepositoryId = ProxyPushConsumer._NP_RepositoryId

    def __init__(self):
        _0_CosNotifyChannelAdmin._objref_ProxyConsumer.__init__(self)
        _0_CosNotifyComm._objref_PushConsumer.__init__(self)

    def connect_any_push_supplier(self, *args):
        return _omnipy.invoke(self, "connect_any_push_supplier", _0_CosNotifyChannelAdmin.ProxyPushConsumer._d_connect_any_push_supplier, args)

    __methods__ = ["connect_any_push_supplier"] + _0_CosNotifyChannelAdmin._objref_ProxyConsumer.__methods__ + _0_CosNotifyComm._objref_PushConsumer.__methods__

omniORB.registerObjref(ProxyPushConsumer._NP_RepositoryId, _objref_ProxyPushConsumer)
_0_CosNotifyChannelAdmin._objref_ProxyPushConsumer = _objref_ProxyPushConsumer
del ProxyPushConsumer, _objref_ProxyPushConsumer

# ProxyPushConsumer skeleton
__name__ = "CosNotifyChannelAdmin__POA"
class ProxyPushConsumer (_0_CosNotifyChannelAdmin__POA.ProxyConsumer, _0_CosNotifyComm__POA.PushConsumer):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin.ProxyPushConsumer._NP_RepositoryId


    _omni_op_d = {"connect_any_push_supplier": _0_CosNotifyChannelAdmin.ProxyPushConsumer._d_connect_any_push_supplier}
    _omni_op_d.update(_0_CosNotifyChannelAdmin__POA.ProxyConsumer._omni_op_d)
    _omni_op_d.update(_0_CosNotifyComm__POA.PushConsumer._omni_op_d)

ProxyPushConsumer._omni_skeleton = ProxyPushConsumer
_0_CosNotifyChannelAdmin__POA.ProxyPushConsumer = ProxyPushConsumer
del ProxyPushConsumer
__name__ = "CosNotifyChannelAdmin"

# interface StructuredProxyPushConsumer
_0_CosNotifyChannelAdmin._d_StructuredProxyPushConsumer = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/StructuredProxyPushConsumer:1.0", "StructuredProxyPushConsumer")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/StructuredProxyPushConsumer:1.0"] = _0_CosNotifyChannelAdmin._d_StructuredProxyPushConsumer
_0_CosNotifyChannelAdmin.StructuredProxyPushConsumer = omniORB.newEmptyClass()
class StructuredProxyPushConsumer (_0_CosNotifyChannelAdmin.ProxyConsumer, _0_CosNotifyComm.StructuredPushConsumer):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin._d_StructuredProxyPushConsumer[1]

    def __init__(self, *args, **kw):
        raise RuntimeError("Cannot construct objects of this type.")

    _nil = CORBA.Object._nil


_0_CosNotifyChannelAdmin.StructuredProxyPushConsumer = StructuredProxyPushConsumer
_0_CosNotifyChannelAdmin._tc_StructuredProxyPushConsumer = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_StructuredProxyPushConsumer)
omniORB.registerType(StructuredProxyPushConsumer._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_StructuredProxyPushConsumer, _0_CosNotifyChannelAdmin._tc_StructuredProxyPushConsumer)

# StructuredProxyPushConsumer operations and attributes
StructuredProxyPushConsumer._d_connect_structured_push_supplier = ((omniORB.typeMapping["IDL:omg.org/CosNotifyComm/StructuredPushSupplier:1.0"], ), (), {_0_CosEventChannelAdmin.AlreadyConnected._NP_RepositoryId: _0_CosEventChannelAdmin._d_AlreadyConnected})

# StructuredProxyPushConsumer object reference
class _objref_StructuredProxyPushConsumer (_0_CosNotifyChannelAdmin._objref_ProxyConsumer, _0_CosNotifyComm._objref_StructuredPushConsumer):
    _NP_RepositoryId = StructuredProxyPushConsumer._NP_RepositoryId

    def __init__(self):
        _0_CosNotifyChannelAdmin._objref_ProxyConsumer.__init__(self)
        _0_CosNotifyComm._objref_StructuredPushConsumer.__init__(self)

    def connect_structured_push_supplier(self, *args):
        return _omnipy.invoke(self, "connect_structured_push_supplier", _0_CosNotifyChannelAdmin.StructuredProxyPushConsumer._d_connect_structured_push_supplier, args)

    __methods__ = ["connect_structured_push_supplier"] + _0_CosNotifyChannelAdmin._objref_ProxyConsumer.__methods__ + _0_CosNotifyComm._objref_StructuredPushConsumer.__methods__

omniORB.registerObjref(StructuredProxyPushConsumer._NP_RepositoryId, _objref_StructuredProxyPushConsumer)
_0_CosNotifyChannelAdmin._objref_StructuredProxyPushConsumer = _objref_StructuredProxyPushConsumer
del StructuredProxyPushConsumer, _objref_StructuredProxyPushConsumer

# StructuredProxyPushConsumer skeleton
__name__ = "CosNotifyChannelAdmin__POA"
class StructuredProxyPushConsumer (_0_CosNotifyChannelAdmin__POA.ProxyConsumer, _0_CosNotifyComm__POA.StructuredPushConsumer):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin.StructuredProxyPushConsumer._NP_RepositoryId


    _omni_op_d = {"connect_structured_push_supplier": _0_CosNotifyChannelAdmin.StructuredProxyPushConsumer._d_connect_structured_push_supplier}
    _omni_op_d.update(_0_CosNotifyChannelAdmin__POA.ProxyConsumer._omni_op_d)
    _omni_op_d.update(_0_CosNotifyComm__POA.StructuredPushConsumer._omni_op_d)

StructuredProxyPushConsumer._omni_skeleton = StructuredProxyPushConsumer
_0_CosNotifyChannelAdmin__POA.StructuredProxyPushConsumer = StructuredProxyPushConsumer
del StructuredProxyPushConsumer
__name__ = "CosNotifyChannelAdmin"

# interface SequenceProxyPushConsumer
_0_CosNotifyChannelAdmin._d_SequenceProxyPushConsumer = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/SequenceProxyPushConsumer:1.0", "SequenceProxyPushConsumer")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/SequenceProxyPushConsumer:1.0"] = _0_CosNotifyChannelAdmin._d_SequenceProxyPushConsumer
_0_CosNotifyChannelAdmin.SequenceProxyPushConsumer = omniORB.newEmptyClass()
class SequenceProxyPushConsumer (_0_CosNotifyChannelAdmin.ProxyConsumer, _0_CosNotifyComm.SequencePushConsumer):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin._d_SequenceProxyPushConsumer[1]

    def __init__(self, *args, **kw):
        raise RuntimeError("Cannot construct objects of this type.")

    _nil = CORBA.Object._nil


_0_CosNotifyChannelAdmin.SequenceProxyPushConsumer = SequenceProxyPushConsumer
_0_CosNotifyChannelAdmin._tc_SequenceProxyPushConsumer = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_SequenceProxyPushConsumer)
omniORB.registerType(SequenceProxyPushConsumer._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_SequenceProxyPushConsumer, _0_CosNotifyChannelAdmin._tc_SequenceProxyPushConsumer)

# SequenceProxyPushConsumer operations and attributes
SequenceProxyPushConsumer._d_connect_sequence_push_supplier = ((omniORB.typeMapping["IDL:omg.org/CosNotifyComm/SequencePushSupplier:1.0"], ), (), {_0_CosEventChannelAdmin.AlreadyConnected._NP_RepositoryId: _0_CosEventChannelAdmin._d_AlreadyConnected})

# SequenceProxyPushConsumer object reference
class _objref_SequenceProxyPushConsumer (_0_CosNotifyChannelAdmin._objref_ProxyConsumer, _0_CosNotifyComm._objref_SequencePushConsumer):
    _NP_RepositoryId = SequenceProxyPushConsumer._NP_RepositoryId

    def __init__(self):
        _0_CosNotifyChannelAdmin._objref_ProxyConsumer.__init__(self)
        _0_CosNotifyComm._objref_SequencePushConsumer.__init__(self)

    def connect_sequence_push_supplier(self, *args):
        return _omnipy.invoke(self, "connect_sequence_push_supplier", _0_CosNotifyChannelAdmin.SequenceProxyPushConsumer._d_connect_sequence_push_supplier, args)

    __methods__ = ["connect_sequence_push_supplier"] + _0_CosNotifyChannelAdmin._objref_ProxyConsumer.__methods__ + _0_CosNotifyComm._objref_SequencePushConsumer.__methods__

omniORB.registerObjref(SequenceProxyPushConsumer._NP_RepositoryId, _objref_SequenceProxyPushConsumer)
_0_CosNotifyChannelAdmin._objref_SequenceProxyPushConsumer = _objref_SequenceProxyPushConsumer
del SequenceProxyPushConsumer, _objref_SequenceProxyPushConsumer

# SequenceProxyPushConsumer skeleton
__name__ = "CosNotifyChannelAdmin__POA"
class SequenceProxyPushConsumer (_0_CosNotifyChannelAdmin__POA.ProxyConsumer, _0_CosNotifyComm__POA.SequencePushConsumer):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin.SequenceProxyPushConsumer._NP_RepositoryId


    _omni_op_d = {"connect_sequence_push_supplier": _0_CosNotifyChannelAdmin.SequenceProxyPushConsumer._d_connect_sequence_push_supplier}
    _omni_op_d.update(_0_CosNotifyChannelAdmin__POA.ProxyConsumer._omni_op_d)
    _omni_op_d.update(_0_CosNotifyComm__POA.SequencePushConsumer._omni_op_d)

SequenceProxyPushConsumer._omni_skeleton = SequenceProxyPushConsumer
_0_CosNotifyChannelAdmin__POA.SequenceProxyPushConsumer = SequenceProxyPushConsumer
del SequenceProxyPushConsumer
__name__ = "CosNotifyChannelAdmin"

# interface ProxyPullSupplier
_0_CosNotifyChannelAdmin._d_ProxyPullSupplier = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/ProxyPullSupplier:1.0", "ProxyPullSupplier")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/ProxyPullSupplier:1.0"] = _0_CosNotifyChannelAdmin._d_ProxyPullSupplier
_0_CosNotifyChannelAdmin.ProxyPullSupplier = omniORB.newEmptyClass()
class ProxyPullSupplier (_0_CosNotifyChannelAdmin.ProxySupplier, _0_CosNotifyComm.PullSupplier):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin._d_ProxyPullSupplier[1]

    def __init__(self, *args, **kw):
        raise RuntimeError("Cannot construct objects of this type.")

    _nil = CORBA.Object._nil


_0_CosNotifyChannelAdmin.ProxyPullSupplier = ProxyPullSupplier
_0_CosNotifyChannelAdmin._tc_ProxyPullSupplier = omniORB.tcInternal.createTypeCode(_0_CosNotifyChannelAdmin._d_ProxyPullSupplier)
omniORB.registerType(ProxyPullSupplier._NP_RepositoryId, _0_CosNotifyChannelAdmin._d_ProxyPullSupplier, _0_CosNotifyChannelAdmin._tc_ProxyPullSupplier)

# ProxyPullSupplier operations and attributes
ProxyPullSupplier._d_connect_any_pull_consumer = ((omniORB.typeMapping["IDL:omg.org/CosEventComm/PullConsumer:1.0"], ), (), {_0_CosEventChannelAdmin.AlreadyConnected._NP_RepositoryId: _0_CosEventChannelAdmin._d_AlreadyConnected})

# ProxyPullSupplier object reference
class _objref_ProxyPullSupplier (_0_CosNotifyChannelAdmin._objref_ProxySupplier, _0_CosNotifyComm._objref_PullSupplier):
    _NP_RepositoryId = ProxyPullSupplier._NP_RepositoryId

    def __init__(self):
        _0_CosNotifyChannelAdmin._objref_ProxySupplier.__init__(self)
        _0_CosNotifyComm._objref_PullSupplier.__init__(self)

    def connect_any_pull_consumer(self, *args):
        return _omnipy.invoke(self, "connect_any_pull_consumer", _0_CosNotifyChannelAdmin.ProxyPullSupplier._d_connect_any_pull_consumer, args)

    __methods__ = ["connect_any_pull_consumer"] + _0_CosNotifyChannelAdmin._objref_ProxySupplier.__methods__ + _0_CosNotifyComm._objref_PullSupplier.__methods__

omniORB.registerObjref(ProxyPullSupplier._NP_RepositoryId, _objref_ProxyPullSupplier)
_0_CosNotifyChannelAdmin._objref_ProxyPullSupplier = _objref_ProxyPullSupplier
del ProxyPullSupplier, _objref_ProxyPullSupplier

# ProxyPullSupplier skeleton
__name__ = "CosNotifyChannelAdmin__POA"
class ProxyPullSupplier (_0_CosNotifyChannelAdmin__POA.ProxySupplier, _0_CosNotifyComm__POA.PullSupplier):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin.ProxyPullSupplier._NP_RepositoryId


    _omni_op_d = {"connect_any_pull_consumer": _0_CosNotifyChannelAdmin.ProxyPullSupplier._d_connect_any_pull_consumer}
    _omni_op_d.update(_0_CosNotifyChannelAdmin__POA.ProxySupplier._omni_op_d)
    _omni_op_d.update(_0_CosNotifyComm__POA.PullSupplier._omni_op_d)

ProxyPullSupplier._omni_skeleton = ProxyPullSupplier
_0_CosNotifyChannelAdmin__POA.ProxyPullSupplier = ProxyPullSupplier
del ProxyPullSupplier
__name__ = "CosNotifyChannelAdmin"

# interface StructuredProxyPullSupplier
_0_CosNotifyChannelAdmin._d_StructuredProxyPullSupplier = (omniORB.tcInternal.tv_objref, "IDL:omg.org/CosNotifyChannelAdmin/StructuredProxyPullSupplier:1.0", "StructuredProxyPullSupplier")
omniORB.typeMapping["IDL:omg.org/CosNotifyChannelAdmin/StructuredProxyPullSupplier:1.0"] = _0_CosNotifyChannelAdmin._d_StructuredProxyPullSupplier
_0_CosNotifyChannelAdmin.StructuredProxyPullSupplier = omniORB.newEmptyClass()

class StructuredProxyPullSupplier (_0_CosNotifyChannelAdmin.ProxySupplier, _0_CosNotifyComm.StructuredPullSupplier):
    _NP_RepositoryId = _0_CosNotifyChannelAdmin._d_StructuredProxyPullSupplier[1]

    def __init__(self, *args, **kw):
        raise RuntimeError("Cannot construct objects of this type.")

    _nil = CORBA.Object._nil


# StructuredProxyPullSupplier operations and attributes
StructuredProxyPullSupplier._d_connect_structured_pull_consumer = ((omniORB.typeMapping["IDL:omg.org/CosNotifyComm/StructuredPullConsumer:1.0"], ), (), {_0_CosEventChannelAdmin.AlreadyConnected._NP_RepositoryId: _0_CosEventChannelAdmin._d_AlreadyConnected})