Toggle navigation
Home
java.lang.String to java.lang.Void
No. of Instances - 14
No. of Commits - 10
No. of Projects - {'alluxio', 'ignite', 'uaa', 'pulsar', 'james-project', 'redisson'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Cascading Type Change (Different)
getUserLocalTempFolder_result
to
cancelBlock_result
Cascading Type Change (Similar)
String
to
Void
AsyncMethodCallback<String>
to
AsyncMethodCallback<Void>
Future<String>
to
Future<Void>
Update Anonymous class
{ public void onComplete( String o){ getUserLocalTempFolder_result result=new getUserLocalTempFolder_result(); result.success=o; try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; getUserLocalTempFolder_result result=new getUserLocalTempFolder_result(); { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } }
to
{ public void onComplete( Void o){ cancelBlock_result result=new cancelBlock_result(); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; cancelBlock_result result=new cancelBlock_result(); { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } }
Add or Remove Method invocation
RedisCommands.PING
to
config.getPassword()
Update argument list (Method invocation)
asyncWithTimeout
to
asyncWithTimeout
Rename Variable
f
to
temp
f
to
temp
tokenResponse
to
clientCreateResponse
Other
new FutureListener<String>(){ @Override public void operationComplete( Future<String> future) throws Exception { try { if (entry.getFreezeReason() != FreezeReason.RECONNECT || !entry.isFreezed()) { return; } if (future.isSuccess() && "PONG".equals(future.getNow())) { entry.resetFailedAttempts(); Promise<Void> promise=connectionManager.newPromise(); promise.addListener(new FutureListener<Void>(){ @Override public void operationComplete( Future<Void> future) throws Exception { if (entry.getNodeType() == NodeType.SLAVE) { masterSlaveEntry.slaveUp(entry.getClient().getAddr().getHostName(),entry.getClient().getAddr().getPort(),FreezeReason.RECONNECT); log.info("slave {} successfully reconnected",entry.getClient().getAddr()); } else { synchronized (entry) { if (entry.getFreezeReason() == FreezeReason.RECONNECT) { entry.setFreezed(false); entry.setFreezeReason(null); log.info("host {} successfully reconnected",entry.getClient().getAddr()); } } } } } ); initConnections(entry,promise,false); } else { scheduleCheck(entry); } } finally { c.closeAsync(); } } }
to
listener