mirror of https://github.com/apache/activemq.git
https://issues.apache.org/activemq/browse/AMQ-2600 - jetty7 - continuations api adaptations - web demo works now
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@908458 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
5a7ceacce9
commit
25f476624f
|
@ -27,7 +27,7 @@
|
|||
<form action="message/FOO/BAR" method="post">
|
||||
<p>
|
||||
<label for="destination">Destination name</label>
|
||||
<input type="text" name="destination"/>
|
||||
<input type="text" name="destination" value="FOO.BAR"/>
|
||||
</p>
|
||||
<p>
|
||||
<label for="type">Destination Type: </label>
|
||||
|
|
|
@ -264,9 +264,8 @@ public class MessageListenerServlet extends MessageServletSupport {
|
|||
}
|
||||
|
||||
Continuation continuation = ContinuationSupport.getContinuation(request);
|
||||
continuation.setTimeout(timeout);
|
||||
Listener listener = getListener(request);
|
||||
if (listener != null && continuation != null && !continuation.isSuspended()) {
|
||||
if (listener != null && continuation != null && !continuation.isInitial()) {
|
||||
listener.access();
|
||||
}
|
||||
|
||||
|
@ -293,15 +292,16 @@ public class MessageListenerServlet extends MessageServletSupport {
|
|||
// Get an existing Continuation or create a new one if there are no
|
||||
// messages
|
||||
|
||||
if (message == null) {
|
||||
if (message == null && continuation.isInitial()) {
|
||||
// register this continuation with our listener.
|
||||
listener.setContinuation(continuation);
|
||||
|
||||
// Get the continuation object (may wait and/or retry
|
||||
// request here).
|
||||
continuation.setTimeout(timeout);
|
||||
continuation.suspend();
|
||||
return;
|
||||
}
|
||||
listener.setContinuation(null);
|
||||
|
||||
// prepare the responds
|
||||
response.setContentType("text/xml");
|
||||
|
|
Loading…
Reference in New Issue