Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
   package org.omg.CosNotifyChannelAdmin;


Generated from IDL interface "SequenceProxyPushConsumer".

Author(s):
JacORB IDL compiler V 3.5
Version:
generated at 11-Jul-2014 12:35:20
   
  
  {
Serial version UID.
  
  	private static final long serialVersionUID = 1L;
  	private String[] ids = {"IDL:omg.org/CosNotifyChannelAdmin/SequenceProxyPushConsumer:1.0","IDL:omg.org/CosNotifyComm/NotifyPublish:1.0","IDL:omg.org/CosNotifyComm/SequencePushConsumer:1.0","IDL:omg.org/CosNotifyFilter/FilterAdmin:1.0","IDL:omg.org/CosNotification/QoSAdmin:1.0","IDL:omg.org/CosNotifyChannelAdmin/ProxyConsumer:1.0"};
  	public String[] _ids()
  	{
  		return ;
  	}
  
  	{
  		while(true)
  		{
  			if(! this._is_local())
  			{
  				org.omg.CORBA.portable.InputStream _is = null;
  				org.omg.CORBA.portable.OutputStream _os = null;
  				try
  				{
  					_os = _request("_get_MyType",true);
  					_is = _invoke(_os);
  					return org.omg.CosNotifyChannelAdmin.ProxyTypeHelper.read(_is);
  				}
  					{
  						continue;
  					}
  				{
  					String _id = _ax.getId();
  					try
  					{
  						_ax.getInputStream().close();
  					}
  					catch (java.io.IOException e)
  					{
  						throw new RuntimeException("Unexpected exception " + e.toString() );
  					}
  						throw new RuntimeException("Unexpected exception " + _id );
  				}
  				finally
  				{
  					if (_os != null)
  					{
  						try
  						{
  							_os.close();
  						}
  						catch (java.io.IOException e)
  						{
  							throw new RuntimeException("Unexpected exception " + e.toString() );
  						}
  					}
  					this._releaseReply(_is);
  				}
  			}
  
  			else
  			{
  				if_so == null )
  					continue;
  				try
  				{
  					_result = _localServant.MyType();
  					if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
  						return _result;
  				}
  				catch (RuntimeException re
  				{
  					if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
  					throw re;
  				}
  				catch (java.lang.Error err
  				{
  					if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
  					throw err;
  				}
  				finally
  				{
 				}
 			}
 
 		}
 
 	}
 
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"set_qos"true);
 					org.omg.CosNotification.PropertySeqHelper.write(_os,qos);
 					_is = _invoke(_os);
 					return;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 						if_id.equals("IDL:omg.org/CosNotification/UnsupportedQoS:1.0"))
 						{
 							throw org.omg.CosNotification.UnsupportedQoSHelper.read(_ax.getInputStream());
 						}
 						else 
 						{
 							throw new RuntimeException("Unexpected exception " + _id );
 						}
 					}
 					finally
 					{
 						try
 						{
 						}
 						catch (java.io.IOException e)
 						{
 							throw new RuntimeException("Unexpected exception " + e.toString() );
 						}
 					}
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			if_so == null )
 				continue;
 			try
 			{
 				_localServant.set_qos(qos);
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return;
 			}
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw ex;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"disconnect_sequence_push_consumer"true);
 					_is = _invoke(_os);
 					return;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 					throw new RuntimeException("Unexpected exception " + _id );
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"disconnect_sequence_push_consumer" );
 			if_so == null )
 				continue;
 			try
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"validate_event_qos"true);
 					org.omg.CosNotification.PropertySeqHelper.write(_os,required_qos);
 					_is = _invoke(_os);
 					available_qos.value = org.omg.CosNotification.NamedPropertyRangeSeqHelper.read(_is);
 					return;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 						if_id.equals("IDL:omg.org/CosNotification/UnsupportedQoS:1.0"))
 						{
 							throw org.omg.CosNotification.UnsupportedQoSHelper.read(_ax.getInputStream());
 						}
 						else 
 						{
 							throw new RuntimeException("Unexpected exception " + _id );
 						}
 					}
 					finally
 					{
 						try
 						{
 						}
 						catch (java.io.IOException e)
 						{
 							throw new RuntimeException("Unexpected exception " + e.toString() );
 						}
 					}
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"validate_event_qos" );
 			if_so == null )
 				continue;
 			try
 			{
 				_localServant.validate_event_qos(required_qos,available_qos);
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return;
 			}
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw ex;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"connect_sequence_push_supplier"true);
 					org.omg.CosNotifyComm.SequencePushSupplierHelper.write(_os,push_supplier);
 					_is = _invoke(_os);
 					return;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 						if_id.equals("IDL:omg.org/CosEventChannelAdmin/AlreadyConnected:1.0"))
 						{
 							throw org.omg.CosEventChannelAdmin.AlreadyConnectedHelper.read(_ax.getInputStream());
 						}
 						else 
 						{
 							throw new RuntimeException("Unexpected exception " + _id );
 						}
 					}
 					finally
 					{
 						try
 						{
 						}
 						catch (java.io.IOException e)
 						{
 							throw new RuntimeException("Unexpected exception " + e.toString() );
 						}
 					}
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"connect_sequence_push_supplier" );
 			if_so == null )
 				continue;
 			try
 			{
 				_localServant.connect_sequence_push_supplier(push_supplier);
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return;
 			}
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw ex;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"offer_change"true);
 					org.omg.CosNotification.EventTypeSeqHelper.write(_os,added);
 					org.omg.CosNotification.EventTypeSeqHelper.write(_os,removed);
 					_is = _invoke(_os);
 					return;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 						if_id.equals("IDL:omg.org/CosNotifyComm/InvalidEventType:1.0"))
 						{
 							throw org.omg.CosNotifyComm.InvalidEventTypeHelper.read(_ax.getInputStream());
 						}
 						else 
 						{
 							throw new RuntimeException("Unexpected exception " + _id );
 						}
 					}
 					finally
 					{
 						try
 						{
 						}
 						catch (java.io.IOException e)
 						{
 							throw new RuntimeException("Unexpected exception " + e.toString() );
 						}
 					}
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			if_so == null )
 				continue;
 			try
 			{
 				_localServant.offer_change(added,removed);
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return;
 			}
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw ex;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"obtain_subscription_types"true);
 					org.omg.CosNotifyChannelAdmin.ObtainInfoModeHelper.write(_os,mode);
 					_is = _invoke(_os);
 					org.omg.CosNotification.EventType[] _result = org.omg.CosNotification.EventTypeSeqHelper.read(_is);
 					return _result;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 					throw new RuntimeException("Unexpected exception " + _id );
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"obtain_subscription_types" );
 			if_so == null )
 				continue;
 			try
 			{
 				_result = _localServant.obtain_subscription_types(mode);
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return _result;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	public int add_filter(org.omg.CosNotifyFilter.Filter new_filter)
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"add_filter"true);
 					org.omg.CosNotifyFilter.FilterHelper.write(_os,new_filter);
 					_is = _invoke(_os);
 					int _result = _is.read_long();
 					return _result;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 					throw new RuntimeException("Unexpected exception " + _id );
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			if_so == null )
 				continue;
 			int _result;
 			try
 			{
 				_result = _localServant.add_filter(new_filter);
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return _result;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	public void remove_filter(int filterthrows org.omg.CosNotifyFilter.FilterNotFound
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"remove_filter"true);
 					_os.write_long(filter);
 					_is = _invoke(_os);
 					return;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 						if_id.equals("IDL:omg.org/CosNotifyFilter/FilterNotFound:1.0"))
 						{
 							throw org.omg.CosNotifyFilter.FilterNotFoundHelper.read(_ax.getInputStream());
 						}
 						else 
 						{
 							throw new RuntimeException("Unexpected exception " + _id );
 						}
 					}
 					finally
 					{
 						try
 						{
 						}
 						catch (java.io.IOException e)
 						{
 							throw new RuntimeException("Unexpected exception " + e.toString() );
 						}
 					}
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"remove_filter" );
 			if_so == null )
 				continue;
 			try
 			{
 				_localServant.remove_filter(filter);
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return;
 			}
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw ex;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"push_structured_events"true);
 					org.omg.CosNotification.EventBatchHelper.write(_os,notifications);
 					_is = _invoke(_os);
 					return;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 						if_id.equals("IDL:omg.org/CosEventComm/Disconnected:1.0"))
 						{
 							throw org.omg.CosEventComm.DisconnectedHelper.read(_ax.getInputStream());
 						}
 						else 
 						{
 							throw new RuntimeException("Unexpected exception " + _id );
 						}
 					}
 					finally
 					{
 						try
 						{
 						}
 						catch (java.io.IOException e)
 						{
 							throw new RuntimeException("Unexpected exception " + e.toString() );
 						}
 					}
 			}
 			finally
 			{
 				if (_os != null)
 				{
 					try
 					{
 						_os.close();
 					}
 					catch (java.io.IOException e)
 					{
 						throw new RuntimeException("Unexpected exception " + e.toString() );
 					}
 				}
 				this._releaseReply(_is);
 			}
 		}
 		else
 		{
 			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"push_structured_events" );
 			if_so == null )
 				continue;
 			try
 			{
 				_localServant.push_structured_events(notifications);
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				return;
 			}
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw ex;
 			}
 			catch (RuntimeException re
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw re;
 			}
 			catch (java.lang.Error err
 			{
 				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
 				throw err;
 			}
 			finally
 			{
 			}
 		}
 
 		}
 
 	}
 
 	public void remove_all_filters()
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"remove_all_filters"true);
 					_is = _invoke(_os);
 					return;
 				}
 					{
 						continue;
 					}
 				{
 					String _id = _ax.getId();
 					try
 					{
 					}
 					catch (java.io.IOException e)
						throw new RuntimeException("Unexpected exception " + e.toString() );
					throw new RuntimeException("Unexpected exception " + _id );
			finally
				if (_os != null)
					try
						_os.close();
					catch (java.io.IOException e)
						throw new RuntimeException("Unexpected exception " + e.toString() );
				this._releaseReply(_is);
		else
			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"remove_all_filters" );
			if_so == null )
				continue;
			try
				_localServant.remove_all_filters();
				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
				return;
			catch (RuntimeException re
				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
				throw re;
			catch (java.lang.Error err
				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
				throw err;
			finally
	public int[] get_all_filters()
		while(true)
			if(! this._is_local())
				try
					_os = _request"get_all_filters"true);
					_is = _invoke(_os);
					int[] _result = org.omg.CosNotifyFilter.FilterIDSeqHelper.read(_is);
					return _result;
						continue;
					String _id = _ax.getId();
					try
					catch (java.io.IOException e)
						throw new RuntimeException("Unexpected exception " + e.toString() );
					throw new RuntimeException("Unexpected exception " + _id );
			finally
				if (_os != null)
					try
						_os.close();
					catch (java.io.IOException e)
						throw new RuntimeException("Unexpected exception " + e.toString() );
				this._releaseReply(_is);
		else
			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"get_all_filters" );
			if_so == null )
				continue;
			int[] _result;
			try
				_result = _localServant.get_all_filters();
				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt