[jira] Resolved: (AMQ-715) Selectors on byte properties now working.

["james strachan (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/activemq/browse/AMQ-715?page=all ]
     
james strachan resolved AMQ-715:
--------------------------------

    Resolution: Cannot Reproduce

Have tried to reproduce this issue firstly testing the byte based selectors (see SelectorTest) which all work fine.

Then I added JmsTopicSendReceiveWithTwoConnectionsAndByteSelectorTest which explicitly sends and receives messages using a byte based selector and it seems to work fine.

> 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
>     Assignee: 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