Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
   package org.omg.dds;


Generated from IDL interface "DataReader".

Author(s):
JacORB IDL compiler V 3.5
Version:
generated at 11-Jul-2014 12:35:22
   
  
  public class _DataReaderStub
  	implements org.omg.dds.DataReader
  {
Serial version UID.
  
  	private static final long serialVersionUID = 1L;
  	private String[] ids = {"IDL:omg.org/dds/DataReader:1.0","IDL:omg.org/dds/Entity:1.0"};
  	public String[] _ids()
  	{
  		return ;
  	}
  
  	public final static java.lang.Class _opsClass = org.omg.dds.DataReaderOperations.class;
  	public int set_listener(org.omg.dds.DataReaderListener a_listenerint mask)
  	{
  		while(true)
  		{
  			if(! this._is_local())
  			{
  				org.omg.CORBA.portable.InputStream _is = null;
  				org.omg.CORBA.portable.OutputStream _os = null;
  				try
  				{
  					_os = _request"set_listener"true);
  					org.omg.dds.DataReaderListenerHelper.write(_os,a_listener);
  					_os.write_ulong(mask);
  					_is = _invoke(_os);
  					int _result = _is.read_long();
  					return _result;
  				}
  					{
  						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
  		{
  			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"set_listener" );
  			if_so == null )
  				continue;
  			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
  			int _result;
  			try
  			{
  				_result = _localServant.set_listener(a_listener,mask);
  				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 get_qos(org.omg.dds.DataReaderQosHolder qos)
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"get_qos"true);
 					org.omg.dds.DataReaderQosHelper.write(_os,qos.value);
 					_is = _invoke(_os);
 					qos.value = org.omg.dds.DataReaderQosHelper.read(_is);
 					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
 		{
 			if_so == null )
 				continue;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			try
 			{
 				_localServant.get_qos(qos);
 				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_matched_publications(org.omg.dds.InstanceHandleSeqHolder publication_handles)
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"get_matched_publications"true);
 					org.omg.dds.InstanceHandleSeqHelper.write(_os,publication_handles.value);
 					_is = _invoke(_os);
 					int _result = _is.read_long();
 					publication_handles.value = org.omg.dds.InstanceHandleSeqHelper.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_matched_publications" );
 			if_so == null )
 				continue;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			int _result;
 			try
 			{
 				_result = _localServant.get_matched_publications(publication_handles);
 				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"get_statuscondition"true);
 					_is = _invoke(_os);
 					org.omg.dds.StatusCondition _result = org.omg.dds.StatusConditionHelper.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_statuscondition" );
 			if_so == null )
 				continue;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			try
 			{
 				_result = _localServant.get_statuscondition();
 				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 set_qos(org.omg.dds.DataReaderQos qos)
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"set_qos"true);
 					org.omg.dds.DataReaderQosHelper.write(_os,qos);
 					_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;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			int _result;
 			try
 			{
 				_result = _localServant.set_qos(qos);
 				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 enable()
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"enable"true);
 					_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;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			int _result;
 			try
 			{
 				_result = _localServant.enable();
 				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"get_topicdescription"true);
 					_is = _invoke(_os);
 					org.omg.dds.TopicDescription _result = org.omg.dds.TopicDescriptionHelper.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_topicdescription" );
 			if_so == null )
 				continue;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			try
 			{
 				_result = _localServant.get_topicdescription();
 				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"get_liveliness_changed_status"true);
 					_is = _invoke(_os);
 					org.omg.dds.LivelinessChangedStatus _result = org.omg.dds.LivelinessChangedStatusHelper.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_liveliness_changed_status" );
 			if_so == null )
 				continue;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			try
 			{
 				_result = _localServant.get_liveliness_changed_status();
 				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"get_requested_incompatible_qos_status"true);
 					_is = _invoke(_os);
 					org.omg.dds.RequestedIncompatibleQosStatus _result = org.omg.dds.RequestedIncompatibleQosStatusHelper.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_requested_incompatible_qos_status" );
 			if_so == null )
 				continue;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			try
 			{
 				_result = _localServant.get_requested_incompatible_qos_status();
 				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 wait_for_historical_data(org.omg.dds.Duration_t max_wait)
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"wait_for_historical_data"true);
 					org.omg.dds.Duration_tHelper.write(_os,max_wait);
 					_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
 		{
 			org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke"wait_for_historical_data" );
 			if_so == null )
 				continue;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			int _result;
 			try
 			{
 				_result = _localServant.wait_for_historical_data(max_wait);
 				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 org.omg.dds.QueryCondition create_querycondition(int sample_statesint view_statesint instance_statesjava.lang.String query_expressionjava.lang.String[] query_parameters)
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"create_querycondition"true);
 					_os.write_ulong(sample_states);
 					_os.write_ulong(view_states);
 					_os.write_ulong(instance_states);
 					java.lang.String tmpResult29 = query_expression;
 _os.write_stringtmpResult29 );
 					org.omg.dds.StringSeqHelper.write(_os,query_parameters);
 					_is = _invoke(_os);
 					org.omg.dds.QueryCondition _result = org.omg.dds.QueryConditionHelper.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"create_querycondition" );
 			if_so == null )
 				continue;
 			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
 			try
 			{
 				_result = _localServant.create_querycondition(sample_states,view_states,instance_states,query_expression,query_parameters);
 				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 org.omg.dds.ReadCondition create_readcondition(int sample_statesint view_statesint instance_states)
 	{
 		while(true)
 		{
 			if(! this._is_local())
 			{
 				org.omg.CORBA.portable.InputStream _is = null;
 				try
 				{
 					_os = _request"create_readcondition"true);
 					_os.write_ulong(sample_states);
 					_os.write_ulong(view_states);
 					_os.write_ulong(instance_states);
 					_is = _invoke(_os);
 					org.omg.dds.ReadCondition _result = org.omg.dds.ReadConditionHelper.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"create_readcondition" );
			if_so == null )
				continue;
			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
			try
				_result = _localServant.create_readcondition(sample_states,view_states,instance_states);
				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 get_status_changes()
		while(true)
			if(! this._is_local())
				try
					_os = _request"get_status_changes"true);
					_is = _invoke(_os);
					int _result = _is.read_ulong();
					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_status_changes" );
			if_so == null )
				continue;
			DataReaderOperations _localServant = (DataReaderOperations)_so.servant;
			int _result;
			try
				_result = _localServant.get_status_changes();
				if ( _so instanceof org.omg.CORBA.portable.ServantObjectExt
				return _result;
			catch (RuntimeException re
				if ( _so instanceof org.omg.CORBA.portable.