Toggle navigation
Home
java.util.Map<org.infinispan.remoting.transport.Address, org.infinispan.remoting.responses.Response> to org.infinispan.remoting.responses.Response
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'infinispan'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Add or Remove Method invocation
Collections.singletonList(getExecutionTarget())
to
DeliverOrder.NONE
rpc.invokeRemotelyAsync(DeliverOrder.NONE,getCommand(),rpc.getRpcOptionsBuilder(DeliverOrder.SYNCHRONOUS).timeout(getOwningTask().timeout(),TimeUnit.MILLISECONDS).build())
to
rpc.invokeCommand(getExecutionTarget(),getCommand(),SingleResponseCollector.validOnly(),new RpcOptions(DeliverOrder.NONE,getOwningTask().timeout(),TimeUnit.MILLISECONDS))
retrieveResult(v)
to
r
rpcFuture.thenAccept(responseMap -> { Response response=getSingleResponse(responseMap); if (response.isSuccessful()) { InternalCacheValue value=(InternalCacheValue)((SuccessfulResponse)response).getResponseValue(); if (value != null) { InternalCacheEntry cacheEntry=value.toInternalCacheEntry(key); entryFactory.wrapExternalEntry(ctx,key,cacheEntry,true,false); } else { entryFactory.wrapExternalEntry(ctx,key,NullCacheEntry.getInstance(),false,false); } } else if (response instanceof UnsureResponse) { throw OutdatedTopologyException.RETRY_NEXT_TOPOLOGY; } else if (response instanceof CacheNotFoundResponse) { throw AllOwnersLostException.INSTANCE; } else { throw new IllegalArgumentException("Unexpected response " + response); } } )
to
rpcFuture.thenAccept(response -> { if (response.isSuccessful()) { InternalCacheValue value=(InternalCacheValue)((SuccessfulResponse)response).getResponseValue(); if (value != null) { InternalCacheEntry cacheEntry=value.toInternalCacheEntry(key); entryFactory.wrapExternalEntry(ctx,key,cacheEntry,true,false); } else { entryFactory.wrapExternalEntry(ctx,key,NullCacheEntry.getInstance(),false,false); } } else if (response instanceof UnsureResponse) { throw OutdatedTopologyException.RETRY_NEXT_TOPOLOGY; } else if (response instanceof CacheNotFoundResponse) { throw AllOwnersLostException.INSTANCE; } else if (response instanceof ExceptionResponse) { throw ResponseCollectors.wrapRemoteException(info.primary(),((ExceptionResponse)response).getException()); } else { throw new IllegalArgumentException("Unexpected response " + response); } } )
rpc.thenApply(responses -> { Response response=getSingleResponse(responses); if (response.isSuccessful()) { return ((SuccessfulResponse)response).getResponseValue(); } else if (response instanceof UnsureResponse) { throw OutdatedTopologyException.RETRY_NEXT_TOPOLOGY; } else if (response instanceof CacheNotFoundResponse) { throw AllOwnersLostException.INSTANCE; } else { throw new IllegalArgumentException("Unexpected response " + response); } } )
to
rpc.thenApply(response -> { if (response.isSuccessful()) { return ((SuccessfulResponse)response).getResponseValue(); } else if (response instanceof UnsureResponse) { throw OutdatedTopologyException.RETRY_NEXT_TOPOLOGY; } else if (response instanceof CacheNotFoundResponse) { throw AllOwnersLostException.INSTANCE; } else if (response instanceof ExceptionResponse) { throw ResponseCollectors.wrapRemoteException(info.primary(),((ExceptionResponse)response).getException()); } else { throw new IllegalArgumentException("Unexpected response " + response); } } )
Cascading Type Change (Similar)
Map<Address,Response>
to
Response
Cascading Type Change (Different)
ResponseMode
to
DeliverOrder
Rename Variable
v
to
r