Définition d'un thread de réception d'événements

Vous devez vous assurer, au niveau du code, que les événements sont reçus sur un thread distinct, afin que votre application puisse continuer d'exécuter d'autres tâches tandis que le thread d'événements attend la notification de rappel d'événements.

La configuration XML est abordée plus loin dans ce chapitre.

Étapes

1. Dans votre code, définissez une sous-classe Thread appelée EventReceptionThread qui crée une classe ServerSocket et attend que les événements arrivent sur le socket.

   Dans cette partie du code, les événements ne sont ni lus ni traités. La lecture et le traitement des événements sont abordés plus loin dans ce chapitre. La classe EventReceptionThread crée une classe ServerSocket sur une adresse générique de protocole inter-réseau. EventReceptionThread conserve également l'objet CrnpClient en référence afin de pouvoir lui transmettre des événements à traiter.

   class EventReceptionThread extends Thread
   {
           public EventReceptionThread(CrnpClient clientIn) throws IOException
           {
                   client = clientIn;
                   listeningSock = new ServerSocket(client.localPort, 50,
                       InetAddress.getLocalHost());
           }
   
           public void run()
           {
                   try {
                           DocumentBuilder db = client.dbf.newDocumentBuilder();
                           db.setErrorHandler(new DefaultHandler());
   
                           while(true) {
                                   Socket sock = listeningSock.accept();
                                   // Construct event from the sock stream and process it
                                   sock.close();
                           }
                           // UNREACHABLE
   
                   } catch (Exception e) {
                           System.out.println(e);
                           System.exit(1);
                   }
           }
   
           /* private member variables */
           private ServerSocket listeningSock;
           private CrnpClient client;
   }

2. Créez un objet createEvtRecepThr.

   private void createEvtRecepThr() throws Exception
   {
           evtThr = new EventReceptionThread(this);
           evtThr.start();
   }