[Owner("main")]
[Service("orders")]
public interface IOrderService
{
    [Endpoint("order.changed")] 
    EventHandler<Order> OrderChanged { get; }
    
    [Endpoint("order.create")]
    Func<Order, int> CreateOrder { get; }
    
    [Endpoint("order.update")]
    Action<Order> UpdateOrder { get; }
}

[Contract("order")]
public class Order
{
    public int Number { get; set; }
    public string Customer { get; set; }
    public List<OrderLine> Lines { get; set; }
}

public class OrderLine
{
    public string GoodCode { get; set; }
    public double Quantity { get; set; }
    public double Price { get; set; }
}

using (var link =
            new ServiceLinkBuilder()
                .HolderName("testserver")
                .Uri("amqp://localhost")
                .AutoStart(true)
                .ConnectionName("Test process")
                .Build())
{
    link.Service<IOrderService>().Call(p => p.CreateOrder)
        .Process((order, cancellation) => Task.FromResult(25));  
    link.Service<IOrderService>().Event(p => p.OrderChanged)
        .PublishAsync(new Order { Numder = 25 });
    Console.ReadKey();    
}

using (var link =
            new ServiceLinkBuilder()
                .HolderName("testclient")
                .Uri("amqp://localhost")
                .AutoStart(true)
                .ConnectionName("Test process")
                .Build())
{
    var id = await link.Service<IOrderService>().Call(p => p.CreateOrder)
        .Call(new Order { Numder = 25 });  
    link.Service<IOrderService>().Event(p => p.OrderChanged)
        .Listen((order, cancellation) => Console.WriteLine($"Order {order.Numder} has been changed");
    
    Console.ReadKey();    
}