Skip to content

Commit

Permalink
Bug 37507573 - [37506280->14.1.2.0.2] Hardened fail-over of gRPC APIs…
Browse files Browse the repository at this point in the history
… (14.1.2.0 cl 113710 --> ce/14.1.2.0)

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v14.1.2.0/": change = 113716]
  • Loading branch information
fryp committed Jan 22, 2025
1 parent 95b9fd9 commit 306bf4a
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 306bf4a

Please sign in to comment.