activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Helen Huang (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AMQ-4277) REST GET 204
Date Fri, 25 Jan 2013 21:31:12 GMT
Helen Huang created AMQ-4277:
--------------------------------

             Summary: REST GET 204
                 Key: AMQ-4277
                 URL: https://issues.apache.org/jira/browse/AMQ-4277
             Project: ActiveMQ
          Issue Type: Bug
    Affects Versions: 5.7.0
         Environment: windows 7 and windows xp
            Reporter: Helen Huang
            Priority: Critical
             Fix For: 5.7.0


Using 5.7 REST API I can GET a message from a topic but if a new message is POSTed to that
same topic before the GET has been reissued (less than 20ms behind the POST and using the
same session as the previous GET) the GET will timeout with a 204 and does not retrieve the
message. This may be as designed for topics (queues are not an option) but I am just looking
for confirmation. I assumed the first GET would have provided a topic subscription and the
broker would hold a topic message for which there is a subscriber for longer than 20ms? This
is not a stress test and is recreated with a simple producer and a separate consumer usually
within the first couple of message exchanges. It has been noticed that when the topic message
is POSTed without an outstanding GET to receive it, the following exception is logged: 

2013-01-22 01:09:37,484 | DEBUG | Async client internal exception occurred with no exception
listener registered: java.lang.IllegalStateException: DISPATCHED,initial | org.apache.activemq.ActiveMQConnection
| ActiveMQ Session Task-1 
java.lang.IllegalStateException: DISPATCHED,initial 
        at org.eclipse.jetty.server.AsyncContinuation.dispatch(AsyncContinuation.java:408)

        at org.eclipse.jetty.server.AsyncContinuation.resume(AsyncContinuation.java:815) 
        at org.apache.activemq.web.MessageServlet$Listener.onMessageAvailable(MessageServlet.java:409)

        at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1343)

        at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:131)

        at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:202)

        at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:129)

        at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:47) 
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)

        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)

        at java.lang.Thread.run(Thread.java:722) 
  
Are there any configuration modifications available to have the topic messages retained for
at least 1 second?

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Mime
View raw message