Spring/spring-ws
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

only connect to the server once to speed up test JmsIntegrationTest (#1405)

Browse Source
This commit is contained in:
TestBoost
2024-04-10 09:35:13 -05:00
committed by GitHub
parent 37662a05e4
commit 3b0a6e9378
1 changed files with 34 additions and 40 deletions
Download Patch File Download Diff File Expand all files Collapse all files

74
spring-ws-support/src/test/java/org/springframework/ws/transport/jms/JmsIntegrationTest.java
View File

@@ -13,11 +13,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.ws.transport.jms;
import static org.xmlunit.assertj.XmlAssert.*;
import org.apache.activemq.artemis.core.config.Configuration;
import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl;
import org.apache.activemq.artemis.core.server.embedded.EmbeddedActiveMQ;
@@ -31,52 +29,48 @@ import org.springframework.test.context.junit.jupiter.SpringExtension;
import org.springframework.ws.client.core.WebServiceTemplate;
import org.springframework.xml.transform.StringResult;
import org.springframework.xml.transform.StringSource;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.AfterAll;
@ExtendWith(SpringExtension.class)
@ContextConfiguration("jms-applicationContext.xml")
public class JmsIntegrationTest {
@Autowired private WebServiceTemplate webServiceTemplate;
@Autowired
private WebServiceTemplate webServiceTemplate;
private EmbeddedActiveMQ server;
private static EmbeddedActiveMQ server;
@BeforeEach
void setUp() throws Exception {
@BeforeAll
static void setUp() throws Exception {
Configuration config = new ConfigurationImpl();
config.addAcceptorConfiguration("vm", "vm://0");
config.addAcceptorConfiguration("tcp", "tcp://127.0.0.1:61616");
config.setSecurityEnabled(false);
server = new EmbeddedActiveMQ();
server.setConfiguration(config);
server.start();
}
Configuration config = new ConfigurationImpl();
config.addAcceptorConfiguration("vm", "vm://0");
config.addAcceptorConfiguration("tcp", "tcp://127.0.0.1:61616");
config.setSecurityEnabled(false);
server = new EmbeddedActiveMQ();
server.setConfiguration(config);
server.start();
}
@AfterAll
static void tearDown() throws Exception {
server.stop();
}
@AfterEach
void tearDown() throws Exception {
server.stop();
}
@Test
public void testTemporaryQueue() {
String content = "<root xmlns='http://springframework.org/spring-ws'><child/></root>";
StringResult result = new StringResult();
webServiceTemplate.sendSourceAndReceiveToResult(new StringSource(content), result);
assertThat(result.toString()).and(content).ignoreWhitespace().areSimilar();
}
@Test
public void testTemporaryQueue() {
String content = "<root xmlns='http://springframework.org/spring-ws'><child/></root>";
StringResult result = new StringResult();
webServiceTemplate.sendSourceAndReceiveToResult(new StringSource(content), result);
assertThat(result.toString()).and(content).ignoreWhitespace().areSimilar();
}
@Test
public void testPermanentQueue() {
String url = "jms:RequestQueue?deliveryMode=NON_PERSISTENT;replyToName=ResponseQueue";
String content = "<root xmlns='http://springframework.org/spring-ws'><child/></root>";
StringResult result = new StringResult();
webServiceTemplate.sendSourceAndReceiveToResult(url, new StringSource(content), result);
assertThat(result.toString()).and(content).ignoreWhitespace().areSimilar();
}
@Test
public void testPermanentQueue() {
String url = "jms:RequestQueue?deliveryMode=NON_PERSISTENT;replyToName=ResponseQueue";
String content = "<root xmlns='http://springframework.org/spring-ws'><child/></root>";
StringResult result = new StringResult();
webServiceTemplate.sendSourceAndReceiveToResult(url, new StringSource(content), result);
assertThat(result.toString()).and(content).ignoreWhitespace().areSimilar();
}
}