// CosEventComm Module, CORBAservices p 4-8, Event Service V1.0 3/94
#pragma prefix "omg.org"

module CosEventComm {

	exception Disconnected{};

	interface PushConsumer {
		void push (in any data) raises(Disconnected);
		void disconnect_push_consumer(); 
	};

    interface PushSupplier {
		void disconnect_push_supplier();
	};

	interface PullSupplier {
		any pull () raises(Disconnected);
		any try_pull (out boolean has_event) 
			raises(Disconnected);
		void	 disconnect_pull_supplier(); 
	};

	interface PullConsumer {
		void disconnect_pull_consumer();
	};

};

//CosEventChannelAdmin Module, p 4-15 CORBAservices, Event Service V1.0, 3/94

//#include "CosEventComm.idl"

module CosEventChannelAdmin {

 	exception AlreadyConnected {};
	exception TypeError {};

	interface ProxyPushConsumer: CosEventComm::PushConsumer {
		void connect_push_supplier(
			in CosEventComm::PushSupplier
			push_supplier)
			raises(AlreadyConnected);
	};

	interface ProxyPullSupplier: CosEventComm::PullSupplier {
		void connect_pull_consumer(
			in CosEventComm::PullConsumer
			pull_consumer)
			raises(AlreadyConnected);
	};

	interface ProxyPullConsumer: CosEventComm::PullConsumer {
		void connect_pull_supplier(
			in CosEventComm::PullSupplier
			pull_supplier)
			raises(AlreadyConnected,TypeError);
	};

	interface ProxyPushSupplier: CosEventComm::PushSupplier {
		void connect_push_consumer(
			in CosEventComm::PushConsumer
			push_consumer)
			raises(AlreadyConnected, TypeError);
	};


	interface ConsumerAdmin {
		ProxyPushSupplier obtain_push_supplier();
		ProxyPullSupplier obtain_pull_supplier();
	};

	interface SupplierAdmin {
		ProxyPushConsumer obtain_push_consumer();
		ProxyPullConsumer obtain_pull_consumer();
	};

	interface EventChannel {
		ConsumerAdmin for_consumers();
		SupplierAdmin for_suppliers();
		void destroy();
	};

};


//CosTyped Event Module, p 4-22 CORBAservices, Event Service V1.0, 3/94

//#include "CosEventComm.idl" 

module CosTypedEventComm {

	interface TypedPushConsumer : CosEventComm::PushConsumer {
		Object get_typed_consumer(); 
	};

	interface TypedPullSupplier : CosEventComm::PullSupplier { 		 
		Object get_typed_supplier();
	};

}; 

//CosTypedEventChannelAdmin Module, p 4- 25 CORBAservices, Event Service V1.0, 3/94

//#include "CosEventChannel.idl" 
//#include "CosTypedEventComm.idl"
module CosTypedEventChannelAdmin { 	 
	exception InterfaceNotSupported {}; 
	exception NoSuchImplementation {}; 
	typedef string Key; 

	interface TypedProxyPushConsumer : 	
			CosEventChannelAdmin::ProxyPushConsumer, 	
			CosTypedEventComm::TypedPushConsumer  { }; 

	interface TypedProxyPullSupplier :
 			CosEventChannelAdmin::ProxyPullSupplier, 	
			CosTypedEventComm::TypedPullSupplier { }; 

	interface TypedSupplierAdmin : 			
			CosEventChannelAdmin::SupplierAdmin { 
		TypedProxyPushConsumer obtain_typed_push_consumer(
 				in Key supported_interface) 		    
			raises(InterfaceNotSupported); 
		CosEventChannelAdmin::ProxyPullConsumer obtain_typed_pull_consumer ( 
				in Key uses_interface) 		   
			 raises(NoSuchImplementation); 
	}; 

	interface TypedConsumerAdmin : 
			CosEventChannelAdmin::ConsumerAdmin { 
		TypedProxyPullSupplier obtain_typed_pull_supplier( 
				in Key supported_interface) 		    
			raises (InterfaceNotSupported); 
		CosEventChannelAdmin::ProxyPushSupplier obtain_typed_push_supplier( 			
				in Key uses_interface) 		    
			raises(NoSuchImplementation); 
	}; 

	interface TypedEventChannel { 
		TypedConsumerAdmin for_consumers(); 		
		TypedSupplierAdmin for_suppliers();                
		void destroy (); 
	}; 
};