Glassfish（v3）JMSキューからメッセージを受け取る方法

Question

できるだけ私の問題の解決策を探しました。 私のアプリケーションはGlassfish v3で動作します。このアプリケーションはGlassfish JMSキューにメッセージを送信し、このメッセージはGlassfish JVM以外の同じホスト上のスタンドアロンクライアントによって読み取られるはずです。

私は、Glassfishインストールディレクトリからappserv-rt.jarとgf-client.jarを含むスタンドアロンのクライアントJavaコードを作成しました。

このクライアントコードはメッセージを受け取ることができません.System outステートメントは「消費者になった」まで印刷されます。

キューの名前を変更した場合、キューが見つからないというエラーが表示されます。クライアントコードはキューを見つけることができますが、メッセージは受信されません。クライアントコードに含める必要があります？どこかで受信コールの前connection.start();：

import java.util.Enumeration; 
import java.util.Hashtable; 
import java.util.Properties; 

import javax.annotation.Resource; 
import javax.jms.Connection; 
import javax.jms.ConnectionFactory; 
import javax.jms.JMSException; 
import javax.jms.MapMessage; 
import javax.jms.Message; 
import javax.jms.MessageConsumer; 
import javax.jms.MessageListener; 
import javax.jms.MessageProducer; 
import javax.jms.ObjectMessage; 
import javax.jms.Session; 
import javax.jms.Queue; 
import javax.naming.Context; 
import javax.naming.InitialContext; 
import javax.naming.NamingException; 

import org.apache.log4j.Category; 

import domain.RedirectFile; 

public class ZblBulkUploadThread implements Runnable,MessageListener{ 

private static final Category log = Category.getInstance(ZblBulkUploadThread.class) ; 



    private Queue queue; 

public void run() 
{ 
    try 
    { 

     System.out.println(" inside try") ; 
     InitialContext jndiContext = null; 

     MessageConsumer messageConsumer=null; 


     jndiContext = new InitialContext(); 

     System.out.println(" got context ") ; 

     ConnectionFactory connectionFactory = (ConnectionFactory)jndiContext. 
       lookup("jms/SimpleConnectionFactory"); 



     System.out.println("got connectionfactory") ; 

    Connection connection = connectionFactory.createConnection(); 

    System.out.println("got connection") ; 
    Session session = connection.createSession(false, 
      Session.AUTO_ACKNOWLEDGE); 

    queue = (Queue)jndiContext.lookup("jms/SimpleQueue") ; 

    System.out.println("got queue"+queue.getQueueName()) ; 

    messageConsumer = session.createConsumer(queue); 

    System.out.println(" selector "+messageConsumer.getMessageSelector()) ; 

    System.out.println("got consumer") ; 

    Message message = messageConsumer.receive() ; 

    System.out.println("Message is "+message) ; 

    System.out.println("destination is "+message.getJMSDestination()) ; 

    ObjectMessage om = ((ObjectMessage)message) ; 
    try 
    { 

    RedirectFile file = (RedirectFile)om.getObject() ; 

    log.debug("filePath "+file.getFilePath()) ; 
    log.debug(" userName "+file.getUserName()) ; 
    log.debug(" mode is "+file.getMode()) ; 

    System.out.println("filePath "+file.getFilePath()) ; 
    System.out.println(" userName "+file.getUserName()) ; 
    System.out.println(" mode is "+file.getMode()) ; 
    } 
    catch(Exception ex) 
    { 
     log.error("ERROR "+ex.getMessage()) ; 
     ex.printStackTrace() ; 
    } 

    log.debug("session created") ; 

    } 
    catch(Exception ex) 
    { 

     ex.printStackTrace() ; 
     log.error("Error "+ex.getMessage()) ; 
    } 
} 


public void onMessage(Message message) 
{ 
    System.out.println("Message received "+message) ; 
} 

public static void main(String[] args) 
{ 
    ZblBulkUploadThread zbut = new ZblBulkUploadThread() ; 
    new Thread(zbut).start() ; 
} 

}

Answer 1

試み - ：

は、ここに私のJavaクラスです。