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();
            } 
      }
   }