Mailing-List: contact activemq-dev-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: activemq-dev@geronimo.apache.org
Message-ID: <28475665.1150383711612.JavaMail.jira@brutus>
Date: Thu, 15 Jun 2006 15:01:51 +0000 (GMT+00:00)
From: "Hiram Chirino (JIRA)" <jira@apache.org>
To: activemq-dev@geronimo.apache.org
Subject: [jira] Commented: (AMQ-725) Messages Sent by JMS that contain
 header properties cause error when STOMP client registers a Subscriber
In-Reply-To: <8205336.1148584671748.JavaMail.jira@brutus>
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: 7bit

    [ https://issues.apache.org/activemq/browse/AMQ-725?page=comments#action_36405 ] 

Hiram Chirino commented on AMQ-725:
-----------------------------------

Added test to the StompTest that looks like :

    public void testSubscribeWithMessageSentWithProperties() throws Exception {
        
        String frame =
            "CONNECT\n" +
            "login: brianm\n" +
            "passcode: wombats\n\n"+
            Stomp.NULL;
        sendFrame(frame);
        
        frame = receiveFrame(100000);
        assertTrue(frame.startsWith("CONNECTED"));
        
        frame =
            "SUBSCRIBE\n" +
            "destination:/queue/" + getQueueName() + "\n" +
            "ack:auto\n\n" +
            Stomp.NULL;
        sendFrame(frame);
        
        
        MessageProducer producer = session.createProducer(queue);
        TextMessage message = session.createTextMessage("Hello World");
        message.setStringProperty("s", "value");
        message.setBooleanProperty("n", false);
        message.setByteProperty("byte", (byte) 9);
        message.setDoubleProperty("d", 2.0);
        message.setFloatProperty("f", (float) 6.0);
        message.setIntProperty("i", 10);
        message.setLongProperty("l", 121);
        message.setShortProperty("s", (short) 12);
        producer.send(message);
        
        frame = receiveFrame(10000);
        assertTrue(frame.startsWith("MESSAGE"));
        
        frame =
            "DISCONNECT\n" +
            "\n\n"+
            Stomp.NULL;
        sendFrame(frame);
    }


And it worked fine.  Could you help me adjust the test case so that it shows the failure your reporting?


> Messages Sent by JMS that contain header properties cause error when STOMP client registers a Subscriber
> --------------------------------------------------------------------------------------------------------
>
>          Key: AMQ-725
>          URL: https://issues.apache.org/activemq/browse/AMQ-725
>      Project: ActiveMQ
>         Type: Bug

>   Components: Transport
>     Versions: 4.0
>  Environment: Running on WinXP with Sun JDK1.5.0_06
>     Reporter: William MacDonald
>     Assignee: Hiram Chirino
>     Priority: Blocker
>      Fix For: 4.0.1, 4.1

>
>
> I am using the lastest 4.0 release build of ActiveMQ and I have been trying to produce messages in a JMS client and receive the messages in a STOMP client.
> What I have found is that if the JMS Client adds header properties to the message to be delivered to ActiveMQ then when I subscribe with the STOMP client I am receiving the Error listed below.  If I remove all header properties then the message is transmitted correctly.  I have also found that if I send messages with a STOMP client that has header properties then everything works correctly.
> java.lang.NullPointerException
> at java.util.Hashtable.put(Unknown Source)
> at java.util.Hashtable.putAll(Unknown Source)
> at org.apache.activemq.transport.stomp.FrameBuilder.addHeaders(FrameBuilder.java:65)
> at org.apache.activemq.transport.stomp.Subscription.receive(Subscription.java:76)
> at org.apache.activemq.transport.stomp.StompWireFormat.writeCommand(StompWireFormat.java:154)
> at org.apache.activemq.transport.stomp.StompWireFormat.marshal(StompWireFormat.java:305)
> at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:124)
> at org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
> at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
> at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
> at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:211)
> at org.apache.activemq.broker.AbstractConnection.processDispatch(AbstractConnection.java:581)
> at org.apache.activemq.broker.AbstractConnection.iterate(AbstractConnection.java:597)
> at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:87)
> at org.apache.activemq.thread.DedicatedTaskRunner.access$000(DedicatedTaskRunner.java:24)
> at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:38)

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