使用java Swing发送消息给JMS队列

我已经成功开发了使用Oracle Glass-fish服务器4.1版本的JMS队列，然后我可以使用java EE应用程序成功发送和读取消息，但是我需要将发送者代码实现为Swing应用程序，我使用了相同的代码，Java EE应用程序，但它不做工精细，请参考下面的代码使用java Swing发送消息给JMS队列

public class SenderSwing {  
    /** 
    * @param args the command line arguments 
    */ 
public static void main(String[] args) { 
    try { 

     new SenderSwing().sendJMSMessageToDefaultQueue("Hi "+System.currentTimeMillis()); 

    }catch(Exception e){ 
     e.printStackTrace(); 
    } 
} 
private void sendJMSMessageToDefaultQueue(Object messageData) throws JMSException, NamingException { 
    Context c = new InitialContext(); 
    ConnectionFactory cf = (ConnectionFactory) c.lookup("java:comp/DefaultJMSConnectionFactory"); 
    Connection conn = null; 
    Session s = null; 
    try { 
     conn = cf.createConnection(); 
     s = conn.createSession(false, s.AUTO_ACKNOWLEDGE); 
     Destination destination = (Destination) c.lookup("jms/defaultQueue"); 
     MessageProducer mp = s.createProducer(destination);    
     mp.send(createJMSMessageForjmsDefaultQueue(s, messageData)); 
    } finally { 
     if (s != null) { 
      try { 
       s.close(); 
      } catch (JMSException e) { 
       Logger.getLogger(this.getClass().getName()).log(Level.WARNING, "Cannot close session", e); 
      } 
     } 
     if (conn != null) { 
      conn.close(); 
     } 
    } 
} 
private Message createJMSMessageForjmsDefaultQueue(Session session, Object messageData) throws JMSException { 
    // TODO create and populate message to send 
    TextMessage tm = session.createTextMessage(); 
    tm.setText(messageData.toString()); 


    return tm; 
}

}

上面的代码给我象下面这样的例外，

javax.naming.NoInitialContextException: Need to specify class name in environment or system property, or as an applet parameter, or in an application resource file: java.naming.factory.initial 
at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:662) 
at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:313) 
at javax.naming.InitialContext.getURLOrDefaultInitCtx(InitialContext.java:350) 
at javax.naming.InitialContext.lookup(InitialContext.java:417) 
at senderswing.SenderSwing.sendJMSMessageToDefaultQueue(SenderSwing.java:43) 
at senderswing.SenderSwing.main(SenderSwing.java:35)

任何人都可以帮忙。

来源

2017-02-18 Ishara Kularatna

在服务器环境之外，没有默认的初始上下文工厂类。

试试这个一开始：

Hashtable env = new Hashtable(); 
env.put(Context.INITIAL_CONTEXT_FACTORY, 
"com.sun.enterprise.naming.SerialInitContextFactory"); 
Context c = new InitialContext(env);

您需要GlassFish的命名（或嵌入所有）的容器作为一个依赖。

来源

2017-02-18 18:20:31

使用java Swing发送消息给JMS队列

回答

相关问题