0

我是 JMS+OPenMq + Glassfish 的新手，请通过成功发送消息和接收消息来放弃我......

我创建了两个不同的 servlet 程序，并部署在 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

如果您的消费者在 servlet 中，它只会捕获在同一时间发送的消息（不太可能） - 您使用的主题默认情况下不缓冲。

要么使用队列（而不是主题），要么编写一个永久运行的独立程序（从而监听/接收）。通常，主题侦听器在 servlet 中没有多大意义。

于 2014-07-11T12:41:17.497 回答