microsoft
/
Omex
зеркало из https://github.com/microsoft/Omex.git
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность
Omex/tests/Hosting.Services.Remoting.U.../MockRemoteListenerBuilder.cs

18 строки
663 B
C#
Исходник Обычный вид История

Create common interface for services and add remoting listeners (#180) Create a common interface for services and add remoting listeners Samaple usage: public async Task Main(string[] args) { await Host .CreateDefaultBuilder(args) .BuildStatelessService( "MyAwesomeService", builder => { builder .AddRemotingListener("MyListener2", CreateService) // Microsoft.Omex.Extensions.Hosting.Services.Remotings .AddRemotingListener<MyListenerBuilder>() }) .RunAsync(); } private static IService CreateService(IService provider, OmexStatelessService service) { ... } private class MyListenerBuilder : RemotingListenerBuilder<OmexStatelessService> { public MyListenerBuilder () : base("ListenerName", listenerSettings) { } public override IService BuildeService(OmexStatelessService service) { ... } }
2020-03-27 22:54:29 +03:00
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT license.
using System.Fabric;
using Microsoft.ServiceFabric.Services.Remoting;
[Breaking Change] Make transport settings required (#639) * Make transport settings required * Update UTs * Update UTs * fix UT * Add custom exception type for insecure remoting --------- Co-authored-by: Keith Cully <kecully@microsoft.com>
2023-11-21 18:24:20 +03:00
using Microsoft.ServiceFabric.Services.Remoting.FabricTransport.Runtime;
Create common interface for services and add remoting listeners (#180) Create a common interface for services and add remoting listeners Samaple usage: public async Task Main(string[] args) { await Host .CreateDefaultBuilder(args) .BuildStatelessService( "MyAwesomeService", builder => { builder .AddRemotingListener("MyListener2", CreateService) // Microsoft.Omex.Extensions.Hosting.Services.Remotings .AddRemotingListener<MyListenerBuilder>() }) .RunAsync(); } private static IService CreateService(IService provider, OmexStatelessService service) { ... } private class MyListenerBuilder : RemotingListenerBuilder<OmexStatelessService> { public MyListenerBuilder () : base("ListenerName", listenerSettings) { } public override IService BuildeService(OmexStatelessService service) { ... } }
2020-03-27 22:54:29 +03:00
namespace Microsoft.Omex.Extensions.Hosting.Services.Remoting.UnitTests
{
internal class MockRemoteListenerBuilder<TService> : RemotingListenerBuilder<TService>
where TService : IServiceFabricService<ServiceContext>
{
[Breaking Change] Make transport settings required (#639) * Make transport settings required * Update UTs * Update UTs * fix UT * Add custom exception type for insecure remoting --------- Co-authored-by: Keith Cully <kecully@microsoft.com>
2023-11-21 18:24:20 +03:00
public MockRemoteListenerBuilder() : base("TestListener", new FabricTransportRemotingListenerSettings()) { }
Create common interface for services and add remoting listeners (#180) Create a common interface for services and add remoting listeners Samaple usage: public async Task Main(string[] args) { await Host .CreateDefaultBuilder(args) .BuildStatelessService( "MyAwesomeService", builder => { builder .AddRemotingListener("MyListener2", CreateService) // Microsoft.Omex.Extensions.Hosting.Services.Remotings .AddRemotingListener<MyListenerBuilder>() }) .RunAsync(); } private static IService CreateService(IService provider, OmexStatelessService service) { ... } private class MyListenerBuilder : RemotingListenerBuilder<OmexStatelessService> { public MyListenerBuilder () : base("ListenerName", listenerSettings) { } public override IService BuildeService(OmexStatelessService service) { ... } }
2020-03-27 22:54:29 +03:00
public override IService BuildService(TService service) => new MockService();
}
}