Searched defs:maxCapacity (Results 1 - 6 of 6) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DTraditionalWorkQueue.java114 private int maxCapacity; field in class:TraditionalWorkQueue
187 maxCapacity = configuration.getMaxWorkQueueCapacity();
190 if (maxCapacity > 0)
192 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity);
421 Message message = WARN_OP_REJECTED_BY_QUEUE_FULL.get(maxCapacity);
745 if (newMaxCapacity != maxCapacity)
766 maxCapacity = newMaxCapacity;
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DTraditionalWorkQueue.java113 private int maxCapacity; field in class:TraditionalWorkQueue
186 maxCapacity = configuration.getMaxWorkQueueCapacity();
189 if (maxCapacity > 0)
191 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity);
420 Message message = WARN_OP_REJECTED_BY_QUEUE_FULL.get(maxCapacity);
744 if (newMaxCapacity != maxCapacity)
765 maxCapacity = newMaxCapacity;
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DTraditionalWorkQueue.java114 private int maxCapacity; field in class:TraditionalWorkQueue
187 maxCapacity = configuration.getMaxWorkQueueCapacity();
190 if (maxCapacity > 0)
192 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity);
421 Message message = WARN_OP_REJECTED_BY_QUEUE_FULL.get(maxCapacity);
745 if (newMaxCapacity != maxCapacity)
766 maxCapacity = newMaxCapacity;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DTraditionalWorkQueue.java114 private int maxCapacity; field in class:TraditionalWorkQueue
187 maxCapacity = configuration.getMaxWorkQueueCapacity();
190 if (maxCapacity > 0)
192 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity);
421 Message message = WARN_OP_REJECTED_BY_QUEUE_FULL.get(maxCapacity);
745 if (newMaxCapacity != maxCapacity)
766 maxCapacity = newMaxCapacity;
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DTraditionalWorkQueue.java113 private int maxCapacity; field in class:TraditionalWorkQueue
186 maxCapacity = configuration.getMaxWorkQueueCapacity();
189 if (maxCapacity > 0)
191 opQueue = new LinkedBlockingQueue<Operation>(maxCapacity);
420 Message message = WARN_OP_REJECTED_BY_QUEUE_FULL.get(maxCapacity);
744 if (newMaxCapacity != maxCapacity)
765 maxCapacity = newMaxCapacity;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/
H A DTraditionalWorkQueue.java103 private int maxCapacity; field in class:TraditionalWorkQueue
174 maxCapacity = configuration.getMaxWorkQueueCapacity();
177 if (maxCapacity > 0)
179 opQueue = new LinkedBlockingQueue<>(maxCapacity);
389 LocalizableMessage message = WARN_OP_REJECTED_BY_QUEUE_FULL.get(maxCapacity);
699 if (newMaxCapacity != maxCapacity)
719 maxCapacity = newMaxCapacity;

Completed in 46 milliseconds