root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

JMS SingleConnectionFactory uses minimized number of start calls (for Oracle AQ; SPR-5987) 

git-svn-id: https://src.springframework.org/svn/spring-framework/trunk@1717 50f2f4bb-b051-0410-bef5-90022cba6387
This commit is contained in:
Juergen Hoeller 2009-08-08 01:25:02 +00:00
parent 33e1eacf57
commit 8af290310c
1 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
org.springframework.jms/src/test/java/org/springframework/jms/connection/SingleConnectionFactoryTests.java
View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2008 the original author or authors. * Copyright 2002-2009 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -42,7 +42,7 @@ public class SingleConnectionFactoryTests extends TestCase {
Connection con = (Connection) conControl.getMock(); Connection con = (Connection) conControl.getMock();
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -56,7 +56,7 @@ public class SingleConnectionFactoryTests extends TestCase {
con1.stop(); // should be ignored con1.stop(); // should be ignored
con1.close(); // should be ignored con1.close(); // should be ignored
Connection con2 = scf.createConnection(); Connection con2 = scf.createConnection();
con2.start(); con2.start(); // should be ignored
con2.stop(); // should be ignored con2.stop(); // should be ignored
con2.close(); // should be ignored con2.close(); // should be ignored
scf.destroy(); // should trigger actual close scf.destroy(); // should trigger actual close
@ -69,7 +69,7 @@ public class SingleConnectionFactoryTests extends TestCase {
Connection con = (QueueConnection) conControl.getMock(); Connection con = (QueueConnection) conControl.getMock();
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -96,7 +96,7 @@ public class SingleConnectionFactoryTests extends TestCase {
Connection con = (TopicConnection) conControl.getMock(); Connection con = (TopicConnection) conControl.getMock();
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -127,7 +127,7 @@ public class SingleConnectionFactoryTests extends TestCase {
cf.createConnection(); cf.createConnection();
cfControl.setReturnValue(con, 1); cfControl.setReturnValue(con, 1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -158,7 +158,7 @@ public class SingleConnectionFactoryTests extends TestCase {
cf.createConnection(); cf.createConnection();
cfControl.setReturnValue(con, 1); cfControl.setReturnValue(con, 1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -189,7 +189,7 @@ public class SingleConnectionFactoryTests extends TestCase {
cf.createQueueConnection(); cf.createQueueConnection();
cfControl.setReturnValue(con, 1); cfControl.setReturnValue(con, 1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -220,7 +220,7 @@ public class SingleConnectionFactoryTests extends TestCase {
cf.createConnection(); cf.createConnection();
cfControl.setReturnValue(con, 1); cfControl.setReturnValue(con, 1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -251,7 +251,7 @@ public class SingleConnectionFactoryTests extends TestCase {
cf.createTopicConnection(); cf.createTopicConnection();
cfControl.setReturnValue(con, 1); cfControl.setReturnValue(con, 1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -284,7 +284,7 @@ public class SingleConnectionFactoryTests extends TestCase {
con.setClientID("myId"); con.setClientID("myId");
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -321,7 +321,7 @@ public class SingleConnectionFactoryTests extends TestCase {
con.getExceptionListener(); con.getExceptionListener();
conControl.setReturnValue(listener, 1); conControl.setReturnValue(listener, 1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -407,7 +407,7 @@ public class SingleConnectionFactoryTests extends TestCase {
cf.createQueueConnection(); cf.createQueueConnection();
cfControl.setReturnValue(con, 1); cfControl.setReturnValue(con, 1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -438,7 +438,7 @@ public class SingleConnectionFactoryTests extends TestCase {
cf.createTopicConnection(); cf.createTopicConnection();
cfControl.setReturnValue(con, 1); cfControl.setReturnValue(con, 1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -487,7 +487,7 @@ public class SingleConnectionFactoryTests extends TestCase {
nonTxSession.close(); nonTxSession.close();
nonTxSessionControl.setVoidCallable(1); nonTxSessionControl.setVoidCallable(1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -549,7 +549,7 @@ public class SingleConnectionFactoryTests extends TestCase {
nonTxSession.close(); nonTxSession.close();
nonTxSessionControl.setVoidCallable(1); nonTxSessionControl.setVoidCallable(1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();
@ -611,7 +611,7 @@ public class SingleConnectionFactoryTests extends TestCase {
nonTxSession.close(); nonTxSession.close();
nonTxSessionControl.setVoidCallable(1); nonTxSessionControl.setVoidCallable(1);
con.start(); con.start();
conControl.setVoidCallable(2); conControl.setVoidCallable(1);
con.stop(); con.stop();
conControl.setVoidCallable(1); conControl.setVoidCallable(1);
con.close(); con.close();