class ModulSSL {
           public static StartTLSSocketStreamSource crearSSL(
           JID servidor, int port) throws IOException,
           CouldNotConfigureSSLException
        }

        private static SSLContext obtainContext()
        throws CouldNotConfigureSSLException {
           SSLContext ctx = null;

           try {
              ctx = SSLContext.getInstance("SSL");
              ctx.init(null, new TrustManager[]
                 {new TrustEverythingManager()}, new SecureRandom());
           } catch (Exception e) {
              throw (new CouldNotConfigureSSLException());
           }

           return ctx;
        }

        class TrustEverythingManager implements X509TrustManager {
           public TrustEverythingManager() {
           }

           public X509Certificate[] getAcceptedIssuers() {
              return new X509Certificate[0];
           }

           public void checkClientTrusted(X509Certificate[] certs,
           String authType) throws CertificateException {
           }

           public void checkServerTrusted(X509Certificate[] certs,
           String authType) throws CertificateException {
           }
        }

        class ProvaSSL {
           public static void main(String args[]) throws Exception {
              JSOImplementation jso = JSOImplementation.getInstance();
              Stream conn = jso.createStream(Utilities.CLIENT_NAMESPACE);
              StreamDataFactory sdf = conn.getDataFactory();
              JID cliente = sdf.createJID("grf@jabber.org/PXCJabber");
              JID servidor = sdf.createJID(cliente.getDomain());

              //establim la conexio SSL amb el servidor
              conn.connect(ModulSSL.crearSSL(servidor, 5223));
              System.out.println("conectat");
              conn.open();
              System.out.println("obert");

              //fem login
              AuthFeatureConsumer au = new AuthFeatureConsumer(servidor,
                  cliente.getNode(), "grf", cliente.getResource());
              au.authenticate(conn, conn);

              //Obtenim la llista de contactes
              InfoQuery iq = (InfoQuery)sdf.createPacketNode(
                  sdf.createNSI("iq", conn.getDefaultNamespace()),
                  InfoQuery.class);
              iq.setType(InfoQuery.GET);
              IdentityGenerator idgen = new IdentityGenerator();
              iq.setID(idgen.generate("roster"));
              RosterQuery rosterq = (RosterQuery)sdf.createExtensionNode(
                  sdf.createNSI("query", RosterQuery.NAMESPACE),
                  RosterQuery.class);
              iq.add(rosterq);
              iq = (InfoQuery)PacketMonitor.sendAndWatch(conn, iq);
              if ((iq == null) || (iq.getType() != InfoQuery.RESULT)) {
                 System.out.println("No s'ha pogut obtenir la
                     llista de contactes");
                 return;
              }
              rosterq = (RosterQuery)iq.getExtension(RosterQuery.class);
              List contactes = rosterq.listElements(RosterItem.class);
              Iterator iter = contactes.iterator();
              System.out.println("Roster:");
              while (iter.hasNext()) {
                 RosterItem contacte = (RosterItem)iter.next();
                 System.out.println("\t" + contacte.getJID());
              }

              //Notifiquem el nostre estat
              Presence pre = (Presence)sdf.createPacketNode(
                  sdf.createNSI("presence", conn.getDefaultNamespace()));
              pre.setStatus("I am available");
              conn.send(pre);

              //Esperem un segon
              Thread.currentThread().sleep(1000);

              //Cambien l'estat per indicar que ens n'anem
              pre = (Presence)sdf.createPacketNode(sdf.createNSI(
                  "presence", conn.getDefaultNamespace()));
              pre.setType(Presence.UNAVAILABLE);
              pre.setStatus("good-bye!");
              conn.send(pre);

              //Tanquem la conexio
              try {conn.close();} catch (Exception e) {}
              System.out.println("Tancat");
              conn.disconnect();
              System.out.println("Desconectat");
           }
        }

        class Cripto {
           public Cripto(Stream conn, String fitxer, String clau) {...}
           public Message xifrarMissatge(Message msg) {...}
           public Message desxifrarMissatge(Message msg) {...}
        }

        public Cripto(Stream conn, String fitxer, String clau)
           throws StreamException, IOException, VCardNotFoundException

        public Message xifrarMissatge(Message msg)
           throws StreamException, UserNotSupportEncryptionException,
           MessageWithoutRecipientException

        <message to='grf@jabber.org' from='guillemrf@jabberes.org'>
           <body>Esto es un mensaje de prueba</body>
        </mensaje>

        <message to='grf@jabber.org' from='guillemrf@jabberes.org'>
           <body>This message has been encrypted by PXCJabber</body>
           <x xmlns='jabber:x:encrypted'>
              mensaje_cifrado
           </x>
        </mensaje>

        mensaje_cifrado = cifrado_rsa(clave_sesion) +
                          cifrado_aes(mensaje_original+firma, clave_sesion)

        public Message desxifrarMissatge(Message msg)
        throws StreamException, UserNotSupportEncryptionException,
           InvalidEncryptedMessageFormatException,
           SignatureVerificationFailedException,
           MessageWithoutSenderException

        class VCard {
           public static VCard getVCard(Stream conn)
           public static VCard getVCard(Stream conn, JID user)
           public static void setVCard(Stream conn, VCard vcard)
           public VCard(Extension vcard)
           public Clau[] getCredentials()
           public void setCredentials(ClauPublica publicKey,
              ClauFirma signatureKey)
        }

        ...
        Cripto c = new Cripto(conn, "claus", "guillem");
        System.out.println("Modul criptografic inicialitzat");
        Message msg1 = (Message)sdf.createPacketNode(
           sdf.createNSI("message", conn.getDefaultNamespace()),
           Message.class);
        msg1.setTo(sdf.createJID("grf@jabber.org"));
        msg1.setFrom(sdf.createJID("guillemrf@jabberes.org"));
        msg1.setBody("Això és un missatge de prova");

        System.out.println("Missatge abans:");
        System.out.println(msg1.toString());

        System.out.println("Xifrant missatge");
        Message aux = c.xifrarMissatge(msg1);

        System.out.println("Missatge xifrat:");
        System.out.println(aux.toString());

        System.out.println("Desxifrant missatge");
        Message msg2 = c.desxifrarMissatge(aux);

        System.out.println("Missatge despres:");
        System.out.println(msg2.toString());

        System.out.println("Comparant");
        if (msg2.toString().equals(msg1.toString())) {
                System.out.println("OK");
        } else {
                System.out.println("Fallada");
        }
        ...

  public void Imprimir(String rusr, String rpsr, String rhost) {

        //Creamos las instancias de los objetos del formulario...
        txt_usr = new JLabel("Usuario:");
        txt_psr = new JLabel("Password:");
        txt_host = new JLabel("Host:");
        usr = new JTextField();
        host = new JTextField();
        psr = new JPasswordField(20);
        ssl = new JCheckBox("Usar SSL", true);
        btn_aceptar = new JButton("Loginar >>");

        //Ponemos los valores por defecto pasados por parámetro...
        host.setText(rhost);
        usr.setText(rusr);
        psr.setText(rpsr);
        getContentPane().setLayout(null);

        //Establecemos las coordenadas de posición absoluta...
        txt_usr.setBounds(10,5,65,25);
        txt_psr.setBounds(10,35,65,25);
        txt_host.setBounds(10,65,65,25);
        usr.setBounds(100,5,200,25);
        psr.setBounds(100,35,200,25);
        host.setBounds(100,65,200,25);
        ssl.setBounds(98,95,100,25);
        btn_aceptar.setBounds(200,95,100,25);

        //Añadimos los componentes en el formulario...
        getContentPane().add(usr);
        getContentPane().add(ssl);
        getContentPane().add(txt_usr);
        getContentPane().add(psr);
        getContentPane().add(txt_psr);
        getContentPane().add(host);
        getContentPane().add(txt_host);
        getContentPane().add(btn_aceptar);

        //Asignamos el evento del boton...
        btn_aceptar.addActionListener( this );
  }

  //Retorna el usuario...
  public String getUsr() {
        return usr.getText();
  }

  //Retorna el password...
  public String getPsr() {
        return psr.getText();
  }

  //Retorna el host...
  public String getHost() {
        return host.getText();
  }

  //Retorna si se usa SSL...
  public boolean getSSL() {
        return ssl.isSelected();
  }

  //Se genera el evento del boton..
  public void actionPerformed( ActionEvent evt ) {
        System.out.println( "Usr: " + getUsr() );
        System.out.println( "Psr: " + getPsr() );
        System.out.println( "Host: " + getHost() );
        System.out.println( "SSL: " + getSSL() );
  }

  //Main de pruebas...
  public static void main( String args[] ) {

    //Creo la ventana con el título pasado por parámetro...
    JFrame ventana = new Login("Login de Usuario");

    ventana.addWindowListener( new WindowAdapter() {
      public void windowClosing( WindowEvent evt ){
                System.exit( 0 );
      }
    } );

    //Tamaño de la ventana...
    ventana.setSize( 320,170 );
    ventana.setVisible( true );
  }

    private String[] iconos = {":)",":(",":S",":O",":R",":P"};

  //Visualiza los objetos del formulario...
  public void Imprimir() {

    //Iniciamos el listado de conversa...
    lista = new JTextPane();

    //Establecemos los estilos de texto...
    iniciarEstilos(lista);

    //Le añadimos el scroll...
    lista.setEditable(false);
    jp = new JScrollPane(lista);
    jp.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);

    //Creamos el botón y mensaje...
    mensaje = new JTextField();
    btn_enviar = new JButton("Enviar >>");

    getContentPane().setLayout(null);

    //Establecemos las coordenadas absolutas...
    mensaje.setBounds(10,215,270,40);
    btn_enviar.setBounds(285,215,95,40);
    jp.setBounds(10,10,370,200);

    //Añadimos los componentes al formulario...
    getContentPane().add(mensaje);
    getContentPane().add(btn_enviar);
    getContentPane().add(jp);

    //Gestionamos los eventos...
    btn_enviar.addActionListener( this );
    mensaje.addActionListener( this );
  }

  //Inicia los estilos del listado...
  protected void iniciarEstilos(JTextPane textPane) {
        Style def = StyleContext.getDefaultStyleContext().
                    getStyle(StyleContext.DEFAULT_STYLE);

        //Estilo por defecto...
        Style regular = textPane.addStyle("regular", def);
        StyleConstants.setFontSize(def, 14);
        StyleConstants.setFontFamily(def, "SansSerif");

        //Estilo recibir de otro cliente...
        Style s = textPane.addStyle("recibir", regular);
        StyleConstants.setItalic(s, true);

        //Estilo enviar a otro cliente...
        s = textPane.addStyle("enviar", regular);
        StyleConstants.setBold(s, true);

        //Cargo las imagenes de los smylers...
        for (int i=0; i<iconos.length; i++) {
          s = textPane.addStyle(iconos[i], regular);
          StyleConstants.setAlignment(s, StyleConstants.ALIGN_LEFT);
          StyleConstants.setIcon(s, new ImageIcon("imagenes/"+i+".gif"));
        }
    }

  //Método llamado cuando envío datos al otro cliente...
  public void Enviar(String txt) {

        //Agrego el texto en la conversación...
        PonTextoEnLista(txt + newline, "enviar");
  }

  //Método llamado cuando recibo datos del otro cliente...
  public void Recibir(String txt) {

        //Agrego el texto en la conversación...
        PonTextoEnLista(txt + newline, "recibir");
  }

  //Pone el texto en la lista...
  public void PonTextoEnLista(String txt, String estilo) {
      Document doc = lista.getDocument();
      try {
        //Genero la expresión regular para realizar el split...
        String reg = new String();
        for (int i=0; i<iconos.length; i++) {
                reg = reg + iconos[i];
                if (i < (iconos.length -1)) {
                  reg = reg + "|";
                }
        }
        reg = reg.replace("(","\\(");
        reg = reg.replace(")","\\)");

        String[] tx = txt.split(reg);
        String st;

        int lon = 0;
        for (int i=0;i<tx.length;i++) {
                //Pongo solo el texto...
                lista.setCaretPosition(doc.getLength());
                doc.insertString(doc.getLength(), tx[i],
                                 lista.getStyle(estilo));
                lista.setLogicalStyle(lista.getStyle(estilo));

                lon = lon + tx[i].length();
                if (lon+2 < txt.length()) {
                        st = txt.substring(lon, lon+2);

                        //Pongo la carita...
                        lista.setCaretPosition(doc.getLength());
                        doc.insertString(doc.getLength(), " ",
                                         lista.getStyle(st));
                        lista.setLogicalStyle(lista.getStyle(st));

                        //Pongo espacio...
                        lista.setCaretPosition(doc.getLength());
                        doc.insertString(doc.getLength(), " ",
                                         lista.getStyle(estilo));
                        lista.setLogicalStyle(lista.getStyle(estilo));

                        lon = lon + st.length();
                 }

        }
      } catch (BadLocationException ble) {
            System.err.println("No puedo enviar nada...");
      }
  }

  //Main para pruebas...
  public static void main( String argv[] ) throws Exception {
    JFrame ventana = new Chat("Privado conmigo");

    ventana.addWindowListener( new WindowAdapter() {
      public void windowClosing( WindowEvent evt ){
        System.exit( 0 );
      }
    } );

    //Tamaño de la ventana...
    ventana.setSize( 400,300 );
    ventana.setVisible( true );
  }

public NuevoContacto(MainGUI mg)
{
        super("Agregar contacto");
        txt_jid = new JLabel("JID:");
        jid = new JTextField();
    btn_aceptar = new JButton("Aceptar >>");
    btn_cancelar = new JButton("Cancelar");

        getContentPane().setLayout(null);

        txt_jid.setBounds(10,10,35,25);
        jid.setBounds(40,10,200,25);

        btn_aceptar.setBounds(40,45,90,25);
        btn_cancelar.setBounds(140,45,90,25);

        getContentPane().add(jid);
        getContentPane().add(txt_jid);
        getContentPane().add(btn_aceptar);
        getContentPane().add(btn_cancelar);

        btn_aceptar.addActionListener( mg ); //Aceptar es capturado por MainGUI
        btn_cancelar.addActionListener(this);//Cancelar cierra la ventana
        setSize( 260,120 );
        setVisible( true );

}

public void actionPerformed (ActionEvent e)
{
          hide();
}

public String getJid()
{
        return jid.getText();
}

NuevaConexion nc;
        .
        .
        .
if (e.getActionCommand().equals("Agregar un contacto"))
{
        nc = new NuevoContacto (this);
}

if (e.getActionCommand().equals("Aceptar >>"))
{
        nc.hide();
        System.out.println("JID introducido: "+nc.getJid());
}

        public ThreadConexion (conexion con)
        {
                try
                {
                        c=con;
                        conn = c.obtConex();
                }
                catch(Exception e)
                {
                        System.out.println("(ThreadConexion)Error: "+e.getMessage());
                }
        }

public void run()
{
        while (c.isContinue())
        {
                Packet      data = null;
                try
                {
                        conn.process();
                        try { Thread.sleep(10); } catch (InterruptedException ie) {}
                        while ((data = c.deque()) != null)
                    conn.send(data);
                }
                catch(Exception e)
                {
                        System.out.println("(ThreadConexion)Warning: "+e.getMessage());
                }
        }
}

public void desconectar()
{
        c.desconectar();
}

    //Datos de conexion
        String jid;
        String passwd;
        String host;
        int port;

        //Lista de contactos
        ArbolContactos lc;

        //Datos de gestion JSO
        conexion _conexion;
        Stream conn=null;
        StreamDataFactory   sdf = null;
        interactua _interactua = null;

        ThreadConexion buclePrincipal=null;

        //Formularios auxiliares
        NuevoContacto nc; //Agregar contacto
        Login ventana;          //Conectar

          public MainGUI()
        {
                super("PXC Jabber Client!");

        MouseListener ml = new MouseAdapter(){
                public void mousePressed(MouseEvent e) {
                        if(e.getClickCount() == 2)
                        {
                                if (_interactua.contactStatus(lc.getContactoSeleccionado())!=null)
                                {
                                        String tmp = new String(_interactua.contactStatus(lc.getContactoSeleccionado()));
                                        if ((tmp.compareTo("offline")!=0) && (tmp.compareTo("unsubscribed")!=0))
                                        {
                                                Chat a = new Chat(lc.getContactoSeleccionado(), _conexion, _interactua);
                                                a.show();
                                        }
                                }
                        }
                }
        };

          lc = new ArbolContactos(ml);
        JPanel cp = new JPanel();
        cp.setLayout(new BorderLayout());
                .
                .
                .
        (creación del menú)
                .
                .
        cp.add(lc, java.awt.BorderLayout.CENTER);

        setContentPane(cp);
        setJMenuBar (jmb);

        setSize(300,500);

        addWindowListener( new WindowAdapter() {
            public void windowClosed( WindowEvent evt ){
                  System.exit(0);}});
        }

          if (e.getActionCommand().equals("Opcion a capturar"))
        {
                ... (código a ejecutar) ...
        }

        ventana = new Login("Login de Usuario", this);
        ventana.show();

        if (buclePrincipal!=null)
        {
                _conexion.desconectar();
                buclePrincipal.desconectar();

                //Esperamos a que finalice el thread
                try { Thread.sleep(10); } catch (InterruptedException ie) {}
                buclePrincipal=null;
                lc.clear();
        }

        // Desconectamos
        if (buclePrincipal!=null)
                _conexion.desconectar();
        System.exit(0);

        nc = new NuevoContacto (this);

        Presence pre = (Presence)sdf.createPacketNode(sdf.createNSI("presence", conn.getDefaultNamespace()));
        pre.setStatus("available");
        pre.setShow("available");
        try
        {
                conn.send(pre);
        }
        catch(StreamException ex)
        {
                JabberException.mensajeError("Error al enviar cambio de estado: "+ex.getMessage());
        }

        ventana.hide();
        getData();
        connect();

        nc.hide();
        _interactua.nuevoContacto(nc.getJid());

void getData()
{
        jid = new String(ventana.getUsr());
        passwd = new String(ventana.getPsr());
        host = new String(ventana.getHost());
        port = 5222;
}

        private void connect()
        {
                try
                {
                        //Creamos la conexion con el servidor
                        _conexion = new conexion (jid.concat("/PXCCLient"),passwd,host,5222);
                        _conexion.login();


                        conn = _conexion.obtConex();
                        sdf = conn.getDataFactory();

                        contactos MisAmigosC=new contactos(_conexion);

                        /* DEFINIMOS UN ESTADO DE PRESENCIA INICIAL */
                        Presence pre = (Presence)sdf.createPacketNode(sdf.createNSI("presence", conn.getDefaultNamespace()));
                        pre.setStatus("available");
                        conn.send(pre);

                        _interactua = new interactua(_conexion, MisAmigosC);

                        //Lanzamos el thread de conexion
                        buclePrincipal = new ThreadConexion(_conexion);
                        buclePrincipal.start();

                        lc.actualizar(MisAmigosC);

                        _interactua.addArbolContactos(lc);
                }
                catch (UnknownHostException e)
                {
                        JabberException.mensajeError("Host desconocido");
                }
                catch(Exception e)
                {
                        JabberException.mensajeError("Error al conectar con el servidor: "+e.getMessage());
                }
        }

public ArbolContactos(MouseListener ml)
{
        super(new GridLayout(1,0));

        rootNode = new DefaultMutableTreeNode("Contactos");
        treeModel = new DefaultTreeModel(rootNode);

        tree = new JTree(treeModel);
        tree.setEditable(false);
        tree.getSelectionModel().setSelectionMode
                (TreeSelectionModel.SINGLE_TREE_SELECTION);
        tree.setShowsRootHandles(true);
        cg = new ContactoGrafico();
        tree.setCellRenderer( cg );

        JScrollPane scrollPane = new JScrollPane(tree);
        add(scrollPane);


                tree.addMouseListener(ml);
    }

        public String getContactoSeleccionado()

        public void clear()

        public void actualizar(contactos _contactos)

public Component getTreeCellRendererComponent( JTree arbol,
                     Object valor,boolean seleccionado,boolean expandido,
                     boolean rama,int fila,boolean conFoco )
        {
                      // Hay que encontrar el nodo en que estamos y coger el
                      // texto que contiene

                     DefaultMutableTreeNode nodo = (DefaultMutableTreeNode)valor;
                     String texto = new String((String)nodo.getUserObject());

                     this.seleccionado = seleccionado;
                     if( !seleccionado )
                            setForeground( Color.black );
                     else
                            setForeground( Color.white);
                     if (nodo != null)
                     {
                             if (texto.equals("Contactos"))
                                       setIcon(icono[0]);
                             else
                                     setIcon(icono[getIconByStatus(texto)]);
                             setText(texto);
                     }
                     return(this);
        }

public void paint( Graphics g )
{
        Color color;
        Icon currentI = getIcon();

        // Fijamos el colos de fondo
        color = seleccionado ? Color.red : Color.white;
        g.setColor( color );
        // Rellenamos el rectángulo que ocupa el texto sobre la
        // celda del árbol
        g.fillRect( 0,0,getWidth()-1,getHeight()-1 );

        super.paint( g );
}

public conexion _conexion;
public contactos _contactos;

Vector conversaciones = null;
ArbolContactos ac = null;

class interactua {
private void IniEscucha() {...}
private String limpia_resource (String entrada) {...}

private String limpia_node (String entrada) {...}
public void addConversacion(Chat nc) {...}
public void addArbolContactos(ArbolContactos a){...}
private Chat encuentraConversacion(String jid){...}
public String contactStatus(String jid){...}
public void nuevoContacto(String jid){...}
private interactua getInteractua(){...}

public interactua (conexion _conexion1, contactos _contactos1)  {...}

_conexion=_conexion1;
_contactos=_contactos1;
IniEscucha();

try {
watcher = new Myxpl(sdf, "app:message[app:body]", _conexion)  {
public void packetMatched(PacketEvent evt)
{
   Message     in = (Message)evt.getData();
   String      temp;
   mensajes _mensaje = new mensajes();
   mensajes _mensaje = new mensajes(_conexion, "pxc_claves", "pxc");
   temp = _mensaje.recibir_mensaje(_conexion,in);
   System.out.println("He recibido: " + temp);
   Chat tmp = encuentraConversacion(from.getNode());
   if (tmp!=null)
      tmp.Recibir(temp);
   else
   {
        System.out.println("Chat iniciado por: "+limpia_resource(from.toString()));
        Chat a = new Chat(limpia_resource(from.toString()), _conexion, getInteractua());
        addConversacion(a);
        a.show();
        a.Recibir(temp);
  }
}

        if (conversaciones == null)
                conversaciones = new Vector();
        conversaciones.add(nc);

...
if (conversaciones == null)
return null;
String tmp = new String();
for (int i=0; i<conversaciones.size(); i++)
{
  tmp = limpia_node(((Chat)(conversaciones.get(i))).getChateante());
  if ((limpia_node(((Chat)(conversaciones.get(i))).getChateante()).compareTo(jid))==0)
{
  return (Chat)conversaciones.get(i);
}
}
return null;
...

try {
watcher = new Myxpl(sdf, "app:presence",_conexion) {
public void packetMatched(PacketEvent evt) {
Presence    in = (Presence)evt.getData();
Presence    out;
Packet.Type type = in.getType();

if (type == Presence.SUBSCRIBE) //alguien quiere darnos de alta
{if (JabberException.mensajeSiNo(in.getFrom().toString()+" quiere agregarle a su lista de contactos. ¿Acepta?")==0)
{
  out = (Presence)in.copy();
  out.reset();
  out.setTo(in.getFrom());
  out.setType(Presence.SUBSCRIBED);
  _conexion.enque(out);
  out = (Presence)in.copy();
  out.reset();
  out.setTo(in.getFrom());
  out.setType(Presence.SUBSCRIBE);
  _conexion.enque(out);
  _contactos.limpiarContactos();
  try{
              _contactos.obtenerContactos(_conexion);
     }
  catch(PacketException e)
{JabberException.mensajeError("Error al actualizar la lista de contactos: "+e.getMessage());
}  catch(StreamException e)
{JabberException.mensajeError("Error al actualizar la lista de contactos: "+e.getMessage());
} ac.actualizar(_contactos);
}

...
else if   (type == Presence.UNSUBSCRIBE) {
out = (Presence)in.copy();
out.reset();
out.setTo(in.getFrom());
out.setType(Presence.UNSUBSCRIBED);
_conexion.enque(out);
out = (Presence)in.copy();
out.reset();
out.setTo(in.getFrom());
out.setType(Presence.UNSUBSCRIBE);
_conexion.enque(out);
}
...

...
else
{   JID remitente;
    String estado;
    remitente = in.getFrom();
    estado=in.getStatus();
    _contactos.mod_contacto(limpia_resource(remitente.toString()),estado);
...

private String limpia_resource (String entrada)
{        String salida[]=entrada.split("/");
        return salida[0];
}

private String limpia_node (String entrada)
{
  String salida[]=entrada.split("@");
  return salida[0];
}

...
Stream conn = _conexion.obtConex();
StreamDataFactory sdf = conn.getDataFactory();
JID to;
Presence pre = (Presence)sdf.createPacketNode(sdf.createNSI("presence", conn.getDefaultNamespace()));
...

...
try
{
  to = new JID(jid);
  pre.setTo(to);
  pre.setType(Presence.SUBSCRIBE);
  _conexion.enque(pre);
}
catch (JIDFormatException e)
{
  JabberException.mensajeError("Error en el formato del JID del contacto");
}
...

...
try {
watcher = new Myxpl(sdf, "app:message[app:body]", _conexion)  {
public void packetMatched(PacketEvent evt)
{
  Message     in = (Message)evt.getData();
  String      temp;
  mensajes _mensaje = new mensajes();
  temp= _mensaje.recibir_mensaje(_conexion,in);
  System.out.println(in);
  conn.addPacketListener(PacketEvent.RECEIVED, watcher);
} catch (SAXPathException spe) {
}
...

<message from='nateng@jabber.org/Gaim' to='ss@jabber.org' type='chat' xml:lang='en-US'><x xmlns='jabber:x:event'><composing/></x><body>HOLA</body><html xmlns='http://jabber.org/protocol/xhtml-im'><body xmlns='http://www.w3.org/1999/xhtml'>hola</body></html></message>

<message from='nateng@jabber.org/Gaim' to='ss@jabber.org/PXCCLient' type='chat' xml:lang='en-US'><x xmlns='jabber:x:event'><composing/></x><body>HOLA_2</body><html xmlns='http://jabber.org/protocol/xhtml-im'><body xmlns='http://www.w3.org/1999/xhtml'>HOLA_2</body></html></message>

<message from='nateng@jabber.org/Gaim' to='ss@jabber.org/PXCCLient' type='chat' xml:lang='en-US'><x xmlns='jabber:x:event'><composing/></x><body>:-;'ç{}[]`+?¿'¡</body><html xmlns='http://jabber.org/protocol/xhtml-im'><body xmlns='http://www.w3.org/1999/xhtml'>:-;'ç{}[]`+?¿'¡</body></html></message>

<presence from='nateng@jabber.org/Gaim' to='ss@jabber.org' xml:lang='en-US'><show>away</show><status>Sorry, I ran out for a bit!</status><x xmlns='jabber:x:delay' from='nateng@jabber.org/Gaim' stamp='20041207T18:21:25'/></presence>

<presence from='nateng@jabber.org/Gaim' to='ss@jabber.org' xml:lang='en-US'><show>away</show></presence>

<presence from='nateng@jabber.org/Gaim' to='ss@jabber.org' type='unavailable' xml:lang='en-US'><status>Logged out</status></presence>

<presence from='nateng@jabber.org/Gaim' to='ss@jabber.org' xml:lang='en-US'/>
<presence from='nateng@jabber.org/Gaim' to='ss@jabber.org' xml:lang='en-US'><x xmlns='jabber:x:delay' from='nateng@jabber.org/Gaim' stamp='20041207T18:23:57'/></presence>

private Stream                      _Conn;
private StartTLSSocketStreamSource  _TLS;
private JID                         _JID;
private String                      _Password;
private boolean             _Loggedin;
private IdentityGenerator   _IdGen = new IdentityGenerator();
private boolean             _Continuar;
private List                _PacketQueue = new java.util.LinkedList();
private long                _INICIO;
public boolean        desconectarse=false;

class conexion {
public Stream obtConex() {...}
public JID getJID() {...}
public String obtPassword() {...}
public boolean isLoggedIn() {...}
public void setLoggedIn(boolean log) {...}
public long getStartTime() {...}
public void setStartTime(long start) {...}
public boolean isContinue() {...}
public Packet deque() {...}
public void enque(Packet data) {...}
protected void login() throws PacketException, StreamException {...}
protected void autentificacion() throws PacketException, StreamException {...}
public  void desconectar () {...}
private StartTLSSocketStreamSource getStartTLSSocketStreamSource(JID servidor,int port){...}
        }

public conexion(String clienteSpec, String pass, String hostSpec, int port) throws IllegalArgumentException,            NoSuchAlgorithmException, IOException, UnknownHostException, StreamException {..}

/* Validación del correcyo formato del primer parámetro */
cliente = sdf.createJID(clienteSpec);
if (!Utilities.isValidString(cliente.getN