COH-25531 - Port COH-24968 - RFA: Exception occurred while encoding a AggregateAllRequest results in total disconnect for client to .net

[git-p4: depot-paths = "//dev/main.net/": change = 92662]

Author: rlubke

src/Coherence.Core/Net/Messaging/Impl/NamedCache/NamedCacheFactory.cs

@@ -1,8 +1,8 @@
 /*
- * Copyright (c) 2000, 2020, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
- * http://oss.oracle.com/licenses/upl.
+ * https://oss.oracle.com/licenses/upl.
  */
 using System;
 
@@ -75,6 +75,7 @@ public NamedCacheFactory()
         /// </summary>
         private Type[] messagingTypes = { typeof(AggregateAllRequest),
                                           typeof(AggregateFilterRequest),
+                                          typeof(CacheEvent),
                                           typeof(ClearRequest),
                                           typeof(ContainsAllRequest),
                                           typeof(ContainsKeyRequest),
@@ -88,15 +89,15 @@ public NamedCacheFactory()
                                           typeof(ListenerFilterRequest),
                                           typeof(ListenerKeyRequest),
                                           typeof(LockRequest),
-                                          typeof(CacheEvent),
                                           typeof(NamedCachePartialResponse),
+                                          typeof(NamedCacheResponse),
+                                          typeof(NoStorageMembers),
                                           typeof(PutAllRequest),
                                           typeof(PutRequest),
                                           typeof(QueryRequest),
                                           typeof(RemoveAllRequest),
                                           typeof(RemoveRequest),
                                           typeof(SizeRequest),
-                                          typeof(UnlockRequest),
-                                          typeof(NamedCacheResponse) };
+                                          typeof(UnlockRequest) };
     }
 }

src/Coherence.Core/Net/Messaging/Impl/NamedCache/NamedCacheProtocol.cs

@@ -2,7 +2,7 @@
  * Copyright (c) 2000, 2022, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
- * http://oss.oracle.com/licenses/upl.
+ * https://oss.oracle.com/licenses/upl.
  */
 namespace Tangosol.Net.Messaging.Impl.NamedCache
 {
@@ -49,7 +49,7 @@ public static NamedCacheProtocol Instance
         /// </summary>
         protected NamedCacheProtocol()
         {
-            CurrentVersion   = 9;
+            CurrentVersion   = 10;
             SupportedVersion = 2;
         }
 

src/Coherence.Core/Net/Messaging/Impl/NamedCache/NoStorageMembers.cs

@@ -0,0 +1,61 @@
+/*
+ * Copyright (c) 2022, Oracle and/or its affiliates.
+ *
+ * Licensed under the Universal Permissive License v 1.0 as shown at
+ * https://oss.oracle.com/licenses/upl.
+ */
+using Tangosol.Net.Cache;
+using Tangosol.Net.Cache.Support;
+using Tangosol.Net.Impl;
+using Tangosol.Util;
+
+namespace Tangosol.Net.Messaging.Impl.NamedCache
+{
+    /// <summary>
+    /// Message indicating no storage members are available to
+    /// service a request.
+    /// </summary>
+    /// <author>rl  2022.05.13</author>
+    /// <seealso cref="NamedCacheRequest"/>
+    /// <seealso cref="NamedCacheProtocol"/>
+    public class NoStorageMembers : NamedCacheRequest
+    {
+        #region Properties
+
+        /// <inheritdoc />
+        public override int TypeId
+        {
+            get { return TYPE_ID; }
+        }
+        
+        #endregion
+        
+        #region Extend Overrides
+
+        /// <inheritdoc />
+        protected override void OnRun(Response response)
+        {
+            IChannel         channel   = Channel;
+            RemoteNamedCache cache     = (RemoteNamedCache) channel.Receiver;
+            Listeners        listeners = cache.DeactivationListeners;
+
+            if (!listeners.IsEmpty)
+            {
+                CacheEventArgs evtDeleted = new CacheEventArgs(cache, CacheEventType.Deleted,
+                    null, null, null, false);
+                RunnableCacheEvent.DispatchSafe(evtDeleted, listeners, null /*Queue*/);
+            }
+        }
+
+        #endregion
+
+        #region Data members
+
+        /// <summary>
+        /// The type identifier for this Message class.
+        /// </summary>
+        public const int TYPE_ID = 56;
+
+        #endregion
+    }
+}