Toggle navigation
Home
io.atomix.protocols.backup.proxy.PrimaryBackupProxySession.Builder to io.atomix.protocols.backup.proxy.PrimaryBackupSessionClient.Builder
No. of Instances - 2
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
BlockingAwareProxySession
to
BlockingAwareSessionClient
Cascading Type Change (Similar)
PrimaryBackupProxySession.Builder
to
PrimaryBackupSessionClient.Builder
Update Anonymous class
{ @Override public ProxySession build(){ Supplier<ProxySession> proxyBuilder=() -> new PrimaryBackupProxySession(clientName,partitionId,sessionIdService.nextSessionId().join(),primitiveType,new PrimitiveDescriptor(primitiveName,primitiveType.name(),configBytes,numBackups,replication),clusterMembershipService,PrimaryBackupClient.this.protocol,primaryElection,threadContextFactory.createContext()); ProxySession proxy; if (recovery == Recovery.RECOVER) { proxy=new RecoveringProxySession(clientName,partitionId,primitiveName,primitiveType,proxyBuilder,threadContextFactory.createContext()); } else { proxy=proxyBuilder.get(); } if (maxRetries > 0) { proxy=new RetryingProxySession(proxy,threadContextFactory.createContext(),maxRetries,retryDelay); } Executor executor=this.executor != null ? this.executor : threadContextFactory.createContext(); return new BlockingAwareProxySession(proxy,executor); } }
to
{ @Override public SessionClient build(){ Supplier<SessionClient> proxyBuilder=() -> new PrimaryBackupSessionClient(clientName,partitionId,sessionIdService.nextSessionId().join(),primitiveType,new PrimitiveDescriptor(primitiveName,primitiveType.name(),configBytes,numBackups,replication),clusterMembershipService,PrimaryBackupClient.this.protocol,primaryElection,threadContextFactory.createContext()); SessionClient proxy; if (recovery == Recovery.RECOVER) { proxy=new RecoveringSessionClient(clientName,partitionId,primitiveName,primitiveType,proxyBuilder,threadContextFactory.createContext()); } else { proxy=proxyBuilder.get(); } if (maxRetries > 0) { proxy=new RetryingSessionClient(proxy,threadContextFactory.createContext(),maxRetries,retryDelay); } Executor executor=this.executor != null ? this.executor : threadContextFactory.createContext(); return new BlockingAwareSessionClient(proxy,executor); } }