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

avoiding warnings

Browse Source
This commit is contained in:
Mark Fisher
2010-11-05 18:33:53 -04:00
parent a3d50d6146
commit 308231f669
1 changed files with 22 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/TcpSendingMessageHandlerTests.java
View File

@@ -38,6 +38,8 @@ import java.util.concurrent.atomic.AtomicBoolean;
import javax.net.ServerSocketFactory;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.Test;
import org.springframework.core.serializer.DefaultDeserializer;
@@ -62,6 +64,9 @@ import org.springframework.integration.support.MessageBuilder;
*/
public class TcpSendingMessageHandlerTests {
private static final Log logger = LogFactory.getLog(TcpSendingMessageHandlerTests.class);
private void readFully(InputStream is, byte[] buff) throws IOException {
for (int i = 0; i < buff.length; i++) {
buff[i] = (byte) is.read();
@@ -86,7 +91,8 @@ public class TcpSendingMessageHandlerTests {
b = ("Reply" + (++i) + "\r\n").getBytes();
socket.getOutputStream().write(b);
}
} catch (Exception e) {
}
catch (Exception e) {
if (!done.get()) {
e.printStackTrace();
}
@@ -745,16 +751,16 @@ public class TcpSendingMessageHandlerTests {
int i = 0;
while (true) {
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
Object in;
Object in = null;
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
if (i == 0) {
in = ois.readObject();
// System.out.println(in);
logger.debug("read object: " + in);
oos.writeObject("world!");
ois = new ObjectInputStream(socket.getInputStream());
oos = new ObjectOutputStream(socket.getOutputStream());
in = ois.readObject();
// System.out.println(in);
logger.debug("read object: " + in);
oos.writeObject("world!");
ois = new ObjectInputStream(socket.getInputStream());
oos = new ObjectOutputStream(socket.getOutputStream());
@@ -762,7 +768,8 @@ public class TcpSendingMessageHandlerTests {
in = ois.readObject();
oos.writeObject("Reply" + (++i));
}
} catch (Exception e) {
}
catch (Exception e) {
if (!done.get()) {
e.printStackTrace();
}
@@ -815,7 +822,7 @@ public class TcpSendingMessageHandlerTests {
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
if (i == 100) {
in = ois.readObject();
// System.out.println(in);
logger.debug("read object: " + in);
oos.writeObject("world!");
ois = new ObjectInputStream(socket.getInputStream());
oos = new ObjectOutputStream(socket.getOutputStream());
@@ -855,7 +862,7 @@ public class TcpSendingMessageHandlerTests {
assertNotNull(mOut);
results.add((String) mOut.getPayload());
}
// System.out.println(results);
logger.debug("results: " + results);
for (int i = 100; i < 1100; i++) {
assertTrue("Missing Reply" + i, results.remove("Reply" + i));
}
@@ -876,16 +883,16 @@ public class TcpSendingMessageHandlerTests {
int i = 0;
while (true) {
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
Object in;
Object in = null;
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
if (i == 0) {
in = ois.readObject();
// System.out.println(in);
logger.debug("read object: " + in);
oos.writeObject("world!");
ois = new ObjectInputStream(socket.getInputStream());
oos = new ObjectOutputStream(socket.getOutputStream());
in = ois.readObject();
// System.out.println(in);
logger.debug("read object: " + in);
oos.writeObject("world!");
ois = new ObjectInputStream(socket.getInputStream());
oos = new ObjectOutputStream(socket.getOutputStream());
@@ -893,7 +900,8 @@ public class TcpSendingMessageHandlerTests {
in = ois.readObject();
oos.writeObject("Reply" + (++i));
}
} catch (Exception e) {
}
catch (Exception e) {
if (!done.get()) {
e.printStackTrace();
}
@@ -932,16 +940,16 @@ public class TcpSendingMessageHandlerTests {
int i = 0;
while (true) {
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
Object in;
Object in = null;
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
if (i == 0) {
in = ois.readObject();
// System.out.println(in);
logger.debug("read object: " + in);
oos.writeObject("world!");
ois = new ObjectInputStream(socket.getInputStream());
oos = new ObjectOutputStream(socket.getOutputStream());
in = ois.readObject();
// System.out.println(in);
logger.debug("read object: " + in);
oos.writeObject("world!");
ois = new ObjectInputStream(socket.getInputStream());
oos = new ObjectOutputStream(socket.getOutputStream());