---

JRMITSHandler.java

Go to the documentation of this file.

/***
 * Jonathan: an Open Distributed Processing Environment 
 * Copyright (C) 1999-2000 France Telecom R&D
 * 
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2 of the License, or (at your option) any later version.
 * 
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * 
 * Release: 3.0
 *
 * Contact: jonathan@objectweb.org
 *
 * Author: Bruno Dumant
 *
 * with contributions from:
 *   Alexis Chemin
 *   Kathleen Milsted
 *   Guy Vachet
 * 
 */
package org.objectweb.jeremie.libs.services.CosTransactions.handler;

import org.objectweb.jonathan.apis.kernel.Context;
import org.objectweb.jonathan.apis.kernel.Element;
import org.objectweb.jonathan.apis.kernel.JonathanException;
import org.objectweb.jonathan.apis.kernel.InternalException;
import org.objectweb.jonathan.apis.presentation.MarshallerFactory;
import org.objectweb.jonathan.apis.presentation.Marshaller;
import org.objectweb.jonathan.apis.presentation.UnMarshaller;
import org.objectweb.jonathan.apis.resources.Chunk;
import org.objectweb.jonathan.libs.helpers.MessageHelpers;

import org.objectweb.david.apis.services.handler.Service;
import org.objectweb.david.libs.services.CosTransactions.handler.TSHandler;

import org.omg.IOP.ServiceContext;
import org.omg.CosTransactions.PropagationContext;
import org.omg.CosTSPortability.Sender;
import org.omg.CosTSPortability.Receiver;

import java.io.ByteArrayInputStream;
import java.io.ObjectInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectOutputStream;

import java.util.Properties;
import java.util.Enumeration;
import java.util.Vector;

public class JRMITSHandler extends TSHandler {

   protected MarshallerFactory mf;

   protected JRMITSHandler(Context c,Object[] used_components)
      throws JonathanException {
      initialize(used_components);
   }
   
   private void initialize(Object[] used_components) 
      throws JonathanException {
      int sid = ((Integer) used_components[0]).intValue();
      if (sid != Integer.MAX_VALUE) {
         service_id = sid;
      }
   
      try {
         Sender sender = (Sender) used_components[1];
         if (sender !=  null) {
            identify_sender(sender);
         }
         Receiver receiver = (Receiver) used_components[2];
         if (receiver !=  null) {
            identify_receiver(receiver);
         }
         mf = (MarshallerFactory) used_components[3];
      } catch (Exception e) {
         throw new JonathanException(e);
      }
   }
   
   protected ServiceContext encodeContext(PropagationContext ctx) {
      if (ctx == null) {
         return null;
      }
      Marshaller marshaller = mf.newMarshaller();
      byte[] byteArray = null;
      try {
         marshaller.writeValue(ctx);
         byteArray = MessageHelpers.copy(marshaller);
         marshaller.close();
      } catch (Exception e) {
         System.err.println("JRMITSHandler.encodeContext: exception");
         e.printStackTrace();
      }
      return new ServiceContext(service_id, byteArray);
   }
   
   protected PropagationContext decodeContext(ServiceContext sc) {
      if ((sc==null) || (sc.context_data==null) || (sc.context_data.length==0)) {
         return null;
      }
      PropagationContext ctx = null;
      byte[] byteArray = sc.context_data;
      UnMarshaller unmarshaller = 
         mf.newUnMarshaller(new Chunk(byteArray, 0, byteArray.length), 0);
      try {
         ctx = (PropagationContext) unmarshaller.readValue();
         unmarshaller.close();
      } catch (Exception e) {
         System.err.println("JRMITSHandler.decodeContext: exception");
         System.err.println(e.toString() + "\n");
      }
      return ctx;
   }
   
}

---