Package org.hornetq.rest.queue

Examples of org.hornetq.rest.queue.QueueConsumer.shutdown()

90
91
92
93
94
95
96
97
98
99
100
      synchronized (consumer)
      {
         if (System.currentTimeMillis() - consumer.getLastPingTime() > consumerTimeoutSeconds * 1000)
         {
            log.warn("shutdown REST consumer because of session timeout for: " + consumer.getId());
            consumer.shutdown();
            queueConsumers.remove(consumer.getId());
            serviceManager.getTimeoutTask().remove(consumer.getId());
         }
      }
   }
View Full Code Here
382
383
384
385
386
387
388
389
390
391
392
            consumer = tmp;
            serviceManager.getTimeoutTask().add(this, subscriptionId);
         }
         else
         {
            tmp.shutdown();
         }
      }
      else
      {
         throw new WebApplicationException(Response.status(405)
View Full Code Here
417
418
419
420
421
422
423
424
425
426
427
         //System.out.println(msg);
         throw new WebApplicationException(Response.status(Response.Status.NOT_FOUND)
                 .entity(msg)
                 .type("text/plain").build());
      }
      consumer.shutdown();
      deleteSubscriberQueue(consumer);

   }

   private void deleteSubscriberQueue(QueueConsumer consumer)
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
      synchronized (consumer)
      {
         if (System.currentTimeMillis() - consumer.getLastPingTime() > subscription.getTimeout())
         {
            HornetQRestLogger.LOGGER.shutdownRestSubscription(consumer.getId());
            consumer.shutdown();
            queueConsumers.remove(consumer.getId());
            serviceManager.getTimeoutTask().remove(consumer.getId());
            if (subscription.isDeleteWhenIdle()) deleteSubscriberQueue(consumer);
         }
      }
View Full Code Here
394
395
396
397
398
399
400
401
402
403
404
            consumer = tmp;
            serviceManager.getTimeoutTask().add(this, subscriptionId);
         }
         else
         {
            tmp.shutdown();
         }
      }
      else
      {
         throw new WebApplicationException(Response.status(405)
View Full Code Here
428
429
430
431
432
433
434
435
436
437
438
         String msg = "Failed to match a subscription to URL " + consumerId;
         throw new WebApplicationException(Response.status(Response.Status.NOT_FOUND)
                 .entity(msg)
                 .type("text/plain").build());
      }
      consumer.shutdown();
      deleteSubscriberQueue(consumer);

   }

   private void deleteSubscriberQueue(QueueConsumer consumer)
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
         synchronized (consumer)
         {
            if (System.currentTimeMillis() - consumer.getLastPingTime() > consumerTimeoutSeconds * 1000)
            {
               log.warn("shutdown REST consumer because of session timeout for: " + consumer.getId());
               consumer.shutdown();
               queueConsumers.remove(consumer.getId());
               serviceManager.getTimeoutTask().remove(consumer.getId());
            }
         }
      }
View Full Code Here
388
389
390
391
392
393
394
395
396
397
398
               consumer = tmp;
               serviceManager.getTimeoutTask().add(this, subscriptionId);
            }
            else
            {
               tmp.shutdown();
            }
         }
      }
      else
      {
View Full Code Here
424
425
426
427
428
429
430
431
432
433
434
         //System.out.println(msg);
         throw new WebApplicationException(Response.status(Response.Status.NOT_FOUND)
                 .entity(msg)
                 .type("text/plain").build());
      }
      consumer.shutdown();
      deleteSubscriberQueue(consumer);

   }

   private void deleteSubscriberQueue(QueueConsumer consumer)
View Full Code Here
432
433
434
435
436
437
438
439
440
441
442
            consumer = tmp;
            serviceManager.getTimeoutTask().add(this, subscriptionId);
         }
         else
         {
            tmp.shutdown();
         }
      }
      else
      {
         throw new WebApplicationException(Response.status(405)
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.