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