Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package org.omg.dds;


Generated from IDL interface "Subscriber".

Author(s):
JacORB IDL compiler V 3.5
Version:
generated at 11-Jul-2014 12:35:22
  
 
 public abstract class SubscriberPOA
 {
 	static private final java.util.HashMap<String,Integerm_opsHash = new java.util.HashMap<String,Integer>();
 	static
 	{
 		.put ( "set_default_datareader_qos", Integer.valueOf(0));
 		.put ( "begin_access", Integer.valueOf(1));
 		.put ( "get_statuscondition", Integer.valueOf(2));
 		.put ( "get_default_datareader_qos", Integer.valueOf(3));
 		.put ( "get_datareaders", Integer.valueOf(4));
 		.put ( "enable", Integer.valueOf(5));
 		.put ( "notify_datareaders", Integer.valueOf(6));
 		.put ( "create_datareader", Integer.valueOf(7));
 		.put ( "end_access", Integer.valueOf(8));
 		.put ( "get_status_changes", Integer.valueOf(9));
 		.put ( "get_listener", Integer.valueOf(10));
 		.put ( "copy_from_topic_qos", Integer.valueOf(11));
 		.put ( "get_participant", Integer.valueOf(12));
 		.put ( "get_qos", Integer.valueOf(13));
 		.put ( "delete_contained_entities", Integer.valueOf(14));
 		.put ( "delete_datareader", Integer.valueOf(15));
 		.put ( "lookup_datareader", Integer.valueOf(16));
 		.put ( "set_listener", Integer.valueOf(17));
 		.put ( "set_qos", Integer.valueOf(18));
 	}
 	private String[] ids = {"IDL:omg.org/dds/Subscriber:1.0","IDL:omg.org/dds/Entity:1.0"};
 	public org.omg.dds.Subscriber _this()
 	{
 		org.omg.CORBA.Object __o = _this_object() ;
 		org.omg.dds.Subscriber __r = org.omg.dds.SubscriberHelper.narrow(__o);
 		return __r;
 	}
 	{
 		org.omg.CORBA.Object __o = _this_object(orb) ;
 		org.omg.dds.Subscriber __r = org.omg.dds.SubscriberHelper.narrow(__o);
 		return __r;
 	}
 	{
 		org.omg.CORBA.portable.OutputStream _out = null;
 		// do something
 		// quick lookup of operation
 		java.lang.Integer opsIndex = (java.lang.Integer).get ( method );
 		if ( null == opsIndex )
 			throw new org.omg.CORBA.BAD_OPERATION(method + " not found");
 		switch ( opsIndex.intValue() )
 		{
 			case 0: // set_default_datareader_qos
 			{
 				org.omg.dds.DataReaderQos _arg0=org.omg.dds.DataReaderQosHelper.read(_input);
 				_out = handler.createReply();
 				break;
 			}
 			case 1: // begin_access
 			{
 				_out = handler.createReply();
 				break;
 			}
 			case 2: // get_statuscondition
 			{
 				_out = handler.createReply();
 				org.omg.dds.StatusConditionHelper.write(_out,get_statuscondition());
 				break;
 			}
 			case 3: // get_default_datareader_qos
 			{
 				_out = handler.createReply();
 				org.omg.dds.DataReaderQosHelper.write(_out,_arg0.value);
 				break;
 			}
 			case 4: // get_datareaders
 			{
 				int _arg1=_input.read_ulong();
 				int _arg2=_input.read_ulong();
 				int _arg3=_input.read_ulong();
 				_out = handler.createReply();
 				_out.write_long(get_datareaders(_arg0,_arg1,_arg2,_arg3));
 				org.omg.dds.DataReaderSeqHelper.write(_out,_arg0.value);
 				break;
 			}
			case 5: // enable
			{
				_out = handler.createReply();
				break;
			}
			case 6: // notify_datareaders
			{
				_out = handler.createReply();
				break;
			}
			case 7: // create_datareader
			{
				org.omg.dds.TopicDescription _arg0=org.omg.dds.TopicDescriptionHelper.read(_input);
				org.omg.dds.DataReaderQos _arg1=org.omg.dds.DataReaderQosHelper.read(_input);
				org.omg.dds.DataReaderListener _arg2=org.omg.dds.DataReaderListenerHelper.read(_input);
				_out = handler.createReply();
				org.omg.dds.DataReaderHelper.write(_out,create_datareader(_arg0,_arg1,_arg2));
				break;
			}
			case 8: // end_access
			{
				_out = handler.createReply();
				break;
			}
			case 9: // get_status_changes
			{
				_out = handler.createReply();
				break;
			}
			case 10: // get_listener
			{
				_out = handler.createReply();
				org.omg.dds.SubscriberListenerHelper.write(_out,get_listener());
				break;
			}
			case 11: // copy_from_topic_qos
			{
				_arg0._read (_input);
				org.omg.dds.TopicQos _arg1=org.omg.dds.TopicQosHelper.read(_input);
				_out = handler.createReply();
				_out.write_long(copy_from_topic_qos(_arg0,_arg1));
				org.omg.dds.DataReaderQosHelper.write(_out,_arg0.value);
				break;
			}
			case 12: // get_participant
			{
				_out = handler.createReply();
				org.omg.dds.DomainParticipantHelper.write(_out,get_participant());
				break;
			}
			case 13: // get_qos
			{
				_arg0._read (_input);
				_out = handler.createReply();
				get_qos(_arg0);
				org.omg.dds.SubscriberQosHelper.write(_out,_arg0.value);
				break;
			}
			case 14: // delete_contained_entities
			{
				_out = handler.createReply();
				break;
			}
			case 15: // delete_datareader
			{
				org.omg.dds.DataReader _arg0=org.omg.dds.DataReaderHelper.read(_input);
				_out = handler.createReply();
				break;
			}
			case 16: // lookup_datareader
			{
				java.lang.String _arg0=_input.read_string();
				_out = handler.createReply();
				org.omg.dds.DataReaderHelper.write(_out,lookup_datareader(_arg0));
				break;
			}
			case 17: // set_listener
			{
				org.omg.dds.SubscriberListener _arg0=org.omg.dds.SubscriberListenerHelper.read(_input);
				int _arg1=_input.read_ulong();
				_out = handler.createReply();
				_out.write_long(set_listener(_arg0,_arg1));
				break;
			}
			case 18: // set_qos
			{
				org.omg.dds.SubscriberQos _arg0=org.omg.dds.SubscriberQosHelper.read(_input);
				_out = handler.createReply();
				_out.write_long(set_qos(_arg0));
				break;
			}
		}
		return _out;
	}
	public String[] _all_interfaces(org.omg.PortableServer.POA poabyte[] obj_id)
	{
		return ;
	}
New to GrepCode? Check out our FAQ X