You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tomee.apache.org by ad...@apache.org on 2012/02/17 04:01:28 UTC
svn commit: r1245307 -
/openejb/trunk/openejb/server/openejb-client/src/main/java/org/apache/openejb/client/Client.java
Author: adc
Date: Fri Feb 17 03:01:28 2012
New Revision: 1245307
URL: http://svn.apache.org/viewvc?rev=1245307&view=rev
Log:
Trivial cleanup.
Modified:
openejb/trunk/openejb/server/openejb-client/src/main/java/org/apache/openejb/client/Client.java
Modified: openejb/trunk/openejb/server/openejb-client/src/main/java/org/apache/openejb/client/Client.java
URL: http://svn.apache.org/viewvc/openejb/trunk/openejb/server/openejb-client/src/main/java/org/apache/openejb/client/Client.java?rev=1245307&r1=1245306&r2=1245307&view=diff
==============================================================================
--- openejb/trunk/openejb/server/openejb-client/src/main/java/org/apache/openejb/client/Client.java (original)
+++ openejb/trunk/openejb/server/openejb-client/src/main/java/org/apache/openejb/client/Client.java Fri Feb 17 03:01:28 2012
@@ -18,7 +18,6 @@ package org.apache.openejb.client;
import static org.apache.openejb.client.Exceptions.newIOException;
-import javax.ejb.ConcurrentAccessTimeoutException;
import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;
@@ -44,13 +43,13 @@ public class Client {
private static final ProtocolMetaData PROTOCOL_VERSION = new ProtocolMetaData("3.1");
- private List<Class<? extends Throwable>> retryConditions = new CopyOnWriteArrayList();
+ private List<Class<? extends Throwable>> retryConditions = new CopyOnWriteArrayList<Class<? extends Throwable>>();
private static Client client = new Client();
private boolean retry = false;
public Client() {
String retryValue = System.getProperty("openejb.client.requestretry", getRetry() + "");
- retry = new Boolean(retryValue);
+ retry = Boolean.valueOf(retryValue);
}
public static boolean addRetryCondition(Class<? extends Throwable> throwable) {
@@ -92,7 +91,7 @@ public class Client {
/* Get a connection to server */
/*----------------------------*/
- Connection conn = null;
+ Connection conn;
try {
if (preferredServerURI != null) {
conn = ConnectionManager.getConnection(preferredServerURI);
@@ -207,7 +206,6 @@ public class Client {
in = conn.getInputStream();
-
} catch (IOException e) {
throw newIOException("Cannot open input stream to server: ", e);
}