renamed SocketIoUtils to SocketUtils
This commit is contained in:
@@ -22,7 +22,7 @@ import java.net.SocketTimeoutException;
|
||||
import org.springframework.core.serializer.Deserializer;
|
||||
import org.springframework.integration.Message;
|
||||
import org.springframework.integration.ip.tcp.serializer.SoftEndOfStreamException;
|
||||
import org.springframework.integration.ip.util.SocketIoUtils;
|
||||
import org.springframework.integration.ip.util.SocketUtils;
|
||||
|
||||
/**
|
||||
* A TcpConnection that uses and underlying {@link Socket}.
|
||||
@@ -162,7 +162,7 @@ public class TcpNetConnection extends AbstractTcpConnection {
|
||||
|
||||
public String getConnectionId() {
|
||||
if (this.connectionId == null) {
|
||||
this.connectionId = SocketIoUtils.getSocketId(this.socket);
|
||||
this.connectionId = SocketUtils.getSocketId(this.socket);
|
||||
}
|
||||
return this.connectionId;
|
||||
}
|
||||
|
||||
@@ -31,7 +31,7 @@ import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
import org.springframework.integration.Message;
|
||||
import org.springframework.integration.ip.tcp.serializer.SoftEndOfStreamException;
|
||||
import org.springframework.integration.ip.util.SocketIoUtils;
|
||||
import org.springframework.integration.ip.util.SocketUtils;
|
||||
|
||||
/**
|
||||
* A TcpConnection that uses and underlying {@link SocketChannel}.
|
||||
@@ -340,7 +340,7 @@ public class TcpNioConnection extends AbstractTcpConnection {
|
||||
|
||||
public String getConnectionId() {
|
||||
if (this.connectionId == null) {
|
||||
this.connectionId = SocketIoUtils.getSocketId(this.socketChannel.socket());
|
||||
this.connectionId = SocketUtils.getSocketId(this.socketChannel.socket());
|
||||
}
|
||||
return this.connectionId;
|
||||
}
|
||||
|
||||
@@ -23,7 +23,7 @@ import java.net.Socket;
|
||||
* @author Gary Russell
|
||||
* @since 2.0
|
||||
*/
|
||||
public abstract class SocketIoUtils {
|
||||
public abstract class SocketUtils {
|
||||
|
||||
public static String getSocketId(Socket socket) {
|
||||
InetAddress inetAddress = socket.getInetAddress();
|
||||
Reference in New Issue
Block a user