ObsFisier

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;


public class Input {

private Observat o;
private BufferedReader in = null;
String mesage = null;

public Input(Observat x){

this.o = x;
in = new BufferedReader(new InputStreamReader(System.in));
try {
while(!(mesage=in.readLine()).equals("")){
if(mesage.equals("")){
System.out.println("Aplicatia s-a terminat");
System.exit(0);
}
else{
System.out.println(mesage);
this.o.trimite(mesage);

}
break;
}

} catch (IOException e) {
System.out.println("Conexiune pierduta la mesaj");
}

}
}

import java.util.Observable;


public class Observat extends Observable {

public void trimite(String mes){
System.out.println("Am ajuns in trimite");
this.setChanged();
this.notifyObservers((String)mes);
}
public static void main(String[] args) {

Observatori y = new Observatori();
Observat x = new Observat();
x.addObserver(y);

Input ana = new Input(x);

}

}

import java.awt.print.Printable;

import java.io.FileNotFoundException;

import java.io.PrintWriter;

import java.util.Observable;

import java.util.Observer;

import javax.swing.JOptionPane;

public class Observatori  implements Observer{

private PrintWriter out1;

private PrintWriter out2;

@Override

public void update(Observable arg0, Object arg1) {

JOptionPane p = new JOptionPane();

p.showMessageDialog(null, "Update");

p.setVisible(true);

p.validate();

p.repaint();

try {

out1 = new PrintWriter("out1.txt");

out2 = new PrintWriter("out2.txt");

out1.println((String)arg1);

out2.println((String)arg1);

} catch (FileNotFoundException e) {

System.out.println("Eroare la stabilire buffere");

}

out1.close();

out2.close();

}

}