import  javax.jms.*;
 import  javax.naming.*;


 public   class  jmsSender {
     public   void  jnsSender(){
        
    }
     public   void  Send(String setInfo,String idClient){
         try {


            Context ctx  =  new  InitialContext();
            QueueConnectionFactory qcf = (QueueConnectionFactory) ctx.lookup("java:comp/env/jms/MyQueueFactory");
            QueueConnection con = qcf.createQueueConnection();
            QueueSession sessionQ = con.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
            Queue queue =  null ;
             try {
                queue = (Queue) ctx.lookup(idClient);
            } catch (NameNotFoundException nnfe){
                queue = sessionQ.createQueue(idClient);
                System.out.println("queue New");
                ctx.bind(idClient,queue);
            }

           TextMessage textMessage = sessionQ.createTextMessage();
            QueueSender sender = sessionQ.createSender(queue);
            con.start();
            textMessage.setText(setInfo);
            sender.send(textMessage);

        }  catch (Exception ex){
            ex.printStackTrace();

        }
    }

}

 public   class  getClient{
 public   static   void  main(String[] args){
      jmsSender jS =  new  jmsSender();
      jS.Send("Hello","k1");
      jmsRecipient jR =  new  jmsRecipient();
      jR.Take("k1");
 }
}