import javax.jms.*;

class p2p_recv {
    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);
         
            Queue que = new com.sun.messaging.Queue("kolejka1");
            MessageConsumer cons = sess.createConsumer(que);
            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();
	} 
    }
}