Searched defs:queue (Results 1 - 5 of 5) sorted by relevance

/glassfish-3.1.2/tests/quicklook/ejb/mdb/src/com/sun/mdb/client/
H A DClient.java132 public void sendMsgs(javax.jms.Queue queue, Message msg, int num) argument
135 System.out.println("Sending message " + i + " to " + queue +
137 queueSender.send(queue, msg);
138 System.out.println("Sent message " + i + " to " + queue +
154 System.out.println("Waiting for queue message");
/glassfish-3.1.2/persistence/cmp/utility/src/main/java/com/sun/jdo/spi/persistence/utility/
H A DWeakHashSet.java56 ReferenceQueue queue = new ReferenceQueue(); field in class:WeakHashSet
114 return super.add(WeakElement.create(o, this.queue));
148 while ((wv = (WeakElement)this.queue.poll()) != null)
H A DWeakValueHashMap.java70 /* Reference queue for cleared WeakValues */
71 private ReferenceQueue queue = new ReferenceQueue(); field in class:WeakValueHashMap
147 (WeakValue)super.put(key, WeakValue.create(key, value, queue));
178 while ((wv = (WeakValue) this.queue.poll()) != null) {
212 private WeakValue(Object key, Object value, ReferenceQueue queue) { argument
213 super(value, queue);
218 * Creates a new weak reference and adds it to the given queue.
221 ReferenceQueue queue) {
223 else return new WeakValue(key, value, queue);
288 ent.setValue(WeakValue.create(getKey(), value, queue));
220 create(Object key, Object value, ReferenceQueue queue) argument
[all...]
/glassfish-3.1.2/connectors/work-management/src/main/java/com/sun/enterprise/connectors/work/
H A DWorkCoordinator.java83 private final WorkQueue queue; field in class:WorkCoordinator
106 * @param queue WorkQueue of the threadpool, to which the work
113 WorkQueue queue,
121 this.queue = queue;
138 * Submits the work to the queue and generates a work accepted event.
151 queue.addWork(new OneWork(work, this, contextHandler, Thread.currentThread().getContextClassLoader()));
110 WorkCoordinator(javax.resource.spi.work.Work work, long timeout, ExecutionContext ec, WorkQueue queue, WorkListener listener, WorkManagementProbeProvider probeProvider, ConnectorRuntime runtime, String raName, WorkContextHandler handler) argument
/glassfish-3.1.2/core/kernel/src/main/java/com/sun/enterprise/v3/services/impl/monitor/
H A DMonitorableThreadPool.java130 Queue<Runnable> queue,
140 queue,
125 GrizzlyIntegrationThreadPoolConfig(String monitoringId, GrizzlyMonitoring monitoring, String poolName, int corePoolSize, int maxPoolSize, Queue<Runnable> queue, int queueLimit, long keepAliveTime, TimeUnit timeUnit, ThreadFactory threadFactory, int priority) argument

Completed in 56 milliseconds