MessageReceiverPOA.java

[$(NDDSHOME)/example/JAVA/corba/MessageReceiverPOA.java]

public abstract class MessageReceiverPOA
        extends org.omg.PortableServer.Servant
        implements org.omg.CORBA.portable.InvokeHandler, MessageReceiverOperations
{
        static private final java.util.HashMap<String,Integer> m_opsHash = new java.util.HashMap<String,Integer>();
        static
        {
                m_opsHash.put ( "sendMessage", Integer.valueOf(0));
        }
        private String[] ids = {"IDL:MessageReceiver:1.0"};
        public MessageReceiver _this()
        {
                org.omg.CORBA.Object __o = _this_object() ;
                MessageReceiver __r = MessageReceiverHelper.narrow(__o);
                return __r;
        }
        public MessageReceiver _this(org.omg.CORBA.ORB orb)
        {
                org.omg.CORBA.Object __o = _this_object(orb) ;
                MessageReceiver __r = MessageReceiverHelper.narrow(__o);
                return __r;
        }
        public org.omg.CORBA.portable.OutputStream _invoke(String method, org.omg.CORBA.portable.InputStream _input, org.omg.CORBA.portable.ResponseHandler handler)
                throws org.omg.CORBA.SystemException
        {
                org.omg.CORBA.portable.OutputStream _out = null;
                // do something
                // quick lookup of operation
                java.lang.Integer opsIndex = (java.lang.Integer)m_opsHash.get ( method );
                if ( null == opsIndex )
                        throw new org.omg.CORBA.BAD_OPERATION(method + " not found");
                switch ( opsIndex.intValue() )
                {
                        case 0: // sendMessage
                        {
                                Message _arg0=MessageHelper.read(_input);
                                _out = handler.createReply();
                                sendMessage(_arg0);
                                break;
                        }
                }
                return _out;
        }

        public String[] _all_interfaces(org.omg.PortableServer.POA poa, byte[] obj_id)
        {
                return ids;
        }
}