Toggle navigation
Home
java.lang.String to io.atomix.protocols.backup.protocol.PrimaryBackupClientProtocol
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'atomix'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Add or Remove Method invocation
log.trace("{} {} {}",System.identityHashCode(primaryElection),clientName,primaryElection.getTerm())
to
protocol.registerEventListener(sessionId,this::handleEvent,threadContext)
communicationService.<OpenSessionRequest,OpenSessionResponse>sendAndReceive(openSessionSubject,request,SERIALIZER::encode,SERIALIZER::decode,primary)
to
protocol
communicationService.addSubscriber(eventSubject,SERIALIZER::decode,this::handleEvent,threadContext)
to
protocol.registerEventListener(sessionId,this::handleEvent,threadContext)
clusterService.addListener(clusterEventListener)
to
protocol.registerEventListener(sessionId,this::handleEvent,threadContext)
stateChangeListeners.forEach(l -> l.accept(state))
to
protocol.registerEventListener(sessionId,this::handleEvent,threadContext)
future.completeExceptionally(error)
to
protocol.registerEventListener(sessionId,this::handleEvent,threadContext)
Wrap or Un-wrap
execute
to
execute
Rename Variable
primitiveName
to
protocol
primitiveName
to
protocol