Toggle navigation
Home
org.redisson.remote.RemoteServiceResponse to org.redisson.remote.RRemoteServiceResponse
No. of Instances - 5
No. of Commits - 2
No. of Projects - {'redisson'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
MessageListener<RemoteServiceResponse>
to
MessageListener<RRemoteServiceResponse>
MessageListener<RemoteServiceResponse>
to
MessageListener<RRemoteServiceResponse>
MessageListener<RemoteServiceResponse>
to
MessageListener<RRemoteServiceResponse>
MessageListener<RemoteServiceResponse>
to
MessageListener<RRemoteServiceResponse>
FutureListener<RemoteServiceResponse>
to
FutureListener<RRemoteServiceResponse>
Add or Remove Method invocation
topic.addListener(new MessageListener<RRemoteServiceResponse>(){ @Override public void onMessage( String channel, RemoteServiceResponse msg){ response.set(msg); latch.countDown(); } } )
to
topic.addListener(new MessageListener<RRemoteServiceResponse>(){ @Override public void onMessage( String channel, RRemoteServiceResponse msg){ if (msg instanceof RemoteServiceResponse) { response.set(msg); latch.countDown(); } else { ackLatch.countDown(); } } } )
topic.addListener(new MessageListener<RRemoteServiceResponse>(){ @Override public void onMessage( String channel, RemoteServiceResponse msg){ response.set(msg); latch.countDown(); } } )
to
topic.addListener(new MessageListener<RRemoteServiceResponse>(){ @Override public void onMessage( String channel, RRemoteServiceResponse msg){ if (msg instanceof RemoteServiceResponse) { response.set(msg); latch.countDown(); } else { ackLatch.countDown(); } } } )
topic.addListener(new MessageListener<RRemoteServiceResponse>(){ @Override public void onMessage( String channel, RemoteServiceResponse msg){ response.set(msg); latch.countDown(); } } )
to
topic.addListener(new MessageListener<RRemoteServiceResponse>(){ @Override public void onMessage( String channel, RRemoteServiceResponse msg){ if (msg instanceof RemoteServiceResponse) { response.set(msg); latch.countDown(); } else { ackLatch.countDown(); } } } )
topic.addListener(new MessageListener<RRemoteServiceResponse>(){ @Override public void onMessage( String channel, RemoteServiceResponse msg){ response.set(msg); latch.countDown(); } } )
to
topic.addListener(new MessageListener<RRemoteServiceResponse>(){ @Override public void onMessage( String channel, RRemoteServiceResponse msg){ if (msg instanceof RemoteServiceResponse) { response.set(msg); latch.countDown(); } else { ackLatch.countDown(); } } } )
Update Anonymous class
{ @Override public void operationComplete( Future<RemoteServiceResponse> future) throws Exception { if (!future.isSuccess()) { result.tryFailure(future.cause()); return; } if (future.getNow() == null) { RemoteServiceTimeoutException e=new RemoteServiceTimeoutException("No response after " + optionsCopy.getExecutionTimeoutInMillis() + "ms for request: "+ request); result.tryFailure(e); return; } if (future.getNow().getError() != null) { result.tryFailure(future.getNow().getError()); return; } result.trySuccess(future.getNow().getResult()); } }
to
{ @Override public void operationComplete( Future<RRemoteServiceResponse> future) throws Exception { if (!future.isSuccess()) { result.tryFailure(future.cause()); return; } if (future.getNow() == null) { RemoteServiceTimeoutException e=new RemoteServiceTimeoutException("No response after " + optionsCopy.getExecutionTimeoutInMillis() + "ms for request: "+ request); result.tryFailure(e); return; } if (future.getNow() instanceof RemoteServiceCancelResponse) { result.doCancel(); return; } RemoteServiceResponse response=(RemoteServiceResponse)future.getNow(); if (response.getError() != null) { result.tryFailure(response.getError()); return; } result.trySuccess(response.getResult()); } }