Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: activemq-users@geronimo.apache.org
Received-SPF: pass (asf.osuosl.org: domain of chirino@gmail.com designates
 64.233.184.230 as permitted sender)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
        s=beta; d=gmail.com;
        h=received:message-id:date:from:sender:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references:x-google-sender-auth;
        b=lfi7r3vSh8W1PRvi8F6S7VdsH132d0XRrwdmx+eNPYWJhdUMqyhLdsZ/zKmaf5xOxwWCxY9b6VlhHmGPMO/EKcegngPZ20Lj8Jt1U6LAy8yxo4u78ELbhCXjuTKTlHvKsCosy2D5mF0+CX23lzZGYo0xOzwaQ22stEjyHGqeNso=
Message-ID: <af2843cd0605190806nd1928c3tee7214cad1cb4e3e@mail.gmail.com>
Date: Fri, 19 May 2006 08:06:01 -0700
From: "Hiram Chirino" <hiram@hiramchirino.com>
Sender: chirino@gmail.com
To: activemq-users@geronimo.apache.org
Subject: Re: problem with byte selector
In-Reply-To: <446C7B17.3090605@datacom-telematica.com.br>
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1; format=flowed
Content-Transfer-Encoding: quoted-printable
Content-Disposition: inline
References: <446C7B17.3090605@datacom-telematica.com.br>

Hi Marcelo,

I've added a test case and fix to the latest source.  Please test
again agaist a subsequent snapshot.  Thanks for the report!

On 5/18/06, Datacom - Marcelo <marcelo@datacom-telematica.com.br> wrote:
> Hi I sent this message to dev-list but I saw it should be posted here
> before, I apologise to post it twice.
>
> 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 =3D
> getSession().createPublisher(MessageClient.topic);
>
>        System.out.println("Started...");
>        Message msg =3D 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 =3D new JmsReceiverTest();
>
>        System.out.println("Started...");
>        TopicSubscriber subscriber =3D
> getSession().createSubscriber(MessageClient.topic, "dummy =3D 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 =3D msg.getPropertyNames();
> e.hasMoreElements();) {
>                String name =3D (String) e.nextElement();
>                System.out.println("Property name: " + name + ", value =3D
> " + msg.getObjectProperty(name));
>            }
>        } catch (Exception exc) {
>            exc.printStackTrace();
>        }
>        this.notify();
>    }
> (end)
>
> Thanks in advance,
>
> Marcelo Ribeiro
>


--=20
Regards,
Hiram