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

/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/internal/
H A DInternalLDAPInputStream.java59 private final ArrayBlockingQueue<LDAPMessage> messageQueue; field in class:InternalLDAPInputStream
88 this.messageQueue = new ArrayBlockingQueue<LDAPMessage>(10);
120 messageQueue.put(message);
131 messageQueue.put(message);
155 LDAPMessage message = messageQueue.poll();
160 messageQueue.clear();
213 while (! messageQueue.offer(nullMessage))
215 messageQueue.clear();
273 message = messageQueue.take();
285 messageQueue
[all...]
/forgerock/opendj2/src/server/org/opends/server/protocols/internal/
H A DInternalLDAPInputStream.java58 private final ArrayBlockingQueue<LDAPMessage> messageQueue; field in class:InternalLDAPInputStream
87 this.messageQueue = new ArrayBlockingQueue<LDAPMessage>(10);
119 messageQueue.put(message);
130 messageQueue.put(message);
154 LDAPMessage message = messageQueue.poll();
159 messageQueue.clear();
212 while (! messageQueue.offer(nullMessage))
214 messageQueue.clear();
272 message = messageQueue.take();
284 messageQueue
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/protocols/internal/
H A DInternalLDAPInputStream.java59 private final ArrayBlockingQueue<LDAPMessage> messageQueue; field in class:InternalLDAPInputStream
88 this.messageQueue = new ArrayBlockingQueue<LDAPMessage>(10);
120 messageQueue.put(message);
131 messageQueue.put(message);
155 LDAPMessage message = messageQueue.poll();
160 messageQueue.clear();
213 while (! messageQueue.offer(nullMessage))
215 messageQueue.clear();
273 message = messageQueue.take();
285 messageQueue
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/protocols/internal/
H A DInternalLDAPInputStream.java59 private final ArrayBlockingQueue<LDAPMessage> messageQueue; field in class:InternalLDAPInputStream
88 this.messageQueue = new ArrayBlockingQueue<LDAPMessage>(10);
120 messageQueue.put(message);
131 messageQueue.put(message);
155 LDAPMessage message = messageQueue.poll();
160 messageQueue.clear();
213 while (! messageQueue.offer(nullMessage))
215 messageQueue.clear();
273 message = messageQueue.take();
285 messageQueue
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/protocols/internal/
H A DInternalLDAPInputStream.java58 private final ArrayBlockingQueue<LDAPMessage> messageQueue; field in class:InternalLDAPInputStream
87 this.messageQueue = new ArrayBlockingQueue<LDAPMessage>(10);
119 messageQueue.put(message);
130 messageQueue.put(message);
154 LDAPMessage message = messageQueue.poll();
159 messageQueue.clear();
212 while (! messageQueue.offer(nullMessage))
214 messageQueue.clear();
272 message = messageQueue.take();
284 messageQueue
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/internal/
H A DInternalLDAPInputStream.java61 private final ArrayBlockingQueue<LDAPMessage> messageQueue; field in class:InternalLDAPInputStream
90 this.messageQueue = new ArrayBlockingQueue<>(10);
122 messageQueue.put(message);
133 messageQueue.put(message);
157 LDAPMessage message = messageQueue.poll();
162 messageQueue.clear();
215 while (! messageQueue.offer(nullMessage))
217 messageQueue.clear();
275 message = messageQueue.take();
287 messageQueue
[all...]

Completed in 730 milliseconds