diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNetConnection.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNetConnection.java index 4336771670..b9c443bea8 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNetConnection.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNetConnection.java @@ -21,8 +21,8 @@ import java.net.SocketTimeoutException; import org.springframework.core.serializer.Deserializer; import org.springframework.integration.Message; -import org.springframework.integration.ip.tcp.SocketIoUtils; import org.springframework.integration.ip.tcp.serializer.SoftEndOfStreamException; +import org.springframework.integration.ip.util.SocketIoUtils; /** * A TcpConnection that uses and underlying {@link Socket}. diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java index aa6b558132..e186557dfb 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java @@ -30,8 +30,8 @@ import java.util.concurrent.Executors; import java.util.concurrent.atomic.AtomicInteger; import org.springframework.integration.Message; -import org.springframework.integration.ip.tcp.SocketIoUtils; import org.springframework.integration.ip.tcp.serializer.SoftEndOfStreamException; +import org.springframework.integration.ip.util.SocketIoUtils; /** * A TcpConnection that uses and underlying {@link SocketChannel}. diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/DatagramPacketMessageMapper.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/DatagramPacketMessageMapper.java index f0ba5539e9..f3ab492594 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/DatagramPacketMessageMapper.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/udp/DatagramPacketMessageMapper.java @@ -56,8 +56,7 @@ import org.springframework.util.Assert; * @author Dave Syer * @since 2.0 */ -public class DatagramPacketMessageMapper implements InboundMessageMapper, - OutboundMessageMapper { +public class DatagramPacketMessageMapper implements InboundMessageMapper, OutboundMessageMapper { private volatile String charset = "UTF-8"; @@ -68,9 +67,9 @@ public class DatagramPacketMessageMapper implements InboundMessageMapper