Skip to content

Commit

Permalink
Bug 37507574 - [37506280->24.09.3] Hardened fail-over of gRPC APIs
Browse files Browse the repository at this point in the history
(merge ce/main -> ce/24.09 113708)

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v24.09/": change = 113709]
  • Loading branch information
thegridman committed Jan 22, 2025
1 parent ba11005 commit f3f08ea
Showing 1 changed file with 7 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -48,8 +48,9 @@
import com.tangosol.coherence.component.util.daemon.queueProcessor.service.Peer;

import com.tangosol.coherence.component.util.daemon.queueProcessor.service.peer.Acceptor;
import com.tangosol.coherence.component.util.daemon.queueProcessor.service.peer.acceptor.grpcAcceptor.GrpcChannel;

import com.tangosol.internal.net.NamedCacheDeactivationListener;

import com.tangosol.internal.util.collection.ConvertingNamedCache;
import com.tangosol.internal.util.processor.BinaryProcessors;
import com.tangosol.internal.util.processor.CacheProcessors;
Expand Down Expand Up @@ -128,7 +129,11 @@ public void close()
{
com.tangosol.net.messaging.Channel channel = proxy.getChannel();
proxy.unregisterChannel(channel);
proxy.removeMapListener(new CacheListener(proxy.getCacheId()));
NamedCache<?, ?> cache = proxy.getNamedCache();
if (cache != null && cache.isActive())
{
proxy.removeMapListener(new CacheListener(proxy.getCacheId()));
}
}
m_aProxy.clear();
}
Expand Down

0 comments on commit f3f08ea

Please sign in to comment.