INT-1217 Move SocketIoUtils from ...util to ...tcp
This commit is contained in:
@@ -21,7 +21,6 @@ import java.net.SocketException;
|
||||
|
||||
import org.springframework.integration.core.Message;
|
||||
import org.springframework.integration.gateway.AbstractMessagingGateway;
|
||||
import org.springframework.integration.ip.util.SocketIoUtils;
|
||||
import org.springframework.integration.message.MessageMappingException;
|
||||
|
||||
/**
|
||||
|
||||
@@ -22,7 +22,6 @@ import org.springframework.integration.core.Message;
|
||||
import org.springframework.integration.core.MessageChannel;
|
||||
import org.springframework.integration.core.MessagingException;
|
||||
import org.springframework.integration.handler.AbstractReplyProducingMessageHandler;
|
||||
import org.springframework.integration.ip.util.SocketIoUtils;
|
||||
|
||||
/**
|
||||
* Simple TCP outbound gateway; delegates write to a {@link TcpNetSendingMessageHandler}
|
||||
|
||||
@@ -13,18 +13,13 @@
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.springframework.integration.ip.util;
|
||||
package org.springframework.integration.ip.tcp;
|
||||
|
||||
import java.lang.reflect.Constructor;
|
||||
import java.net.Socket;
|
||||
import java.nio.channels.SocketChannel;
|
||||
|
||||
import org.springframework.beans.BeanUtils;
|
||||
import org.springframework.integration.ip.tcp.MessageFormats;
|
||||
import org.springframework.integration.ip.tcp.NetSocketReader;
|
||||
import org.springframework.integration.ip.tcp.NetSocketWriter;
|
||||
import org.springframework.integration.ip.tcp.NioSocketReader;
|
||||
import org.springframework.integration.ip.tcp.NioSocketWriter;
|
||||
import org.springframework.integration.message.MessageMappingException;
|
||||
|
||||
/**
|
||||
@@ -23,7 +23,6 @@ import java.net.Socket;
|
||||
import javax.net.ServerSocketFactory;
|
||||
|
||||
import org.springframework.integration.core.Message;
|
||||
import org.springframework.integration.ip.util.SocketIoUtils;
|
||||
|
||||
/**
|
||||
* Tcp Receiving Channel adapter that uses a {@link Socket}. Each
|
||||
|
||||
@@ -19,7 +19,6 @@ import java.net.Socket;
|
||||
|
||||
import javax.net.SocketFactory;
|
||||
|
||||
import org.springframework.integration.ip.util.SocketIoUtils;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@@ -30,7 +30,6 @@ import java.util.Iterator;
|
||||
import java.util.Set;
|
||||
|
||||
import org.springframework.integration.core.Message;
|
||||
import org.springframework.integration.ip.util.SocketIoUtils;
|
||||
|
||||
/**
|
||||
* Tcp Receiving Channel adapter that uses a {@link java.nio.channels.SocketChannel}.
|
||||
|
||||
@@ -17,7 +17,6 @@ package org.springframework.integration.ip.tcp;
|
||||
|
||||
import java.nio.channels.SocketChannel;
|
||||
|
||||
import org.springframework.integration.ip.util.SocketIoUtils;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
Reference in New Issue
Block a user