import javax.jms.*;

class subscriber {
    public static void main(String[] argv) {
	try {
            ConnectionFactory fact = new com.sun.messaging.ConnectionFactory();
            Connection conn = fact.createConnection();
            Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
         
            Topic top = new com.sun.messaging.Topic("temat1");
            MessageConsumer cons = sess.createConsumer(top);
            conn.start();         
            TextMessage tmsg;
            tmsg = (TextMessage)cons.receive();
         
            System.out.println("Odebrano: " + tmsg.getText()); 
            conn.close();
	} 
	catch (Exception jmse) {
	    System.out.println("Exception occurred : " + jmse.toString());
	    jmse.printStackTrace();
	} 
    }
}