Add new SendAll/SendAllAsync/SendAllOneWay API's to IServiceClient in…

…terfaces
ServiceStack · Nov 14, 2014 · 3c3047a · 3c3047a
1 parent 78d00a6
commit 3c3047a
Show file tree

Hide file tree

Showing 18 changed files with 92 additions and 3 deletions.
diff --git a/lib/ServiceStack.Client.dll b/lib/ServiceStack.Client.dll
diff --git a/lib/ServiceStack.Common.dll b/lib/ServiceStack.Common.dll
diff --git a/lib/ServiceStack.Interfaces.dll b/lib/ServiceStack.Interfaces.dll
diff --git a/lib/ServiceStack.Razor.BuildTask.dll b/lib/ServiceStack.Razor.BuildTask.dll
diff --git a/lib/ServiceStack.dll b/lib/ServiceStack.dll
diff --git a/lib/ServiceStack.pdb b/lib/ServiceStack.pdb
diff --git a/src/ServiceStack.Client/Messaging/InMemoryMessageQueueClient.cs b/src/ServiceStack.Client/Messaging/InMemoryMessageQueueClient.cs
@@ -2,6 +2,7 @@
 //License: https://raw.github.com/ServiceStack/ServiceStack/master/license.txt
 
 using System;
+using System.Collections.Generic;
 
 namespace ServiceStack.Messaging
 {
@@ -49,6 +50,11 @@ public void SendOneWay(string queueName, object requestDto)
             Publish(queueName, MessageFactory.Create(requestDto));
         }
 
+        public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         public void Notify(string queueName, IMessage message)
         {
             var messageBytes = message.ToBytes();

diff --git a/src/ServiceStack.Client/Messaging/RedisMessageProducer.cs b/src/ServiceStack.Client/Messaging/RedisMessageProducer.cs
@@ -2,6 +2,7 @@
 //License: https://raw.github.com/ServiceStack/ServiceStack/master/license.txt
 
 using System;
+using System.Collections.Generic;
 using ServiceStack.Redis;
 using ServiceStack.Text;
 
@@ -63,7 +64,12 @@ public void SendOneWay(string queueName, object requestDto)
             Publish(queueName, MessageFactory.Create(requestDto));
         }
 
-        public void Publish(string queueName, IMessage message)
+	    public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+	    {
+	        throw new NotImplementedException();
+	    }
+
+	    public void Publish(string queueName, IMessage message)
         {
             using (__requestAccess())
             {

diff --git a/src/ServiceStack.Client/Messaging/RedisMessageQueueClient.cs b/src/ServiceStack.Client/Messaging/RedisMessageQueueClient.cs
@@ -2,6 +2,7 @@
 //License: https://raw.github.com/ServiceStack/ServiceStack/master/license.txt
 
 using System;
+using System.Collections.Generic;
 using ServiceStack.Redis;
 
 namespace ServiceStack.Messaging
@@ -79,6 +80,11 @@ public void SendOneWay(string queueName, object requestDto)
             Publish(queueName, MessageFactory.Create(requestDto));
         }
 
+        public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         public void Publish(string queueName, IMessage message)
         {
             using (__requestAccess())

diff --git a/src/ServiceStack.Client/WcfServiceClient.cs b/src/ServiceStack.Client/WcfServiceClient.cs
@@ -338,6 +338,11 @@ public void Send(IReturnVoid request)
             throw new NotImplementedException();
         }
 
+        public List<TResponse> SendAll<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         public void Get(IReturnVoid request)
         {
             throw new NotImplementedException();
@@ -529,6 +534,11 @@ public void SendOneWay(string relativeOrAbsoluteUrl, object request)
             SendOneWay(Message.CreateMessage(MessageVersion, relativeOrAbsoluteUrl, request));
         }
 
+        public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         public void SendOneWay(object requestDto, string action)
         {
             SendOneWay(Message.CreateMessage(MessageVersion, action, requestDto));
@@ -657,6 +667,11 @@ public Task<TResponse> SendAsync<TResponse>(object requestDto)
             throw new NotImplementedException();
         }
 
+        public Task<List<TResponse>> SendAllAsync<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         public void Dispose()
         {
         }

diff --git a/src/ServiceStack.Interfaces/IOneWayClient.cs b/src/ServiceStack.Interfaces/IOneWayClient.cs
@@ -1,9 +1,13 @@
+using System.Collections.Generic;
+
 namespace ServiceStack
 {
     public interface IOneWayClient
     {
         void SendOneWay(object requestDto);
 
         void SendOneWay(string relativeOrAbsoluteUri, object requestDto);
+
+        void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests);
     }
 }
diff --git a/src/ServiceStack.Interfaces/IReplyClient.cs b/src/ServiceStack.Interfaces/IReplyClient.cs
@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using System.IO;
 
 namespace ServiceStack
@@ -12,5 +13,7 @@ public interface IReplyClient
 		TResponse Send<TResponse>(object request);
         TResponse Send<TResponse>(IReturn<TResponse> request);
 	    void Send(IReturnVoid request);
-	}
+
+        List<TResponse> SendAll<TResponse>(IEnumerable<IReturn<TResponse>> requests);
+    }
 }
diff --git a/src/ServiceStack.Interfaces/IServiceClientAsync.cs b/src/ServiceStack.Interfaces/IServiceClientAsync.cs
@@ -1,9 +1,11 @@
+using System.Collections.Generic;
 using System.Threading.Tasks;
 
 namespace ServiceStack
 {
 	public interface IServiceClientAsync : IRestClientAsync
 	{
 		Task<TResponse> SendAsync<TResponse>(object requestDto);
-	}
+        Task<List<TResponse>> SendAllAsync<TResponse>(IEnumerable<IReturn<TResponse>> requests);
+    }
 }
diff --git a/src/ServiceStack.RabbitMq/RabbitMqProducer.cs b/src/ServiceStack.RabbitMq/RabbitMqProducer.cs
@@ -83,6 +83,11 @@ public void SendOneWay(string queueName, object requestDto)
             Publish(queueName, MessageFactory.Create(requestDto));
         }
 
+        public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         public void Publish(string queueName, IMessage message, string exchange)
         {
             using (__requestAccess())

diff --git a/src/ServiceStack.Server/Messaging/Rcon/PacketProcessingClient.cs b/src/ServiceStack.Server/Messaging/Rcon/PacketProcessingClient.cs
@@ -1,5 +1,6 @@
 #if !SL5 
 using System;
+using System.Collections.Generic;
 using System.Net.Sockets;
 
 namespace ServiceStack.Messaging.Rcon
@@ -45,6 +46,11 @@ public void SendOneWay(string queueName, object requestDto)
             Publish(queueName, MessageFactory.Create(requestDto));
         }
 
+        public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         /// <summary>
         /// Publish the specified message into the durable queue @queueName
         /// </summary>

diff --git a/src/ServiceStack/Messaging/InMemoryTransientMessageFactory.cs b/src/ServiceStack/Messaging/InMemoryTransientMessageFactory.cs
@@ -1,4 +1,5 @@
 #if !SL5
+using System.Collections.Generic;
 using ServiceStack.Logging;
 
 namespace ServiceStack.Messaging
@@ -84,6 +85,11 @@ public void SendOneWay(string queueName, object requestDto)
                 Publish(queueName, MessageFactory.Create(requestDto));
             }
 
+            public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+            {
+                throw new System.NotImplementedException();
+            }
+
             public void Dispose()
             {
             }

diff --git a/tests/ServiceStack.Common.Tests/TestBase.cs b/tests/ServiceStack.Common.Tests/TestBase.cs
@@ -111,6 +111,11 @@ public void SendOneWay(string relativeOrAbsoluteUri, object requestDto)
                 ServiceManager.Execute(requestDto);
             }
 
+            public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+            {
+                throw new NotImplementedException();
+            }
+
             public TResponse Send<TResponse>(object request)
             {
                 var message = MessageFactory.Create(request);
@@ -156,6 +161,11 @@ public void Send(IReturnVoid request)
                 throw new NotImplementedException();
             }
 
+            public List<TResponse> SendAll<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+            {
+                throw new NotImplementedException();
+            }
+
             public HttpWebResponse Get(object request)
             {
                 throw new NotImplementedException();
@@ -367,6 +377,11 @@ public Task<TResponse> SendAsync<TResponse>(object requestDto)
                 return tcs.Task;
             }
 
+            public Task<List<TResponse>> SendAllAsync<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+            {
+                throw new NotImplementedException();
+            }
+
             private static void HandleException<TResponse>(Exception exception, Action<TResponse, Exception> onError)
             {
                 var response = (TResponse)typeof(TResponse).CreateInstance();

diff --git a/tests/ServiceStack.WebHost.Endpoints.Tests/Support/DirectServiceClient.cs b/tests/ServiceStack.WebHost.Endpoints.Tests/Support/DirectServiceClient.cs
@@ -32,6 +32,11 @@ public void SendOneWay(string relativeOrAbsoluteUri, object requestDto)
             ServiceController.Execute(requestDto);
         }
 
+        public void SendAllOneWay<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         private bool ApplyRequestFilters<TResponse>(object request)
         {
             if (HostContext.ApplyRequestFilters(httpReq, httpRes, request))
@@ -101,6 +106,11 @@ public void Send(IReturnVoid request)
             throw new NotImplementedException();
         }
 
+        public List<TResponse> SendAll<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         public TResponse Patch<TResponse>(string relativeOrAbsoluteUrl, object requestDto)
         {
             throw new NotImplementedException();
@@ -346,6 +356,11 @@ public Task<TResponse> SendAsync<TResponse>(object requestDto)
             }
         }
 
+        public Task<List<TResponse>> SendAllAsync<TResponse>(IEnumerable<IReturn<TResponse>> requests)
+        {
+            throw new NotImplementedException();
+        }
+
         public void SetCredentials(string userName, string password)
         {
             throw new NotImplementedException();