Examples of returnManagedConnection()

Examples of org.jboss.resource.connectionmanager.BaseConnectionManager2.returnManagedConnection()

187
188
189
190
191
192
193
194
195
196
197
      {
         Collection mcs = new ArrayList(pp.maxSize);
         for (int i = 0 ; i < pp.maxSize; i++)
            mcs.add(cm.getManagedConnection(subject, cri));
         for (Iterator i =  mcs.iterator(); i.hasNext(); )
            cm.returnManagedConnection((ConnectionListener)i.next(), false);

         assertTrue("Wrong number of connections counted: " + cm.getConnectionCount(), cm.getConnectionCount() == pp.maxSize);
         Thread.sleep(1500);
         ConnectionListener cl = cm.getManagedConnection(subject, cri);
         cm.returnManagedConnection(cl, false);
View Full Code Here

Examples of org.jboss.resource.connectionmanager.BaseConnectionManager2.returnManagedConnection()

192
193
194
195
196
197
198
199
200
201
202
            cm.returnManagedConnection((ConnectionListener)i.next(), false);

         assertTrue("Wrong number of connections counted: " + cm.getConnectionCount(), cm.getConnectionCount() == pp.maxSize);
         Thread.sleep(1500);
         ConnectionListener cl = cm.getManagedConnection(subject, cri);
         cm.returnManagedConnection(cl, false);

         // Let the idle remover kick in
         Thread.sleep(1500);
         assertTrue("Wrong number of connections counted: " + cm.getConnectionCount(), cm.getConnectionCount() == 1);
View Full Code Here

Examples of org.jboss.resource.connectionmanager.BaseConnectionManager2.returnManagedConnection()

219
220
221
222
223
224
225
226
227
228
229
      pp.idleTimeout = 2000;
      BaseConnectionManager2 cm = getCM(pp);
      try
      {
         ConnectionListener cl = cm.getManagedConnection(subject, cri);
         cm.returnManagedConnection(cl, false);
         // Allow fill to min to work
         Thread.sleep(1000);
         assertTrue("Wrong number of connections counted: " + cm.getConnectionCount(), cm.getConnectionCount() == pp.minSize);
         // Allow the idle remover to work
         Thread.sleep(3000);
View Full Code Here

Examples of org.jboss.resource.connectionmanager.BaseConnectionManager2.returnManagedConnection()

294
295
296
297
298
299
300
301
302
303
304
      pp.idleTimeout = 2000;
      BaseConnectionManager2 cm = getCM(pp);
      try
      {
         ConnectionListener cl = cm.getManagedConnection(subject, cri);
         cm.returnManagedConnection(cl, false);
         // Allow fill to min to work
         Thread.sleep(1000);
         assertTrue("Wrong number of connections counted: " + cm.getConnectionCount(), cm.getConnectionCount() == pp.maxSize);
         // Allow the idle remover to work
         Thread.sleep(3000);
View Full Code Here

Examples of org.jboss.resource.connectionmanager.BaseConnectionManager2.returnManagedConnection()

336
337
338
339
340
341
342
343
344
345
346
         pool.flush();

         // Put the connections back (should destroy/close them with no errors)
         for (Iterator i = cs.iterator(); i.hasNext();)
         {
            cm.returnManagedConnection((ConnectionListener)i.next(), true);
         }

         // Checkout all the connections with the new maximum size
         cs = new ArrayList();
         for (int i = 0; i < pp.maxSize; i++)
View Full Code Here

Examples of org.jboss.resource.connectionmanager.BaseConnectionManager2.returnManagedConnection()

360
361
362
363
364
365
366
367
368
369
370
         {
         }

         // Put the connections back into the new pool
         for (Iterator i = cs.iterator(); i.hasNext();)
            cm.returnManagedConnection((ConnectionListener)i.next(), true);
         assertTrue("Wrong number of connections counted: " + cm.getConnectionCount(), cm.getConnectionCount() == 0);
      }
      finally
      {
         shutdown(cm);
View Full Code Here

Examples of org.jboss.resource.connectionmanager.BaseConnectionManager2.returnManagedConnection()

404
405
406
407
408
409
410
411
412
413
414
         {
         }

         for (Iterator i = cs.iterator(); i.hasNext();)
         {
            cm.returnManagedConnection((ConnectionListener)i.next(), true);
         }

         assertTrue("Wrong number of connections counted: " + cm.getConnectionCount(), cm.getConnectionCount() == 0);
      }
      finally
View Full Code Here

Examples of org.jboss.resource.connectionmanager.BaseConnectionManager2.returnManagedConnection()

478
479
480
481
482
483
484
485
486
487
488
                     cont.await();

                     for (Iterator i = cs.iterator(); i.hasNext();)
                     {
                        cm.returnManagedConnection((ConnectionListener)i.next(), true);
                     }

                     done.countDown();
                  }
                  catch (InterruptedException ie)
View Full Code Here

Examples of org.jboss.resource.connectionmanager.NoTxConnectionManager.returnManagedConnection()

209
210
211
212
213
214
215
216
217
218
219
     
      //Let prefiller run
      Thread.sleep(5000);
     
      ConnectionListener cl = noTxn.getManagedConnection(null, null);
      noTxn.returnManagedConnection(cl, false);
     
      assertTrue(mcp.getConnectionDestroyedCount() == 0);

     
   }
View Full Code Here

Examples of org.jboss.resource.connectionmanager.NoTxConnectionManager.returnManagedConnection()

241
242
243
244
245
246
247
248
249
250
251
     
      //Let prefiller run
      Thread.sleep(5000);
     
      ConnectionListener cl = noTxn.getManagedConnection(null, null);
      noTxn.returnManagedConnection(cl, false);
     
      assertTrue(mcp.getConnectionDestroyedCount() > 0);
     
   }
  
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.