Package org.mortbay.util.ajax

Examples of org.mortbay.util.ajax.Continuation.suspend()

107
108
109
110
111
112
113
114
115
116
117
        synchronized (queue.getActivationLock()) {
          final Continuation cont = ContinuationSupport.getContinuation(httpServletRequest, queue);

          if (!cont.isResumed() && !queue.messagesWaiting()) {
            queue.setActivationCallback(new JettyQueueActivationCallback(cont));
            if (cont.suspend(30 * 1000)) {
              return;
            }
          }
        }
      }
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
                                cont.resume();
                            }
                        });

                        if (!queue.messagesWaiting()) {
                            cont.suspend(45 * 1000);
                        }
                    } else {
                        queue.setActivationCallback(null);
                    }

View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
            // This will throw an exception
            action = suspended(req, response);
            if (action.type() == Action.TYPE.SUSPEND) {
                // Do nothing except setting the times out
                if (action.timeout() != -1) {
                    c.suspend(action.timeout());
                } else {
                    c.suspend(0);
                }
            } else if (action.type() == Action.TYPE.RESUME) {
                if (!resumed.remove(c)) {
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
            if (action.type() == Action.TYPE.SUSPEND) {
                // Do nothing except setting the times out
                if (action.timeout() != -1) {
                    c.suspend(action.timeout());
                } else {
                    c.suspend(0);
                }
            } else if (action.type() == Action.TYPE.RESUME) {
                if (!resumed.remove(c)) {
                    c.reset();
View Full Code Here
108
109
110
111
112
113
114
115
116
117
118
        synchronized (queue.getActivationLock()) {
          final Continuation cont = ContinuationSupport.getContinuation(httpServletRequest, queue);

          if (!cont.isResumed() && !queue.messagesWaiting()) {
            queue.setActivationCallback(new JettyQueueActivationCallback(cont));
            if (cont.suspend(30 * 1000)) {
              return;
            }
          }
        }
      }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
          if (!queue.messagesWaiting()) {

            queue.setActivationCallback(new JettyQueueActivationCallback(cont));

            if (!queue.messagesWaiting()) {
              cont.suspend(45 * 1000);
            }
          }
          else {
            queue.setActivationCallback(null);
          }
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
        EasyMock.expectLastCall();
        c.reset();
        EasyMock.expectLastCall();
        c.resume();
        EasyMock.expectLastCall();
        c.suspend(100);
        EasyMock.expectLastCall().andReturn(true);
        EasyMock.replay(c);
       
        HttpServletRequest request = EasyMock.createMock(HttpServletRequest.class);
        request.getAttribute("org.mortbay.jetty.ajax.Continuation");
View Full Code Here
296
297
298
299
300
301
302
303
304
305
306
                // register this continuation with our listener.
                listener.setContinuation(continuation);

                // Get the continuation object (may wait and/or retry
                // request here).
                continuation.suspend(timeout);
            }
            listener.setContinuation(null);

            // prepare the responds
            response.setContentType("text/xml");
View Full Code Here
209
210
211
212
213
214
215
216
217
218
219
                    // register this continuation with our listener.
                    listener.setContinuation(continuation);

                    // Get the continuation object (may wait and/or retry
                    // request here).
                    continuation.suspend(timeout);
                }

                // Try again now
                if (message == null) {
                    message = consumer.receiveNoWait();
View Full Code Here
182
183
184
185
186
187
188
189
190
191
192
                synchronized (cont) {
                    channel.send(exchange);
                    if (log.isDebugEnabled()) {
                        log.debug("Suspending continuation for exchange: " + exchange.getExchangeId());
                    }
                    boolean result = cont.suspend(suspentionTime);
                    exchanges.remove(exchange.getExchangeId());
                    if (!result) {
                        throw new Exception("Error sending exchange: aborted");
                    }
                    request.removeAttribute(MessageExchange.class.getName());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.