Cours CNAM par J. Laforgue

ExempleCh07_01_cas6_event_push_ref_corba

Retour

Télécharger

Exemple de l'utilisation d'un canal d'évènement en CORBA.
Dans l'évènement on fait transiter un objet CORBA afin que le consommateur utilise cet objet distant.

ChannelServer.java
Consommer.java

package my_event;

import java.io.*;
import org.omg.CORBA.*;

import org.omg.CosEventChannelAdmin.*;
import org.omg.CosEventComm.*;
import org.omg.CosNaming.*;

import devise.*;

class Consommateur implements PushConsumerOperations
{
        public Consommateur()
        {
        }

public void disconnect_push_consumer()
        {
                System.out.println("Consumer disconnected.");
        }
        
        public synchronized void push(org.omg.CORBA.Any data)
                throws org.omg.CosEventComm.Disconnected
        {
                org.omg.CORBA.Object obj = data.extract_Object();
                
                InterfaceDeviseOD devise =  
                                        InterfaceDeviseODHelper.narrow(obj);

DeviseData devisedata = devise.getDevise();
                System.out.println( devisedata.nom + " " + devisedata.taux +
                                                                        " " + devisedata.sens.value());
                System.out.println("-------------------------------------------");
    }
}

public class Consommer 
{
    public static void main( String args[] ) 
    {
                EventChannel ecs = null;
                ConsumerAdmin ca = null;
                PushConsumer pushConsumer = null;
                ProxyPushSupplier pps = null;

try 
                        {
                                //Initialisation de l'ORB.
                                ORB orb = ORB.init( args, null );
                                
                                org.omg.PortableServer.POA poa =
                                        org.omg.PortableServer.POAHelper.narrow(
                                                                                                                        orb.resolve_initial_references("RootPOA"));
                                poa.the_POAManager().activate();

// Récupération du Main Service
                                NamingContextExt nc =     
                                        NamingContextExtHelper.narrow(orb.resolve_initial_references("NameService"));

// Récupération du canal d'évènement
                                ecs = EventChannelHelper.narrow(nc.resolve(
                                                                                                                     nc.to_name("eventchannel.example")));

// On obtient les proxy des fournisseurs
                                ca  = ecs.for_consumers();
                                pps = ca.obtain_push_supplier();

// Création du consommateur (comme un servant on obtient la référence
                                // a un objet CORBA
                                PushConsumerPOATie pt = new PushConsumerPOATie( new Consommateur() );
                                pt._this_object(orb);
                                pushConsumer = PushConsumerHelper.narrow(poa.servant_to_reference(pt) );

// On connecte le consommateur au proxy des fournisseurs suivant le modèle push
                                pps.connect_push_consumer( pushConsumer );
                                
                                System.out.println("PushConsumerImpl registered.");
                                orb.run();

}
        catch( Exception ex ) 
                        {
                                ex.printStackTrace();
                        }
    }
}

Devise.java
DeviseOD.java

package devise;

import org.omg.CORBA.*;

import devise.DeviseData;
import devise.Devise;
import devise.SensTaux;

public class DeviseOD extends InterfaceDeviseODPOA
{
    private Devise _devise;

public DeviseOD( String nom, double taux )
    {
        _devise = new Devise(nom,taux,SensTaux.normale);
    }

public DeviseData getDevise()
        {
                return new DeviseData(_devise.getNom(),
                                                            _devise.getTaux(),
                                                            _devise.getSens());
        }

public void getDevise2( DeviseDataHolder d)
        {
                d.value = new DeviseData(_devise.getNom(),
                                                                 _devise.getTaux(),
                                                                 _devise.getSens());
        }

// Methodes définies dans l'IDL avec "attribute"
        //  Voir le fichier : InterfaceDeviseODOperations.java
        //
        public int attr1(){return 0;}
        public void attr1(int v){}
        public int attr2(){return 0;}

}

Producter.java

package my_event;

import java.io.*;

import org.omg.CORBA.*;
import org.omg.PortableServer.*;

import org.omg.CosNaming.*;
import org.omg.CosEventChannelAdmin.*;
import org.omg.CosEventComm.*;
import org.jacorb.events.*;

class Producteur extends PushSupplierPOA
{
  private EventChannel       _ec;
  private org.omg.CORBA.ORB  _orb;
  private ProxyPushConsumer  _consommateurs;

public Producteur(org.omg.CORBA.ORB orb,
                    EventChannel ec)
  {
    _ec=ec;
    _orb=orb;

try{
      // On obtient les proxy des consommateurs suivant le modèle push
      SupplierAdmin supplierAdmin = _ec.for_suppliers();
      _consommateurs = supplierAdmin.obtain_push_consumer();
                        
      // On connecte le producteur aux proxy des consommateur suivant le modèle push
      _consommateurs.connect_push_supplier( _this(_orb) );
    }catch(Exception e){}
  }

public void disconnect_push_supplier ()
  {
    System.out.println ("Supplier disconnected");
  }

public void poster(String message)
  {
    try{
      // Récupération du Naming Service
      NamingContextExt nc =     
        NamingContextExtHelper.narrow(_orb.resolve_initial_references("NameService"));

// Accès au servant de devise
      org.omg.CORBA.Object obj =  nc.resolve(nc.to_name("EURO_DOLLARS"));

Any any = _orb.create_any();
      any.insert_Object(obj);
      System.out.println("*** Pushing event");

_consommateurs.push( any );

}catch(Exception e){};
  }
}

public class Producter 
{
        
  public static void main(String[] args) 
  {
    try 
      {            
        //Initialisation de l'ORB
        ORB orb = ORB.init( args, null );

//Création du POA
        POA poa = 
          POAHelper.narrow( orb.resolve_initial_references( "RootPOA" ));

//Activation du POA
        poa.the_POAManager().activate();

//Récupération du Naming contexte
        NamingContextExt nc = NamingContextExtHelper.narrow(orb.resolve_initial_references("NameService"));

// Récupération du canal d'évènement
        org.omg.CosEventChannelAdmin.EventChannel e = EventChannelHelper.narrow(nc.resolve(
                                                                                           nc.to_name("eventchannel.example")));

// Création d'un producteur
        Producteur p = new Producteur(orb,e);

// On poste 100 évènements
        for(int i=1;i<3;i++)
          p.poster("EXEMPLE DE MESSAGE " + i );

}
    catch( Exception e ) 
      {
        System.out.println( e );
      }
  }
}

Server.java

package devise;

import java.io.*;

import org.omg.CORBA.*;
import org.omg.PortableServer.*;

import org.omg.CosNaming.*;

import devise.*;

public class Server 
{
  public static void main(String[] args) 
  {
    try 
      {            
        //init ORB
        ORB orb = ORB.init( args, null );

//init POA
        POA poa = 
          POAHelper.narrow( orb.resolve_initial_references( "RootPOA" ));

poa.the_POAManager().activate();

NamingContextExt nc = NamingContextExtHelper.narrow(
                                                            orb.resolve_initial_references("NameService"));

// create a GoodDay object
        DeviseOD deviseod = new DeviseOD( "EURO_DOLLARS",1.23 );
    
        // create the object reference
        org.omg.CORBA.Object obj = 
          poa.servant_to_reference( deviseod );
        nc.bind( nc.to_name("EURO_DOLLARS") , obj);
                                
        // wait for requests
        orb.run();
      }
    catch( Exception e ) 
      {
        System.out.println( e );
      }
  }
}

build.xml

<?xml version="1.0"?>

<project name="PROG" default="all" basedir=".">

<target name="load-taskdef">
        <taskdef name="jacidl" classname="org.jacorb.idl.JacIDL">
            <classpath>
                <pathelement path="${env.CLASSPATH}" />
                <fileset dir="${env.JACORB_HOME}/lib">
                    <include name="*.jar" />
                </fileset>
            </classpath>
        </taskdef>
    </target>

<target name="init">
       <property environment="env" />
       <property name="dirs.base" value="${basedir}"/>
     <property name="jacorb.dir" value="C:\JacORB-2.2.3" />
       <property name="classdir" value="${dirs.base}/classes"/>
       <property name="lib" value="${jacorb.dir}/lib"/>
     <property name="dest" value="${dirs.base}/generated"/>
       <property name="include" value="${jacorb.dir}/idl/omg"/>
     <mkdir dir="${classdir}"/>

</target>

<target name="all" depends="init,idl">
       <javac srcdir="${dest}"
            destdir="${classdir}"
              includes="**/*.java">
       </javac>
       <javac srcdir="${dirs.base}"
            destdir="${classdir}"
              includes="*.java">
                      <classpath>
                            <pathelement location="${lib}/jacorb.jar" />
              <pathelement path="${java.class.path}/" />
                        </classpath>
       </javac>
  </target>

<target name="idl" depends="init,load-taskdef">
     <mkdir dir="${dest}" />
     <jacidl srcdir="${dirs.base}"
             destdir="${dest}"
             includepath="${include}"
               includes="*.idl"/>
   </target>

<target name="clean" depends="init">
          <delete dir="${classdir}"/>
          <delete dir="${dest}"/>
  </target>

</project>

      compil.bat
      etc
         jacorb.properties

##
##  JacORB configuration options
##

########################################
#                                      #
#   Initial references configuration   #
#                                      #
########################################

#
# URLs where IORs are stored (used in orb.resolve_initial_service())
# DO EDIT these! (Only those that you are planning to use,
# of course ;-).
#
# The ORBInitRef references are created on ORB startup time. In the
# cases of the services themselves, this may lead to exceptions being
# displayed (because the services aren't up yet). These exceptions
# are handled properly and cause no harm!

#ORBInitRef.NameService=corbaloc::160.45.110.41:38693/StandardNS/NameServer-POA/_root
ORBInitRef.NameService=file:/d:/NS_Ref
#ORBInitRef.NameService=http://www.x.y.z/~user/NS_Ref
#ORBInitRef.TradingService=http://www.x.y.z/~user/TraderRef

########################################
#                                      #
#      Export of corbaloc IORs         #
#                                      #
########################################

# allow for more readable corbaloc URLs by mapping the
# actual object key to an arbitrary string. The mapping
# below would permit clients of a name service to
# access it using corbaloc::ipaddress:portnum/NameService
# Note: it is NOT necessary to define this property for
# the name service here because this is done already in the
# code of the ns implementation.
# This mapping can be altered programatically by the proprietary
# function ORB::addObjectKey(NameService, file:/home/rnc/NameSingleton.ior)
#
# The property also accepts the following mappings:
# IOR, resource, jndi, URL (e.g. file, http)
# examples:
# jacorb.orb.objectKeyMap.NameService=StandardNS/NameServer-POA/_root
# jacorb.orb.objectKeyMap.NameService=file:/home/rnc/NameSingleton.ior

##################################
#                                #
#   ORB version number output    #
#                                #
##################################

# if on, the ORB's version number and a copyright statement is printed
# any time the ORB is initialized
jacorb.orb.print_version=on

##################################
#                                #
#  Default Logging configuration #
#                                #
##################################

# Name of the factory class that plugs in a given log kit
# The default value is JacORB's own factory for the Apache
# LogKit. Only edit (or uncomment) if you want a different
# log kit.
#jacorb.log.loggerFactory=org.jacorb.util.LogKitLoggerFactory

# log levels:
#
# 0 = fatal errors only = "almost off" (FATAL ERRORS)
# 1 = non-fatal errors and exceptions (ERROR)
# 2 = important messages (WARN)
# 3 = informational messages and exceptions (INFO)
# 4 = debug-level output (DEBUG) (may confuse the unaware user :-)
# NOTE: the name of this property has changed from jacorb.verbosity!!
jacorb.log.default.verbosity=2

# where does output go? Terminal is default
#jacorb.logfile=LOGFILEPATH

# If logging to file whether to append to existing file or overwrite
jacorb.logfile.append=off

# If jacorb.logfile.append is on, set rolling log size in kilobytes.
# A value of 0 implies no rolling log
jacorb.logfile.maxLogSize=0

# hexdump outgoing messages
jacorb.debug.dump_outgoing_messages=off

# hexdump incoming messages
jacorb.debug.dump_incoming_messages=off

jacorb.util.tpool.log.verbosity=0

##################################################
#                                                #
#    WARNING: The following properties should    #
#    only be edited by the expert user. They     #
#    can be left untouched in most cases!        #
#                                                #
##################################################

################################
#                              #
#   Basic ORB Configuration    #
#                              #
################################

# the GIOP minor version number to use for newly created IORs
jacorb.giop_minor_version=2

# number of retries if connection cannot directly be established
jacorb.retries=5

# how many msecs. do we wait between retries
jacorb.retry_interval=500

# log2 of maximum buffer size managed by the internal
# buffer manager.
#
# This is NOT the maximum buffer size that
# can be used, but just the largest size of buffers that
# will be kept and managed. This value will be added to
# an internal constant of 5, so the real value in bytes
# is 2**(5+maxManagedBufSize-1). You only need to increase this
# value if you are dealing with LOTS of LARGE data structures.
# You may decrease it to make the buffer manager release large
# buffers immediately rather than keeping them for later
# reuse.
jacorb.maxManagedBufSize=18

# If this value is 0 an extra unlimited size buffer cache is created
# for the CDROutputStreams. If this value is > 0 then the cache will
# be purged every x msecs. If this value is -1 no caching of these
# buffers will take place. This will reduce memory footprint at the
# cost of decreased performance handling large data structures.
# This value defaults to 0 if not set.
#jacorb.bufferManagerMaxFlush=-1

# Normally, a jacorb server will close the TCP/IP connection right
# after sending a CloseConnection message. However, it may
# occasionally happen that the client sends a message into the closed
# connection because it hasn't handled the CloseConnection yet. To
# avoid this situation, closing of the TCP/IP connection can be delayed.
#jacorb.connection.delay_close=on
#jacorb.connection.timeout_after_closeconnection=20000

# Initial timeout for establishing a connection.
#jacorb.connection.client.connect_timeout=0

# Wait the specified number of msecs for a reply to a request. If
# exceeded, a org.omg.CORBA.TIMEOUT exception will be thrown
#jacorb.connection.client.pending_reply_timeout=0

# client-side connection idle timeout, set no non-zero to stop
# close the connection after so many msecs.
#jacorb.connection.client.idle_timeout=0

# shall the orb ignore pending messages when a connection idle timeout
# is detected? If "on", the connection is closed and all pending
# messages are cancelled. Default is "off"
#jacorb.connection.client.timeout_ignores_pending_messages=off

# whenever a network failure is detected, the orb can either
# (infinitely) retry all pending requests, or propagate a COMM_FAILURE
# back into the client code. Default is "off", i.e. throw a
# COMM_FAILURE
#jacorb.connection.client.retry_on_failure=off

# max time (msecs) a server keeps a connection open if nothing happens
#jacorb.connection.server.timeout=10000

# Max no of accepted connections on the server.
#jacorb.connection.max_server_connections=

# Max number of connection threads.
#jacorb.connection.max_threads=

# The number of msecs that are waited until the next attempt to find
# an idle connection is made (i.e. do not continuously spin)
#jacorb.connection.wait_for_idle_interval=500

# The class name of the SelectionStrategy class
#jacorb.connection.selection_strategy_class=

# The class name of the StatisticsProvider class
#jacorb.connection.statistics_provider_class=

#jacorb.reference_caching=off

#
# The following property specifies the class which is used for
# reference caching. WeakHashtable uses WeakReferences, so entries
# get gc'ed if only the Hashtable has a reference to them. This
# is useful if you have many references to short-living non-persistent
# CORBA objects. It is only available for java 1.2 and above.
#
# On the other hand the standard Hashtable keeps the references until
# they are explicitely deleted by calling _release(). This is useful
# for persistent and long-living CORBA objects.
#
#jacorb.hashtable_class=org.jacorb.util.WeakHashtable
#
jacorb.hashtable_class=java.util.Hashtable

# use GIOP 1.2 byte order markers (since CORBA 2.4-5)
jacorb.use_bom=off

# add additional IIOP 1.0 profiles even if we are using IIOP 1.2
jacorb.giop.add_1_0_profiles=off

# Use DNS names in IORs
jacorb.dns.enable=off

# Compact Typecodes (0 - off, 1 - partial (not member_names), 2 - all)
jacorb.compactTypecodes=0

# Cache typecode on read
jacorb.cacheTypecodes=off

# Cache poa names
jacorb.cachePoaNames=off

###########################################
#                                         #
#         Interoperability                #
#                                         #
###########################################

# Turn off indirection encoding for repeated typecodes. This fixes
# interoperability with certain broken ORB's eg. Orbix2000
jacorb.interop.indirection_encoding_disable=off

# Iona Comet CORBA/COM bridge can incorrectly encode buffer lengths.
# Enabling this property adds additional length checking and adjustment
# for interoperability with Comet.
jacorb.interop.comet=off

# Some ORBs do not set a byte value of 1 as a CDR encoded boolean true
# value. Enabling this property interprets any non zero CDR encoded
# boolean value as true.
jacorb.interop.lax_boolean_encoding=off

# Control whether the method create_abstract_interface_tc performs
# a validity check on the name parameter or not. Turning this check
# off circumvents a bug in Sun's implementation of javax.rmi.CORBA.ValueHander,
# which occasionally passes an invalid name (an empty string) to
# ORBSingleton.create_abstract_interface_tc. If you are using RMI valuetypes,
# you should turn this property off.
jacorb.interop.strict_check_on_tc_creation=on

# Custom-marshalled RMI valuetypes should be encoded as chunks, but some
# ORBs are not able to decode chunked values. Disable this property for
# interoperability with the ORB in Sun's JDK 1.4.2.
jacorb.interop.chunk_custom_rmi_valuetypes=on
###########################################
#                                         #
#         Socket Factories                #
#                                         #
###########################################

# A factory design pattern is used for the creation of sockets and server
# sockets.
# The jacorb.net.socket_factory property can be used to configure
# a socket factory that must implement the operations defined in the
# interface org.jacorb.orb.factory.SocketFactory.
# The jacorb.net.server_socket_factory property can be used to configure a
# server socket factory that must implement the operations defined in the
# interface org.jacorb.orb.factory.ServerSocketFactory.
#
#jacorb.net.socket_factory=org.jacorb.orb.factory.DefaultSocketFactory
#jacorb.net.server_socket_factory=org.jacorb.orb.factory.DefaultServerSocketFactory
#jacorb.net.socket_factory=org.jacorb.orb.factory.PortRangeSocketFactory
#jacorb.net.server_socket_factory=org.jacorb.orb.factory.PortRangeServerSocketFactory
#
# Additional socket factores are supported that allow for the configuration
# of maximum and minimum port numbers that can be used. This can be used to
# enable firewall traversal via a fixed port range. To use these socket factories
# configure one or both of the following property pairs. The first property pair
# configures the client socket factory and the second pair the server socket
# factory.
#
#jacorb.net.socket_factory.port.min
#jacorb.net.socket_factory.port.max
#jacorb.net.server_socket_factory.port.min
#jacorb.net.server_socket_factory.port.max

###########################################
#                                         #
#         BiDirectional GIOP              #
#                                         #
###########################################

# uncomment this initializer if you want to use BiDirectional GIOP

#org.omg.PortableInterceptor.ORBInitializerClass.bidir_init=org.jacorb.orb.giop.BiDirConnectionInitializer

###########################################
#                                         #
#       Proxy address in IOR              #
#                                         #
###########################################

#
# Some times it is necessary to present an endpoint alias in an IOR
# to allow clients outside a firewall to get a connection to a server
# that is behind a NAT'ing firewall.
#
# WARNING: this is just "dumb" replacing, so you
# have to take care of your configuration!
#

# The general form of this address is <protocol key>://<address>
# The protocol key in the address must match the protocol(s) used by
# the server. See the section on configuring Transport Factories for
# information on loading specific protocols.
#jacorb.ior_proxy_address=iiop://1.2.3.4:4711

# Deprecated IIOP-specific form:
# with these two properties it is possible to
# tell the ORB what IP/port IORs should contain,
# if the ServerSockets IP/port can't be used
# (e.g. for traffic through a firewall).
#
# WARNING: this is just "dumb" replacing, so you
# have to take care of your configuration!
#

#jacorb.ior_proxy_host=1.2.3.4
#jacorb.ior_proxy_port=4711

###########################################
#                                         #
#   The Object Adapter Internet Address   #
#                                         #
###########################################

# IP address on multi-homed host (this gets encoded in
# object references). NOTE: Adresses like 127.0.0.X
# will only be accessible from the same machine!
#OAIAddr=1.2.3.4
#OAPort=4711

# A new protocol-independent configuration is available
# for use to configure an explicit endpoint using IIOP or
# other protocols.
#OAAddress=iiop://1.2.3.4:4711

############################
#                          #
#   Default Interceptors   #
#   Please leave them in!  #
#                          #
############################
org.omg.PortableInterceptor.ORBInitializerClass.standard_init=org.jacorb.orb.standardInterceptors.IORInterceptorInitializer

###############################################
#                                             #
#   Implementation Repository Configuration   #
#                                             #
###############################################
# Switch off to avoid contacting the ImR on every server start-up
jacorb.use_imr=off

# Switch off if you don't want to write the ImR address into server IORs
# (ignored if jacorb.use_imr=off)
jacorb.use_imr_endpoint=on

# if set to "on", servers that don't already have an entry on their
# first call to the imr, will get automatically registered. Otherwise,
# an UnknownServer exception is thrown.
jacorb.imr.allow_auto_register=off

# if set to "on", the imr will try to "ping" every object reference,
# that it is going to return. If the reference is not alive, TRANSIENT
# is thrown.
jacorb.imr.check_object_liveness=off

ORBInitRef.ImplementationRepository=http://www.x.y.z/~user/ImR_Ref

jacorb.imr.table_file=Z:\table.dat
jacorb.imr.backup_file=z:\backup.dat
jacorb.imr.ior_file=/home/bwana/brose/public_html/ImR_Ref
# Time (msecs) that the implementation will wait for a started server to register.
jacorb.imr.timeout=

# Host for ImR endpoint
jacorb.imr.endpoint_host=
# Port number for IMR endpoint
jacorb.imr.endpoint_port_number=

# how many millisecs should the imr wait, until a connection from an
# application client is terminated. Default is 2000.
jacorb.imr.connection_timeout=2000

# the implementation name, should be set to a different
# name in the code of persistent servers
jacorb.implname=StandardImplName

#
# This is supposed to be a generic startup string for everything
# that calls Runtime.exec(). Might be replaced by jaco[.bat].
#
jacorb.java_exec=java -Dorg.omg.CORBA.ORBClass=org.jacorb.orb.ORB -Dorg.omg.CORBA.ORBSingletonClass=org.jacorb.orb.ORBSingleton

# with these two properties it is possible to
# tell the ORB what IP / hostname  and port the IMR IOR and IMRified server IORs should
# contain,  if the ServerSockets IP/port can't be used
# (e.g. for traffic through a firewall).
#
# WARNING: this is just "dumb" replacement, so you
# have to take care of your configuration!
#
#jacorb.imr.ior_proxy_host=1.2.3.4
#jacorb.imr.ior_proxy_port=4711

# protocol-independent form for assigning imr proxy endpoint
#jacorb.imr.ior_proxy_address=iiop://1.2.3.4:4711

#########################
#                       #
#   SSL Configuration   #
#                       #
#########################

#
# The port number used by SSL, will be dynmically assigned
# by default
#

#OASSLPort=4711

# This interceptor must be set if programs need access to
# certificates using the CORBA Security API, SSL works also
# without this interceptor

#org.omg.PortableInterceptor.ORBInitializerClass.ForwardInit=org.jacorb.security.ssl.SecurityServiceInitializer
#org.omg.PortableInterceptor.ORBInitializerClass.ForwardInit=org.jacorb.security.ssl.iaik.SecurityServiceInitializer

# qualified classname of access decision object
jacorb.security.access_decision=org.jacorb.security.level2.AccessDecisionImpl

# list of qualified classnames of principal authenticator objects,
# separated by commas (no whitespaces!). The first entry (that can
# be successfully created) will be available through the
# principal_authenticator property.
jacorb.security.principal_authenticator=org.jacorb.security.level2.PrincipalAuthenticatorImpl

# the qualified classname of the ssl socket factory class
#jacorb.ssl.socket_factory=org.jacorb.security.ssl.sun_jsse.SSLSocketFactory
jacorb.ssl.socket_factory=org.jacorb.security.ssl.iaik.SSLSocketFactory

# the qualified classname of the ssl server socket factory class
#jacorb.ssl.server_socket_factory=org.jacorb.security.ssl.sun_jsse.SSLServerSocketFactory
jacorb.ssl.server_socket_factory=org.jacorb.security.ssl.iaik.SSLServerSocketFactory

# IIOP/SSL parameters (numbers are hex values, without the leading "0x"):
# NoProtection = 1
# EstablishTrustInClient = 40
# EstablishTrustInTarget = 20
# mutual authentication = 60
# please see the programming guide for more explanation

jacorb.security.support_ssl=off

jacorb.security.ssl.client.supported_options=0
jacorb.security.ssl.client.required_options=0

jacorb.security.ssl.server.supported_options=0
jacorb.security.ssl.server.required_options=0

#
# If set, the following two values will be placed in the IOR, if
# "corbaloc:ssliop" ssliop.
#
# If not set, only EstablishTrustInTarget is used for both supported
# and required options. EstablishTrustInClient is not set, and the
# rest of the Association Options aren't currently used anyway.
#jacorb.security.ssl.corbaloc_ssliop.supported_options=0
#jacorb.security.ssl.corbaloc_ssliop.required_options=0

# The name and location of the keystore. This may be absolute or
# relative to the home directory, or a file retrievable through the
# classloader.
#
# NOTE (for Sun JSSE users): The "javax.net.ssl.trustStore[Password]"
# properties don't seem to take effect, so you may want to add trusted
# certificates to "normal" keystores. In this case, please set the
# property "jacorb.security.jsse.trustees_from_ks"is to "on", so trusted
# certificates are taken from the keystore instead of a dedicated
# truststore.
jacorb.security.keystore=
jacorb.security.keystore_password=

#
# IAIK specific settings
#

# files with public key certs of trusted CAs
#
# WARNING: If no CA certs are present, the IAIK chain verifier will
# accept ALL otherwise valid chains!
#
jacorb.security.trustees=

# the name of the default key alias to look up in the keystore
jacorb.security.default_user=
jacorb.security.default_password=

# have iaiks ssl classes print debug output to stdout
jacorb.security.iaik_debug=off

#
# Sun JSSE specific settings
#
# Use the keystore to take trusted certs from.
jacorb.security.jsse.trustees_from_ks=off

# A comma-separated (no whitespaces!) list of cipher suite names. See
# the JSSE docs on how to obtain the correct cipher suite strings
jacorb.security.ssl.server.cipher_suites=
jacorb.security.ssl.client.cipher_suites=

# A comma seperated list of the names of the protocols to be set enabled on
# the SSL socket.  See the JSSE documentation for
# javax.net.ssl.SSLSocket#setEnabledProtocols()
# NOTE: Does only apply to jdk1.4 and above
#jacorb.security.ssl.client.protocols=
#jacorb.security.ssl.server.protocols=

# A user defined javax.net.ssl.TrustManager implemementation class name.
# Will be used to intialise the SSLContext. See JSSE docs for javax.net.ssl.SSLContext#init().
# Must be capable of instantiation via a no arg constructor.
#jacorb.security.ssl.client.trust_manager=my.trust.Manager
#jacorb.security.ssl.server.trust_manager=my.trust.Manager

#########################
#                       #
#   POA Configuration   #
#                       #
#########################

# displays a GUI monitoring tool for servers
jacorb.poa.monitoring=off

# POA log levels:
# 0 = fatal errors only = "almost off" (FATAL ERRORS)
# 1 = non-fatal errors and exceptions (ERROR)
# 2 = important messages (WARN)
# 3 = informational messages and exceptions (INFO)
# 4 = debug-level output (DEBUG) (may confuse the unaware user :-)
jacorb.poa.log.verbosity=3

# thread pool configuration for request processing
jacorb.poa.thread_pool_max=20
jacorb.poa.thread_pool_min=5

# if set, request processing threads in thePOA
# will run at this priority. If not set or invalid,
# MAX_PRIORITY will be used.
#jacorb.poa.thread_priority=

# Properties controlling the POA's request queue.  If queue_wait is off,
# then if there are more than queue_max requests in the queue, the
# client gets TRANSIENT exceptions for any requests.  If queue_wait is on,
# then the call blocks at the server side until no more than queue_min
# requests are left in the queue.  The new request is then delivered as usual.
jacorb.poa.queue_wait=off
jacorb.poa.queue_max=100
jacorb.poa.queue_min=10

# Set this to on for server-side checking of expired ReplyEndTimePolicy.
# (This also applies to RelativeRoundtripTimeoutPolicy.)  When this is on,
# the clocks of the server and client machine need to be synchronized.
#jacorb.poa.check_reply_end_time=off

###################################
#                                 #
#  Transport Layer Configuration  #
#                                 #
###################################

# Names of the factories classes for all installed transport plug-ins
# (comma-separated list).

#jacorb.transport.factories=org.jacorb.orb.iiop.IIOPFactories

# ProfileId tags of all installed transports that should actually
# listen on the server side.  This is a comma-separated list of numbers,
# each number must correspond to one ProfileId tag from a factory in
# jacorb.transport.factories.  In IORs produced by the server, the transport
# profiles will appear in the order indicated by this list.

#jacorb.transport.server.listeners=0

# Name of a class that selects the transport profile to use on the
# client side.

#jacorb.transport.client.selector=org.jacorb.orb.DefaultProfileSelector

##################################
#                                #
#   Name Service Configuration   #
#                                #
##################################

# log levels:
# 0 = fatal errors only = "almost off" (FATAL ERRORS)
# 1 = non-fatal errors and exceptions (ERROR)
# 2 = important messages (WARN)
# 3 = informational messages and exceptions (INFO)
# 4 = debug-level output (DEBUG) (may confuse the unaware user :-)

jacorb.naming.log.verbosity=3

#
# name of the logger factory. Implement your own subclass of
# org.jacorb.util.LoggerFactory and enter class name here to
# customize logging behavior. Built-in default is org.jacorb.util.LogKitLoggerFactory
#jacorb.log.loggerFactory=

# Whether non active references are purged from name service
# when list operation is invoked.

jacorb.naming.purge=on

# Whether resolve should return references without trying to
# ping them to see if they're still alive first.

jacorb.naming.noping=on

# The file where the name server drops its IOR
jacorb.naming.ior_filename=d:/NS_Ref

########################################
#                                      #
#   Trader configuration, please see   #
#   src/trading/README.PROPERTIES for  #
#   explanation                        #
#                                      #
########################################

jtrader.util.max_threads=10
jtrader.util.min_threads=1
jtrader.util.query_timeout=5000
jtrader.impl.cache_max=100

# boolean values, e.g. true / false
#jtrader.modifiable_properties=
#jtrader.dynamic_properties=
#jtrader.proxy_offers=

jtrader.debug=false
jtrader.debug_verbosity=3

#integer values
jtrader.def_search_card=
jtrader.max_search_card=
jtrader.def_match_card=
jtrader.max_match_card=
jtrader.def_return_card=
jtrader.max_return_card=
jtrader.max_list=
jtrader.def_hop_count=
jtrader.max_hop_count=

#FollowOptions
#always=2
#if_no_local=1
#local_only=0
jtrader.def_follow_policy=
jtrader.max_follow_policy=
jtrader.max_link_follow_policy=

########################################################
#                                                      #
#   Notification Service configuration, please see     #
#   the JacORB ProgrammingGuide for a explanation      #
#                                                      #
########################################################

jacorb.notification.filter.thread_pool_size = 2

jacorb.notification.proxyconsumer.thread_pool_size = 2

jacorb.notification.proxysupplier.thread_pool_size = 4

jacorb.notification.supplier.poll_intervall = 1000

jacorb.notification.max_batch_size = 1

jacorb.notification.max_events_per_consumer = 100

jacorb.notification.order_policy = PriorityOrder

jacorb.notification.discard_policy = PriorityOrder

jacorb.notification.consumer.backout_interval = 5000

jacorb.notification.consumer.error_threshold = 3

# valid values: ThreadPool, ThreadPerProxy
jacorb.notification.proxysupplier.threadpolicy = ThreadPool

jacorb.notification.default_filter_factory = builtin

# jacorb.notification.supplier.max_number = 10

# jacorb.notification.start_time_supported = 10

jacorb.notification.stop_time_supported = on

jacorb.notification.proxy.destroy_causes_disconnect = on

# Notification Service log levels:
org.jacorb.notification.log.verbosity = 3

########################################
#                                      #
#   SAS configuration                  #
#                                      #
########################################

jacorb.SAS.log.verbosity=INFO
jacorb.SAS.CSS.log.verbosity=INFO
jacorb.SAS.TSS.log.verbosity=INFO

# This option defines the specific SAS context generator/validator
# Currently supported contexts include:
#    NullContext       - Sends a NULL SAS Context
#    GssUpContext      - Uses GSSUP security
#    KerberosContext   - uses Kerberos security
# At least one context must be selected for SAS support
#jacorb.security.sas.contextClass=org.jacorb.security.sas.NullContext
#jacorb.security.sas.contextClass=org.jacorb.security.sas.GssUpContext
#jacorb.security.sas.contextClass=org.jacorb.security.sas.KerberosContext

# This initializer installs the SAS interceptors
# Comment out this line if you do not want SAS support
#org.omg.PortableInterceptor.ORBInitializerClass.SAS=org.jacorb.security.sas.SASInitializer

# This option is used for GSSUP security and sets up the GSS Provider
# Comment out this line if you are not using GSS UP authentication
#org.omg.PortableInterceptor.ORBInitializerClass.GSSUPProvider=org.jacorb.security.sas.GSSUPProviderInitializer

########################################
#                                      #
#   Custom configuration               #
#                                      #
########################################

# any other custom properties can be added here.

      generated
         devise
            DesDevisesHelper.java

package devise;

/**
 *    Generated from IDL definition of alias "DesDevises"
 *    @author JacORB IDL compiler 
 */

public final class DesDevisesHelper
{
    private static org.omg.CORBA.TypeCode _type = null;

public static void insert (org.omg.CORBA.Any any, devise.DeviseData[] s)
    {
        any.type (type ());
        write (any.create_output_stream (), s);
    }

public static devise.DeviseData[] extract (final org.omg.CORBA.Any any)
    {
        return read (any.create_input_stream ());
    }

public static org.omg.CORBA.TypeCode type ()
    {
        if (_type == null)
        {
            _type = org.omg.CORBA.ORB.init().create_alias_tc(devise.DesDevisesHelper.id(), "DesDevises",org.omg.CORBA.ORB.init().create_sequence_tc(0, devise.DeviseDataHelper.type()));
        }
        return _type;
    }

public static String id()
    {
        return "IDL:devise/DesDevises:1.0";
    }
    public static devise.DeviseData[] read (final org.omg.CORBA.portable.InputStream _in)
    {
        devise.DeviseData[] _result;
        int _l_result2 = _in.read_long();
        _result = new devise.DeviseData[_l_result2];
        for (int i=0;i<_result.length;i++)
        {
            _result[i]=devise.DeviseDataHelper.read(_in);
        }

return _result;
    }

public static void write (final org.omg.CORBA.portable.OutputStream _out, devise.DeviseData[] _s)
    {
        
        _out.write_long(_s.length);
        for (int i=0; i<_s.length;i++)
        {
            devise.DeviseDataHelper.write(_out,_s[i]);
        }

}
}

            DesDevisesHolder.java
            DeviseData.java
            DeviseDataHelper.java

package devise;

/**
 *    Generated from IDL definition of struct "DeviseData"
 *    @author JacORB IDL compiler 
 */

public final class DeviseDataHelper
{
    private static org.omg.CORBA.TypeCode _type = null;
    public static org.omg.CORBA.TypeCode type ()
    {
        if (_type == null)
        {
            _type = org.omg.CORBA.ORB.init().create_struct_tc(devise.DeviseDataHelper.id(),"DeviseData",new org.omg.CORBA.StructMember[]{new org.omg.CORBA.StructMember("nom", org.omg.CORBA.ORB.init().create_string_tc(0), null),new org.omg.CORBA.StructMember("taux", org.omg.CORBA.ORB.init().get_primitive_tc(org.omg.CORBA.TCKind.from_int(7)), null),new org.omg.CORBA.StructMember("sens", devise.SensTauxHelper.type(), null)});
        }
        return _type;
    }

public static void insert (final org.omg.CORBA.Any any, final devise.DeviseData s)
    {
        any.type(type());
        write( any.create_output_stream(),s);
    }

public static devise.DeviseData extract (final org.omg.CORBA.Any any)
    {
        return read(any.create_input_stream());
    }

public static String id()
    {
        return "IDL:devise/DeviseData:1.0";
    }
    public static devise.DeviseData read (final org.omg.CORBA.portable.InputStream in)
    {
        devise.DeviseData result = new devise.DeviseData();
        result.nom=in.read_string();
        result.taux=in.read_double();
        result.sens=devise.SensTauxHelper.read(in);
        return result;
    }
    public static void write (final org.omg.CORBA.portable.OutputStream out, final devise.DeviseData s)
    {
        out.write_string(s.nom);
        out.write_double(s.taux);
        devise.SensTauxHelper.write(out,s.sens);
    }
}

DeviseDataHolder.java
EntierHelper.java

package devise;

/**
 *    Generated from IDL definition of alias "Entier"
 *    @author JacORB IDL compiler 
 */

public final class EntierHelper
{
    private static org.omg.CORBA.TypeCode _type = null;

public static void insert (org.omg.CORBA.Any any, short s)
    {
        any.type (type ());
        write (any.create_output_stream (), s);
    }

public static short extract (final org.omg.CORBA.Any any)
    {
        return read (any.create_input_stream ());
    }

public static org.omg.CORBA.TypeCode type ()
    {
        if (_type == null)
        {
            _type = org.omg.CORBA.ORB.init().create_alias_tc(devise.EntierHelper.id(), "Entier",org.omg.CORBA.ORB.init().get_primitive_tc(org.omg.CORBA.TCKind.from_int(2)));
        }
        return _type;
    }

public static String id()
    {
        return "IDL:devise/Entier:1.0";
    }
    public static short read (final org.omg.CORBA.portable.InputStream _in)
    {
        short _result;
        _result=_in.read_short();
        return _result;
    }

public static void write (final org.omg.CORBA.portable.OutputStream _out, short _s)
    {
        _out.write_short(_s);
    }
}

InterfaceDeviseOD.java
InterfaceDeviseODHelper.java

package devise;

/**
 *    Generated from IDL interface "InterfaceDeviseOD"
 *    @author JacORB IDL compiler V 2.2.3, 10-Dec-2005
 */

public final class InterfaceDeviseODHelper
{
    public static void insert (final org.omg.CORBA.Any any, final devise.InterfaceDeviseOD s)
    {
            any.insert_Object(s);
    }
    public static devise.InterfaceDeviseOD extract(final org.omg.CORBA.Any any)
    {
        return narrow(any.extract_Object()) ;
    }
    public static org.omg.CORBA.TypeCode type()
    {
        return org.omg.CORBA.ORB.init().create_interface_tc("IDL:devise/InterfaceDeviseOD:1.0", "InterfaceDeviseOD");
    }
    public static String id()
    {
        return "IDL:devise/InterfaceDeviseOD:1.0";
    }
    public static InterfaceDeviseOD read(final org.omg.CORBA.portable.InputStream in)
    {
        return narrow(in.read_Object());
    }
    public static void write(final org.omg.CORBA.portable.OutputStream _out, final devise.InterfaceDeviseOD s)
    {
        _out.write_Object(s);
    }
    public static devise.InterfaceDeviseOD narrow(final java.lang.Object obj)
    {
        if (obj instanceof devise.InterfaceDeviseOD)
        {
            return (devise.InterfaceDeviseOD)obj;
        }
        else if (obj instanceof org.omg.CORBA.Object)
        {
            return narrow((org.omg.CORBA.Object)obj);
        }
        throw new org.omg.CORBA.BAD_PARAM("Failed to narrow in helper");
    }
    public static devise.InterfaceDeviseOD narrow(final org.omg.CORBA.Object obj)
    {
        if (obj == null)
            return null;
        try
        {
            return (devise.InterfaceDeviseOD)obj;
        }
        catch (ClassCastException c)
        {
            if (obj._is_a("IDL:devise/InterfaceDeviseOD:1.0"))
            {
                devise._InterfaceDeviseODStub stub;
                stub = new devise._InterfaceDeviseODStub();
                stub._set_delegate(((org.omg.CORBA.portable.ObjectImpl)obj)._get_delegate());
                return stub;
            }
        }
        throw new org.omg.CORBA.BAD_PARAM("Narrow failed");
    }
    public static devise.InterfaceDeviseOD unchecked_narrow(final org.omg.CORBA.Object obj)
    {
        if (obj == null)
            return null;
        try
        {
            return (devise.InterfaceDeviseOD)obj;
        }
        catch (ClassCastException c)
        {
                devise._InterfaceDeviseODStub stub;
                stub = new devise._InterfaceDeviseODStub();
                stub._set_delegate(((org.omg.CORBA.portable.ObjectImpl)obj)._get_delegate());
                return stub;
        }
    }
}

            InterfaceDeviseODHolder.java
            InterfaceDeviseODOperations.java
            InterfaceDeviseODPOA.java

package devise;

/**
 *    Generated from IDL interface "InterfaceDeviseOD"
 *    @author JacORB IDL compiler V 2.2.3, 10-Dec-2005
 */

public abstract class InterfaceDeviseODPOA
    extends org.omg.PortableServer.Servant
    implements org.omg.CORBA.portable.InvokeHandler, devise.InterfaceDeviseODOperations
{
    static private final java.util.Hashtable m_opsHash = new java.util.Hashtable();
    static
    {
        m_opsHash.put ( "_get_attr2", new java.lang.Integer(0));
        m_opsHash.put ( "getDevise2", new java.lang.Integer(1));
        m_opsHash.put ( "getDevise", new java.lang.Integer(2));
        m_opsHash.put ( "_set_attr1", new java.lang.Integer(3));
        m_opsHash.put ( "_get_attr1", new java.lang.Integer(4));
    }
    private String[] ids = {"IDL:devise/InterfaceDeviseOD:1.0"};
    public devise.InterfaceDeviseOD _this()
    {
        return devise.InterfaceDeviseODHelper.narrow(_this_object());
    }
    public devise.InterfaceDeviseOD _this(org.omg.CORBA.ORB orb)
    {
        return devise.InterfaceDeviseODHelper.narrow(_this_object(orb));
    }
    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: // _get_attr2
            {
            _out = handler.createReply();
            _out.write_long(attr2());
                break;
            }
            case 1: // getDevise2
            {
                devise.DeviseDataHolder _arg0= new devise.DeviseDataHolder();
                _out = handler.createReply();
                getDevise2(_arg0);
                devise.DeviseDataHelper.write(_out,_arg0.value);
                break;
            }
            case 2: // getDevise
            {
                _out = handler.createReply();
                devise.DeviseDataHelper.write(_out,getDevise());
                break;
            }
            case 3: // _set_attr1
            {
            _out = handler.createReply();
            attr1(_input.read_long());
                break;
            }
            case 4: // _get_attr1
            {
            _out = handler.createReply();
            _out.write_long(attr1());
                break;
            }
        }
        return _out;
    }

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

InterfaceDeviseODPOATie.java

package devise;

import org.omg.PortableServer.POA;

/**
 *    Generated from IDL interface "InterfaceDeviseOD"
 *    @author JacORB IDL compiler V 2.2.3, 10-Dec-2005
 */

public class InterfaceDeviseODPOATie
    extends InterfaceDeviseODPOA
{
    private InterfaceDeviseODOperations _delegate;

private POA _poa;
    public InterfaceDeviseODPOATie(InterfaceDeviseODOperations delegate)
    {
        _delegate = delegate;
    }
    public InterfaceDeviseODPOATie(InterfaceDeviseODOperations delegate, POA poa)
    {
        _delegate = delegate;
        _poa = poa;
    }
    public devise.InterfaceDeviseOD _this()
    {
        return devise.InterfaceDeviseODHelper.narrow(_this_object());
    }
    public devise.InterfaceDeviseOD _this(org.omg.CORBA.ORB orb)
    {
        return devise.InterfaceDeviseODHelper.narrow(_this_object(orb));
    }
    public InterfaceDeviseODOperations _delegate()
    {
        return _delegate;
    }
    public void _delegate(InterfaceDeviseODOperations delegate)
    {
        _delegate = delegate;
    }
    public POA _default_POA()
    {
        if (_poa != null)
        {
            return _poa;
        }
        else
        {
            return super._default_POA();
        }
    }
    public int attr2()
    {
        return _delegate.attr2();
    }

public void getDevise2(devise.DeviseDataHolder d)
    {
_delegate.getDevise2(d);
    }

public devise.DeviseData getDevise()
    {
        return _delegate.getDevise();
    }

public void attr1(int a)
    {
        _delegate.attr1(a);
    }

public int attr1()
    {
        return _delegate.attr1();
    }

}

InterfaceEnveloppeOD.java
InterfaceEnveloppeODHelper.java

package devise;

/**
 *    Generated from IDL interface "InterfaceEnveloppeOD"
 *    @author JacORB IDL compiler V 2.2.3, 10-Dec-2005
 */

public final class InterfaceEnveloppeODHelper
{
    public static void insert (final org.omg.CORBA.Any any, final devise.InterfaceEnveloppeOD s)
    {
            any.insert_Object(s);
    }
    public static devise.InterfaceEnveloppeOD extract(final org.omg.CORBA.Any any)
    {
        return narrow(any.extract_Object()) ;
    }
    public static org.omg.CORBA.TypeCode type()
    {
        return org.omg.CORBA.ORB.init().create_interface_tc("IDL:devise/InterfaceEnveloppeOD:1.0", "InterfaceEnveloppeOD");
    }
    public static String id()
    {
        return "IDL:devise/InterfaceEnveloppeOD:1.0";
    }
    public static InterfaceEnveloppeOD read(final org.omg.CORBA.portable.InputStream in)
    {
        return narrow(in.read_Object());
    }
    public static void write(final org.omg.CORBA.portable.OutputStream _out, final devise.InterfaceEnveloppeOD s)
    {
        _out.write_Object(s);
    }
    public static devise.InterfaceEnveloppeOD narrow(final java.lang.Object obj)
    {
        if (obj instanceof devise.InterfaceEnveloppeOD)
        {
            return (devise.InterfaceEnveloppeOD)obj;
        }
        else if (obj instanceof org.omg.CORBA.Object)
        {
            return narrow((org.omg.CORBA.Object)obj);
        }
        throw new org.omg.CORBA.BAD_PARAM("Failed to narrow in helper");
    }
    public static devise.InterfaceEnveloppeOD narrow(final org.omg.CORBA.Object obj)
    {
        if (obj == null)
            return null;
        try
        {
            return (devise.InterfaceEnveloppeOD)obj;
        }
        catch (ClassCastException c)
        {
            if (obj._is_a("IDL:devise/InterfaceEnveloppeOD:1.0"))
            {
                devise._InterfaceEnveloppeODStub stub;
                stub = new devise._InterfaceEnveloppeODStub();
                stub._set_delegate(((org.omg.CORBA.portable.ObjectImpl)obj)._get_delegate());
                return stub;
            }
        }
        throw new org.omg.CORBA.BAD_PARAM("Narrow failed");
    }
    public static devise.InterfaceEnveloppeOD unchecked_narrow(final org.omg.CORBA.Object obj)
    {
        if (obj == null)
            return null;
        try
        {
            return (devise.InterfaceEnveloppeOD)obj;
        }
        catch (ClassCastException c)
        {
                devise._InterfaceEnveloppeODStub stub;
                stub = new devise._InterfaceEnveloppeODStub();
                stub._set_delegate(((org.omg.CORBA.portable.ObjectImpl)obj)._get_delegate());
                return stub;
        }
    }
}

            InterfaceEnveloppeODHolder.java
            InterfaceEnveloppeODOperations.java
            InterfaceEnveloppeODPOA.java

package devise;

/**
 *    Generated from IDL interface "InterfaceEnveloppeOD"
 *    @author JacORB IDL compiler V 2.2.3, 10-Dec-2005
 */

public abstract class InterfaceEnveloppeODPOA
    extends org.omg.PortableServer.Servant
    implements org.omg.CORBA.portable.InvokeHandler, devise.InterfaceEnveloppeODOperations
{
    static private final java.util.Hashtable m_opsHash = new java.util.Hashtable();
    static
    {
        m_opsHash.put ( "getObjectCORBA", new java.lang.Integer(0));
    }
    private String[] ids = {"IDL:devise/InterfaceEnveloppeOD:1.0"};
    public devise.InterfaceEnveloppeOD _this()
    {
        return devise.InterfaceEnveloppeODHelper.narrow(_this_object());
    }
    public devise.InterfaceEnveloppeOD _this(org.omg.CORBA.ORB orb)
    {
        return devise.InterfaceEnveloppeODHelper.narrow(_this_object(orb));
    }
    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: // getObjectCORBA
            {
                _out = handler.createReply();
                _out.write_Object(getObjectCORBA());
                break;
            }
        }
        return _out;
    }

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

InterfaceEnveloppeODPOATie.java

package devise;

import org.omg.PortableServer.POA;

/**
 *    Generated from IDL interface "InterfaceEnveloppeOD"
 *    @author JacORB IDL compiler V 2.2.3, 10-Dec-2005
 */

public class InterfaceEnveloppeODPOATie
    extends InterfaceEnveloppeODPOA
{
    private InterfaceEnveloppeODOperations _delegate;

private POA _poa;
    public InterfaceEnveloppeODPOATie(InterfaceEnveloppeODOperations delegate)
    {
        _delegate = delegate;
    }
    public InterfaceEnveloppeODPOATie(InterfaceEnveloppeODOperations delegate, POA poa)
    {
        _delegate = delegate;
        _poa = poa;
    }
    public devise.InterfaceEnveloppeOD _this()
    {
        return devise.InterfaceEnveloppeODHelper.narrow(_this_object());
    }
    public devise.InterfaceEnveloppeOD _this(org.omg.CORBA.ORB orb)
    {
        return devise.InterfaceEnveloppeODHelper.narrow(_this_object(orb));
    }
    public InterfaceEnveloppeODOperations _delegate()
    {
        return _delegate;
    }
    public void _delegate(InterfaceEnveloppeODOperations delegate)
    {
        _delegate = delegate;
    }
    public POA _default_POA()
    {
        if (_poa != null)
        {
            return _poa;
        }
        else
        {
            return super._default_POA();
        }
    }
    public org.omg.CORBA.Object getObjectCORBA()
    {
        return _delegate.getObjectCORBA();
    }

}

Node.java
NodeHelper.java

package devise;

/**
 *    Generated from IDL definition of struct "Node"
 *    @author JacORB IDL compiler 
 */

public final class NodeHelper
{
    private static org.omg.CORBA.TypeCode _type = null;
    public static org.omg.CORBA.TypeCode type ()
    {
        if (_type == null)
        {
            _type = org.omg.CORBA.ORB.init().create_struct_tc(devise.NodeHelper.id(),"Node",new org.omg.CORBA.StructMember[]{new org.omg.CORBA.StructMember("value", org.omg.CORBA.ORB.init().create_interface_tc("IDL:omg.org/CORBA/Object:1.0","Object"), null),new org.omg.CORBA.StructMember("premierFils", org.omg.CORBA.ORB.init().create_sequence_tc(0, org.omg.CORBA.ORB.init().create_recursive_tc("IDL:devise/Node:1.0")), null),new org.omg.CORBA.StructMember("frere", org.omg.CORBA.ORB.init().create_sequence_tc(0, org.omg.CORBA.ORB.init().create_recursive_tc("IDL:devise/Node:1.0")), null)});
        }
        return _type;
    }

public static void insert (final org.omg.CORBA.Any any, final devise.Node s)
    {
        any.type(type());
        write( any.create_output_stream(),s);
    }

public static devise.Node extract (final org.omg.CORBA.Any any)
    {
        return read(any.create_input_stream());
    }

public static String id()
    {
        return "IDL:devise/Node:1.0";
    }
    public static devise.Node read (final org.omg.CORBA.portable.InputStream in)
    {
        devise.Node result = new devise.Node();
        result.value=in.read_Object();
        int _lresult_premierFils0 = in.read_long();
        result.premierFils = new devise.Node[_lresult_premierFils0];
        for (int i=0;i<result.premierFils.length;i++)
        {
            result.premierFils[i]=devise.NodeHelper.read(in);
        }

int _lresult_frere1 = in.read_long();
        result.frere = new devise.Node[_lresult_frere1];
        for (int i=0;i<result.frere.length;i++)
        {
            result.frere[i]=devise.NodeHelper.read(in);
        }

return result;
    }
    public static void write (final org.omg.CORBA.portable.OutputStream out, final devise.Node s)
    {
        out.write_Object(s.value);
        
        out.write_long(s.premierFils.length);
        for (int i=0; i<s.premierFils.length;i++)
        {
            devise.NodeHelper.write(out,s.premierFils[i]);
        }

out.write_long(s.frere.length);
        for (int i=0; i<s.frere.length;i++)
        {
            devise.NodeHelper.write(out,s.frere[i]);
        }

}
}

            NodeHolder.java
            SensTaux.java
            SensTauxHelper.java

package devise;
/**
 *    Generated from IDL definition of enum "SensTaux"
 *    @author JacORB IDL compiler 
 */

public final class SensTauxHelper
{
    private static org.omg.CORBA.TypeCode _type = null;
    public static org.omg.CORBA.TypeCode type ()
    {
        if (_type == null)
        {
            _type = org.omg.CORBA.ORB.init().create_enum_tc(devise.SensTauxHelper.id(),"SensTaux",new String[]{"normale","inverse"});
        }
        return _type;
    }

public static void insert (final org.omg.CORBA.Any any, final devise.SensTaux s)
    {
        any.type(type());
        write( any.create_output_stream(),s);
    }

public static devise.SensTaux extract (final org.omg.CORBA.Any any)
    {
        return read(any.create_input_stream());
    }

public static String id()
    {
        return "IDL:devise/SensTaux:1.0";
    }
    public static SensTaux read (final org.omg.CORBA.portable.InputStream in)
    {
        return SensTaux.from_int(in.read_long());
    }

public static void write (final org.omg.CORBA.portable.OutputStream out, final SensTaux s)
    {
        out.write_long(s.value());
    }
}

SensTauxHolder.java
_InterfaceDeviseODStub.java

package devise;

/**
 *    Generated from IDL interface "InterfaceDeviseOD"
 *    @author JacORB IDL compiler V 2.2.3, 10-Dec-2005
 */

public class _InterfaceDeviseODStub
    extends org.omg.CORBA.portable.ObjectImpl
    implements devise.InterfaceDeviseOD
{
    private String[] ids = {"IDL:devise/InterfaceDeviseOD:1.0"};
    public String[] _ids()
    {
        return ids;
    }

public final static java.lang.Class _opsClass = devise.InterfaceDeviseODOperations.class;
    public int attr2()
    {
        while(true)
        {
        if(! this._is_local())
        {
            org.omg.CORBA.portable.InputStream _is = null;
            try
            {
                org.omg.CORBA.portable.OutputStream _os = _request("_get_attr2",true);
                _is = _invoke(_os);
                return _is.read_long();
            }
            catch( org.omg.CORBA.portable.RemarshalException _rx ){}
            catch( org.omg.CORBA.portable.ApplicationException _ax )
            {
                String _id = _ax.getId();
                throw new RuntimeException("Unexpected exception " + _id );
            }
            finally
            {
                this._releaseReply(_is);
            }
        }

else
        {
        org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke( "_get_attr2", _opsClass);
        if( _so == null )
            throw new org.omg.CORBA.UNKNOWN("local invocations not supported!");
            InterfaceDeviseODOperations _localServant = (InterfaceDeviseODOperations)_so.servant;
            int _result;
        try
        {
            _result = _localServant.attr2();
        }
        finally
        {
            _servant_postinvoke(_so);
        }
        return _result;
        }
        }

}

public void getDevise2(devise.DeviseDataHolder d)
    {
        while(true)
        {
        if(! this._is_local())
        {
            org.omg.CORBA.portable.InputStream _is = null;
            try
            {
                org.omg.CORBA.portable.OutputStream _os = _request( "getDevise2", true);
                _is = _invoke(_os);
                d.value = devise.DeviseDataHelper.read(_is);
                return;
            }
            catch( org.omg.CORBA.portable.RemarshalException _rx ){}
            catch( org.omg.CORBA.portable.ApplicationException _ax )
            {
                String _id = _ax.getId();
                throw new RuntimeException("Unexpected exception " + _id );
            }
            finally
            {
                this._releaseReply(_is);
            }
        }
        else
        {
            org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke( "getDevise2", _opsClass );
            if( _so == null )
                throw new org.omg.CORBA.UNKNOWN("local invocations not supported!");
            InterfaceDeviseODOperations _localServant = (InterfaceDeviseODOperations)_so.servant;
            try
            {
            _localServant.getDevise2(d);
            }
            finally
            {
                _servant_postinvoke(_so);
            }
            return;
        }

}

public devise.DeviseData getDevise()
    {
        while(true)
        {
        if(! this._is_local())
        {
            org.omg.CORBA.portable.InputStream _is = null;
            try
            {
                org.omg.CORBA.portable.OutputStream _os = _request( "getDevise", true);
                _is = _invoke(_os);
                devise.DeviseData _result = devise.DeviseDataHelper.read(_is);
                return _result;
            }
            catch( org.omg.CORBA.portable.RemarshalException _rx ){}
            catch( org.omg.CORBA.portable.ApplicationException _ax )
            {
                String _id = _ax.getId();
                throw new RuntimeException("Unexpected exception " + _id );
            }
            finally
            {
                this._releaseReply(_is);
            }
        }
        else
        {
            org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke( "getDevise", _opsClass );
            if( _so == null )
                throw new org.omg.CORBA.UNKNOWN("local invocations not supported!");
            InterfaceDeviseODOperations _localServant = (InterfaceDeviseODOperations)_so.servant;
            devise.DeviseData _result;            try
            {
            _result = _localServant.getDevise();
            }
            finally
            {
                _servant_postinvoke(_so);
            }
            return _result;
        }

}

public void attr1(int a)
    {
        while(true)
        {
        if(! this._is_local())
        {
            org.omg.CORBA.portable.InputStream _is = null;
            try
            {
                org.omg.CORBA.portable.OutputStream _os = _request("_set_attr1",true);
                _os.write_long(a);
                _is = _invoke(_os);
                return;
            }
            catch( org.omg.CORBA.portable.RemarshalException _rx ){}
            catch( org.omg.CORBA.portable.ApplicationException _ax )
            {
                String _id = _ax.getId();
                throw new RuntimeException("Unexpected exception " + _id );
            }
            finally
            {
                this._releaseReply(_is);
            }
        }

else
        {
            org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke( "_set_attr1", _opsClass);
            if( _so == null )
                throw new org.omg.CORBA.UNKNOWN("local invocations not supported!");
            InterfaceDeviseODOperations _localServant = (InterfaceDeviseODOperations)_so.servant;
                try
                {
                    _localServant.attr1(a);
                }
                finally
                {
                    _servant_postinvoke(_so);
                }
                return;
            }
        }

}

public int attr1()
    {
        while(true)
        {
        if(! this._is_local())
        {
            org.omg.CORBA.portable.InputStream _is = null;
            try
            {
                org.omg.CORBA.portable.OutputStream _os = _request("_get_attr1",true);
                _is = _invoke(_os);
                return _is.read_long();
            }
            catch( org.omg.CORBA.portable.RemarshalException _rx ){}
            catch( org.omg.CORBA.portable.ApplicationException _ax )
            {
                String _id = _ax.getId();
                throw new RuntimeException("Unexpected exception " + _id );
            }
            finally
            {
                this._releaseReply(_is);
            }
        }

else
        {
        org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke( "_get_attr1", _opsClass);
        if( _so == null )
            throw new org.omg.CORBA.UNKNOWN("local invocations not supported!");
            InterfaceDeviseODOperations _localServant = (InterfaceDeviseODOperations)_so.servant;
            int _result;
        try
        {
            _result = _localServant.attr1();
        }
        finally
        {
            _servant_postinvoke(_so);
        }
        return _result;
        }
        }

}

_InterfaceEnveloppeODStub.java

package devise;

/**
 *    Generated from IDL interface "InterfaceEnveloppeOD"
 *    @author JacORB IDL compiler V 2.2.3, 10-Dec-2005
 */

public class _InterfaceEnveloppeODStub
    extends org.omg.CORBA.portable.ObjectImpl
    implements devise.InterfaceEnveloppeOD
{
    private String[] ids = {"IDL:devise/InterfaceEnveloppeOD:1.0"};
    public String[] _ids()
    {
        return ids;
    }

public final static java.lang.Class _opsClass = devise.InterfaceEnveloppeODOperations.class;
    public org.omg.CORBA.Object getObjectCORBA()
    {
        while(true)
        {
        if(! this._is_local())
        {
            org.omg.CORBA.portable.InputStream _is = null;
            try
            {
                org.omg.CORBA.portable.OutputStream _os = _request( "getObjectCORBA", true);
                _is = _invoke(_os);
                org.omg.CORBA.Object _result = _is.read_Object();
                return _result;
            }
            catch( org.omg.CORBA.portable.RemarshalException _rx ){}
            catch( org.omg.CORBA.portable.ApplicationException _ax )
            {
                String _id = _ax.getId();
                throw new RuntimeException("Unexpected exception " + _id );
            }
            finally
            {
                this._releaseReply(_is);
            }
        }
        else
        {
            org.omg.CORBA.portable.ServantObject _so = _servant_preinvoke( "getObjectCORBA", _opsClass );
            if( _so == null )
                throw new org.omg.CORBA.UNKNOWN("local invocations not supported!");
            InterfaceEnveloppeODOperations _localServant = (InterfaceEnveloppeODOperations)_so.servant;
            org.omg.CORBA.Object _result;            try
            {
            _result = _localServant.getObjectCORBA();
            }
            finally
            {
                _servant_postinvoke(_so);
            }
            return _result;
        }

}

      runChannel.bat
      runConsommer.bat
      runNS.bat
      runProducter.bat
      runServerDevise.bat
      server.idl

module devise 
{
        // Exemple d'un short
        typedef short Entier;

// Exemple d'une données récursive (obligation d'utiliser la sequence)
        struct Node {
                Object value;
                sequence<Node> premierFils;
                sequence<Node> frere;
        };

// Exemple d'une énumération
        enum SensTaux
        {
                normale,
                inverse
        };

// La données de devise utilisée dans l'IDL
        struct DeviseData {
                string   nom;
                double   taux;
                SensTaux sens;
        };

// Un exemple d'une séquence de devise
        typedef sequence<DeviseData> DesDevises;

// L'interface de la DEVISE                        
        interface InterfaceDeviseOD 
        {
                // Retourne une devise (par valeur de la méthode)
                DeviseData getDevise();

// Retourne une devise (par référence du paramètre)
                void getDevise2(out DeviseData d);

// Exemples de deux attributs IDL
                //
                attribute long attr1;
                readonly attribute long attr2;  // cett attribut est en readonly
        };

// L'interface d'une enveloppe contenant une référence CORBA
        //
        interface InterfaceEnveloppeOD
        {
                Object getObjectCORBA();
        };
};

Cours d'Informatique par Jacques LAFORGUE

Retour

Télécharger

Cours d'Informatique
par Jacques LAFORGUE