package com.l7tech.server.cassandra;

import java.util.concurrent.Callable;

class b implements Callable<String> {
   final String val$connectionName;
   final String val$query;
   final long val$queryTimeout;
   final CassandraConnectionManagerAdminImpl this$0;

   b(CassandraConnectionManagerAdminImpl var1, String var2, String var3, long var4) {
      this.this$0 = var1;
      this.val$connectionName = var2;
      this.val$query = var3;
      this.val$queryTimeout = var4;
   }

   public String call() throws Exception {
      return this.this$0.testQuery(this.val$connectionName, this.val$query, this.val$queryTimeout);
   }
}