activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hiram Chirino (JIRA)" <j...@apache.org>
Subject [jira] Created: (AMQ-715) Selectors on byte properties now working.
Date Fri, 19 May 2006 02:16:51 GMT
Selectors on byte properties now working.
-----------------------------------------

         Key: AMQ-715
         URL: https://issues.apache.org/activemq/browse/AMQ-715
     Project: ActiveMQ
        Type: Bug

    Versions: 4.0, 4.0 M4, 4.0 RC2, 4.0 RC3    
    Reporter: Hiram Chirino
 Assigned to: Hiram Chirino 
     Fix For: 4.1


Reported on mailing list by Marcelo Ribeiro:

W're using active-mq 4.0-rc2 and realize that any message sent are not
received if we use a selector with a byte param. Here is the two
programs used to show this behavior. If we change this param from byte
to int it works. Is this a known bug ?

Some parts are not shown to make this sample smaller.

(MESSAGE SENDER)

......................
  public static void main(String[] args) throws Exception {
      TopicPublisher publisher =
getSession().createPublisher(MessageClient.topic);

      System.out.println("Started...");
      Message msg = getSession().createMessage();
      msg.setByteProperty("dummy", (byte) 33);
      publisher.publish(msg);
      System.out.println("Message sent.");
      try {Thread.sleep(10000);} catch (Exception exc) {}
      publisher.close();
      session.close();
      conn.close();
      System.out.println("Finished.");
  }
(end)


(MESSAGE RECEIVER)

......................

 public static void main(String[] args) throws Exception {
      JmsReceiverTest listen = new JmsReceiverTest();

      System.out.println("Started...");
      TopicSubscriber subscriber =
getSession().createSubscriber(MessageClient.topic, "dummy = 33", false);
      subscriber.setMessageListener(listen);
      synchronized (listen) {
          listen.wait(30000);
      }
      subscriber.close();
      session.close();
      conn.close();
      System.out.println("Finished.");
  }

  public void onMessage(Message msg) {
      System.out.println("Message received.");
      try {
          for (Enumeration e = msg.getPropertyNames();
e.hasMoreElements();) {
              String name = (String) e.nextElement();
              System.out.println("Property name: " + name + ", value =
" + msg.getObjectProperty(name));
          }
      } catch (Exception exc) {
          exc.printStackTrace();
      }
      this.notify();
  }
(end)

Thanks in advance,

Marcelo Ribeiro




-- 
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
   https://issues.apache.org/activemq/secure/Administrators.jspa
-
For more information on JIRA, see:
   http://www.atlassian.com/software/jira


Mime
View raw message