Class Util

java.lang.Object

org.infinispan.client.hotrod.impl.Util

public class Util
extends Object

Method Summary

Modifier and Type	Method	Description
static <T> T	await(CompletableFuture<T> cf)
static <T> T	await(CompletableFuture<T> cf, long timeoutMillis)
static <T> T	await(CompletionStage<T> cf)
static <T> T	await(CompletionStage<T> cf, long timeoutMillis)
static CompletionStage<Boolean>	checkTransactionSupport(String cacheName, org.infinispan.client.hotrod.impl.operations.ManagerOperationsFactory operationsFactory, org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher dispatcher)
static boolean	checkTransactionSupport(String cacheName, org.infinispan.client.hotrod.impl.operations.ManagerOperationsFactory factory, org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher dispatcher, Log log)
static HotRodClientException	rewrap(Throwable t)
protected static RuntimeException	rewrap(ExecutionException e)
static WrappedByteArray	wrapBytes(byte[] cacheName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

await

public static <T> T await(CompletionStage<T> cf)

await

public static <T> T await(CompletableFuture<T> cf)

await

public static <T> T await(CompletionStage<T> cf,
 long timeoutMillis)

await

public static <T> T await(CompletableFuture<T> cf,
 long timeoutMillis)

rewrap

public static HotRodClientException rewrap(Throwable t)

rewrap

protected static RuntimeException rewrap(ExecutionException e)

checkTransactionSupport

public static CompletionStage<Boolean> checkTransactionSupport(String cacheName,
 org.infinispan.client.hotrod.impl.operations.ManagerOperationsFactory operationsFactory,
 org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher dispatcher)

checkTransactionSupport

public static boolean checkTransactionSupport(String cacheName,
 org.infinispan.client.hotrod.impl.operations.ManagerOperationsFactory factory,
 org.infinispan.client.hotrod.impl.transport.netty.OperationDispatcher dispatcher,
 Log log)

wrapBytes

public static WrappedByteArray wrapBytes(byte[] cacheName)