diff --git a/spring-ws-support/src/main/java/org/springframework/ws/transport/jms/TextMessageOutputStream.java b/spring-ws-support/src/main/java/org/springframework/ws/transport/jms/TextMessageOutputStream.java index 00fcb124a..15c2214af 100644 --- a/spring-ws-support/src/main/java/org/springframework/ws/transport/jms/TextMessageOutputStream.java +++ b/spring-ws-support/src/main/java/org/springframework/ws/transport/jms/TextMessageOutputStream.java @@ -50,7 +50,7 @@ public void flush() throws IOException { super.flush(); try { ByteArrayOutputStream baos = (ByteArrayOutputStream) out; - String text = new String(baos.toByteArray(), encoding); + String text = baos.toString(encoding); message.setText(text); } catch (JMSException ex) { throw new JmsTransportException(ex); diff --git a/spring-ws-support/src/main/java/org/springframework/ws/transport/xmpp/MessageOutputStream.java b/spring-ws-support/src/main/java/org/springframework/ws/transport/xmpp/MessageOutputStream.java index ff5b418a7..67a456504 100644 --- a/spring-ws-support/src/main/java/org/springframework/ws/transport/xmpp/MessageOutputStream.java +++ b/spring-ws-support/src/main/java/org/springframework/ws/transport/xmpp/MessageOutputStream.java @@ -48,7 +48,7 @@ class MessageOutputStream extends FilterOutputStream { public void flush() throws IOException { super.flush(); ByteArrayOutputStream bos = (ByteArrayOutputStream) out; - String text = new String(bos.toByteArray(), encoding); + String text = bos.toString(encoding); message.setBody(text); } } diff --git a/spring-ws-support/src/test/java/org/springframework/ws/transport/jms/JmsMessageSenderIntegrationTest.java b/spring-ws-support/src/test/java/org/springframework/ws/transport/jms/JmsMessageSenderIntegrationTest.java index 72251a180..c92098892 100644 --- a/spring-ws-support/src/test/java/org/springframework/ws/transport/jms/JmsMessageSenderIntegrationTest.java +++ b/spring-ws-support/src/test/java/org/springframework/ws/transport/jms/JmsMessageSenderIntegrationTest.java @@ -171,7 +171,7 @@ public void testSendAndReceiveQueueTextMessage() throws Exception { ByteArrayOutputStream bos = new ByteArrayOutputStream(); messageFactory.createMessage().writeTo(bos); - final String text = new String(bos.toByteArray(), StandardCharsets.UTF_8); + final String text = bos.toString(StandardCharsets.UTF_8); jmsTemplate.send(request.getJMSReplyTo(), session -> {