Author: jbellis
Date: Fri Jul 29 05:53:51 2011
New Revision: 1152112
URL: http://svn.apache.org/viewvc?rev=1152112&view=rev
Log:
revert incomplete code, better
Modified:
cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
Modified:
cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
URL:
http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java?rev=1152112&r1=1152111&r2=1152112&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
(original)
+++ cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java Fri
Jul 29 05:53:51 2011
@@ -136,7 +136,7 @@ public final class MessagingService impl
}
};
StorageService.scheduledTasks.scheduleWithFixedDelay(logDropped,
LOG_DROPPED_INTERVAL_IN_MS, LOG_DROPPED_INTERVAL_IN_MS, TimeUnit.MILLISECONDS);
-onfi
+
Function<Pair<String, Pair<InetAddress, IMessageCallback>>, ?>
timeoutReporter = new Function<Pair<String, Pair<InetAddress,
IMessageCallback>>, Object>()
{
public Object apply(Pair<String, Pair<InetAddress,
IMessageCallback>> pair)
