init WEB-2313

This commit is contained in:
Vladimir Krivosheev
2012-12-20 15:36:28 +04:00
parent 27c2364d0c
commit 7707558328
2 changed files with 10 additions and 8 deletions
@@ -88,12 +88,7 @@ public class QueueProcessor<T> {
@NotNull
public static QueueProcessor<Runnable> createRunnableQueueProcessor() {
return new QueueProcessor<Runnable>(new Consumer<Runnable>() {
@Override
public void consume(Runnable runnable) {
runnable.run();
}
});
return new QueueProcessor<Runnable>(new RunnableConsumer());
}
@NotNull
@@ -268,4 +263,11 @@ public class QueueProcessor<T> {
return ((MyOverrideEquals)obj).myDelegate == myDelegate;
}
}
public static final class RunnableConsumer implements Consumer<Runnable> {
@Override
public void consume(Runnable runnable) {
runnable.run();
}
}
}
@@ -41,8 +41,8 @@ public class SocketConnectionFactory {
public static <Request extends AbstractRequest, Response extends AbstractResponse>
ClientSocketConnection<Request, Response> createConnection(final @Nullable InetAddress host, int initialPort,
int portsNumberToTry,
RequestResponseExternalizerFactory<Request, Response> factory) {
int portsNumberToTry,
RequestResponseExternalizerFactory<Request, Response> factory) {
return new SocketConnectionImpl<Request, Response>(host, initialPort, portsNumberToTry, factory);
}
}