1 20 21 package org.jacorb.orb.giop; 22 23 import org.jacorb.orb.*; 24 25 import org.omg.PortableInterceptor.*; 26 import org.omg.IOP.*; 27 import org.omg.BiDirPolicy.BIDIRECTIONAL_POLICY_TYPE; 28 29 34 35 public class BiDirConnectionInitializer 36 extends org.omg.CORBA.LocalObject 37 implements ORBInitializer 38 { 39 public void post_init(ORBInitInfo info) 40 { 41 try 42 { 43 ORB orb = ((org.jacorb.orb.portableInterceptor.ORBInitInfoImpl) info).getORB(); 44 Encoding encoding = new Encoding(ENCODING_CDR_ENCAPS.value, 45 (byte) 1, (byte) 0); 46 Codec codec = info.codec_factory().create_codec(encoding); 47 48 info.add_client_request_interceptor( new BiDirConnectionClientInterceptor( orb, codec )); 49 info.add_server_request_interceptor( new BiDirConnectionServerInterceptor( orb, codec )); 50 51 info.register_policy_factory( BIDIRECTIONAL_POLICY_TYPE.value, 52 new BiDirPolicyFactory() ); 53 } 54 catch (Exception e) 55 { 56 } 57 } 58 59 public void pre_init(ORBInitInfo info) 60 { 61 } 62 } | Popular Tags |