0

JMS+OPenMq + Glassfish は初めてです。メッセージの送信と受信を成功させてください....

私は2つの異なるサーブレットプログラムを作成し、galssfishサーバーにデプロイしました....ここではメッセージを正常に送信していますが、消費者はメッセージを消費できません......

プロデューサー :

          Properties p = new Properties(); 
                               p.put("java.naming.factory.initial","com.sun.enterprise.naming.SerialInitContextFactory");
        p.put("java.naming.factory.url.pkgs","com.sun.enterprise.naming");
        p.put("java.naming.provider.url", "iiop://localhost:3700");
        InitialContext jndiContext = new InitialContext(p);
        TopicConnectionFactory connectionFactory = (TopicConnectionFactory) jndiContext.lookup("jms/HQTapicConnectionFactory");
        Topic topic = (Topic) jndiContext.lookup("jms/HqDestTopic");
        System.out.println(topic.getTopicName());
                    TopicConnection connection =  (TopicConnection) connectionFactory.createTopicConnection();
                    System.out.println(connection.toString());
        TopicSession session = connection.createTopicSession(true, Session.AUTO_ACKNOWLEDGE);  //createSession(false, Session.AUTO_ACKNOWLEDGE);
        TopicPublisher publisher = session.createPublisher(topic);
        ObjectMessage message = session.createObjectMessage();
        ArrayList<Employee> employeeList= new ArrayList<Employee>();
        Employee employee  = null;
        for (int i = 0; i < 5; i++) {
              employee =  new Employee();
             employee.setEmpid((100+i));
             employee.setName("devid"+i);
             employeeList.add(employee);
        }
       System.out.println(employeeList.size());
        message.setObject(employeeList);
        publisher.send(message);

消費者：

public void onMessage(メッセージメッセージ){

  ObjectMessage objectMessage= (ObjectMessage) message;

try{

  System.out.println("Received the following message: ");
  Object object = objectMessage.getObject(); 

  if(object  instanceof ArrayList){
      ArrayList arrayList = (ArrayList)object;
      for (int i = 0; i < arrayList.size(); i++) {
          Object object1 = arrayList.get(i); 
         if(object1  instanceof Employee){
          Employee employee = (Employee)object1;
          System.out.println(employee.getEmpid());
          System.out.println(employee.getName());
             System.out.println();
         }
    }
  }

}
catch (JMSException e)
{
  e.printStackTrace();
}

}

メッセージを受信できません。

Glassfishサーバーでブローカーを適切に構成するのを手伝ってください。

、...あなたのリプレイに感謝します

4

1 に答える 1

0

コンシューマーがサーブレットにある場合、同じ瞬間に送信されたメッセージのみをキャッチします (ほとんどありません) 。デフォルトではバッファリングしないトピックを使用しています。

（トピックの代わりに）キューを使用するか、永続的に実行される（したがって、リッスン/受信する）スタンドアロンプ​​ログラムを作成します。通常、トピック リスナーは、サーブレットではあまり意味がありません。

于 2014-07-11T12:41:17.497 に答える