esiur/esiur-dotnet
2
0
Fork 0
mirror of https://github.com/esiur/esiur-dotnet.git synced 2025-09-13 12:43:17 +00:00
Code Issues Projects Releases Wiki Activity

Working

Browse Source
This commit is contained in:
ahmed
2025-08-26 06:18:15 +03:00
parent dde86c9af7
commit 8f1a29b44e
2 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Test/MyService.cs
View File

@@ -159,8 +159,8 @@ public partial class MyService
[Export] [Export]
public void InvokeEvents(string msg, InvocationContext context) public void InvokeEvents(string msg, InvocationContext context)
{ {
if (context.Connection.Session.AuthorizedAccount != "Alice") //if (context.Connection.Session.AuthorizedAccount != "Alice")
throw new Exception("Only Alice is allowed."); // throw new Exception("Only Alice is allowed.");
StringEvent?.Invoke(msg); StringEvent?.Invoke(msg);
ArrayEvent?.Invoke(new object[] { DateTime.UtcNow, "Event", msg }); ArrayEvent?.Invoke(new object[] { DateTime.UtcNow, "Event", msg });

10
Test/Program.cs
View File

@@ -200,8 +200,7 @@ namespace Test
private static async void TestClient(IResource local) private static async void TestClient(IResource local)
{ {
var con = await new Warehouse().Get<DistributedConnection>("iip://localhost", new DistributedConnectionConfig
var con = await Warehouse.Default.Get<DistributedConnection>("iip://localhost", new DistributedConnectionConfig
{ {
AutoReconnect = true, AutoReconnect = true,
Username = "admin", Username = "admin",
@@ -210,8 +209,11 @@ namespace Test
}); });
dynamic remote = await con.Get("sys/service"); dynamic remote = await con.Get("sys/service");
perodicTimer = new Timer(new TimerCallback(perodicTimerElapsed), remote, 0, 1000);
var pcall = await con.Call("Hello", "whats up ?", DateTime.UtcNow); var pcall = await con.Call("Hello", "whats up ?", DateTime.UtcNow);
var temp = await con.Call("temp"); var temp = await con.Call("temp");
@@ -259,7 +261,7 @@ namespace Test
//Console.WriteLine(path); //Console.WriteLine(path);
perodicTimer = new Timer(new TimerCallback(perodicTimerElapsed), remote, 0, 1000);
} }
static async void perodicTimerElapsed(object state) static async void perodicTimerElapsed(object state)
@@ -268,6 +270,8 @@ namespace Test
try try
{ {
dynamic remote = state; dynamic remote = state;
await remote.InvokeEvents("Hello");
Console.WriteLine("Perodic : " + await remote.AsyncHello()); Console.WriteLine("Perodic : " + await remote.AsyncHello());
} }
catch (Exception ex) catch (Exception ex)