Succubus.Core by Succubus.io

<PackageReference Include="Succubus.Core" Version="0.1.30" />

---

API Diff between 0.1.30 and 0.1.2-pre

152 Additions 40 Removals

Succubus.Collections

• public class TimeoutHandler<TKey, TValue> where TValue : IExpiring<TKey>
  • public TimeoutHandler()
  • public void DumpTimeoutTable()
  • public IEnumerable<TValue> GetAndRemoveValues(TKey correlationId)
  • public IEnumerable<TValue> GetValues(TKey correlationId)
  • public int NumberOfItemsForTimeout()
  • public void RemoveTimeout(TKey correlationId)
  • public long Timeout(TValue value, int milliseconds)

Succubus.Collections.Interfaces

• public interface IExpiring<T>
  • T Id { get; }
  • bool TimedOut { get; set; }
  • Action TimeoutHandler { get; }
  • void OnTimeout()
• public interface INow
  • DateTime Now { get; }

Succubus.Core

• public class Bus : IBusConfigurator, IBus, ITransportBridge
  • public string MessageHostPublishAddress { get; set; }
  • public string MessageHostSubscribeAddress { get; set; }
  • public string Network { get; set; }
  • public string PublishAddress { get; set; }
  • public bool StartMessageHost { get; set; }
  • public string SubscribeAddress { get; set; }
  • public ITransportBridge Bridge { get; set; }
  • public ICorrelationIdProvider CorrelationIdProvider { get; set; }
  • public bool IncludeMessageOriginator { get; set; }
  • public LogLevel LogLevel { get; set; }
  • public TextWriter LogWriter { get; set; }
  • public string Name { get; set; }
  • public ISubscriptionManager SubscriptionManager { get; set; }
  • public ITransport Transport { get; set; }
  • public event EventHandler<ExceptionEventArgs> Exception
  • public event EventHandler<ExceptionEventArgs> HandlerException
  • public event EventHandler<ExceptionEventArgs> MessageCreationException
  • public event EventHandler<ExceptionEventArgs> TransportException
  • public void Call<TReq, TRes>(TReq request, Action<TRes> handler)
  • public TRes Call<TReq, TRes>(TReq request)
  • public Guid Call<TReq>(TReq request, Action<TReq> timeoutHandler = null, int timeout = 0)
  • public Task<TRes> CallAsync<TReq, TRes>(TReq request)
  • public IResponseContext Defer<TReq, T>()
  • public IResponseContext Defer<TReq, T1, T2>()
  • public IResponseContext Defer<TReq, T1, T2, T3>()
  • public IResponseContext Defer<TReq, T1, T2, T3, T4>()
  • public IResponseContext Defer<TReq, T1, T2, T3, T4, T5>()
  • public IResponseContext Defer<TReq, T1, T2, T3, T4, T5, T6>()
  • public IResponseContext Defer<TReq, T1, T2, T3, T4, T5, T6, T7>()
  • public void DumpTimeoutTable()
  • public void GetFromConfigurationFile()
  • public void Initialize()
  • public void Initialize(Action<IBusConfigurator> initializationHandler)
  • public IResponseContext On<T>(Action<T> handler)
  • public IResponseContext OnReply<TReq, T>(Action<TReq, T> handler)
  • public IResponseContext OnReply<TReq, T1, T2>(Action<TReq, T1, T2> handler)
  • public IResponseContext OnReply<TReq, T1, T2, T3>(Action<TReq, T1, T2, T3> handler)
  • public IResponseContext OnReply<TReq, T1, T2, T3, T4>(Action<TReq, T1, T2, T3, T4> handler)
  • public IResponseContext OnReply<TReq, T1, T2, T3, T4, T5>(Action<TReq, T1, T2, T3, T4, T5> handler)
  • public IResponseContext OnReply<TReq, T1, T2, T3, T4, T5, T6>(Action<TReq, T1, T2, T3, T4, T5, T6> handler)
  • public IResponseContext OnReply<TReq, T1, T2, T3, T4, T5, T6, T7>(Action<TReq, T1, T2, T3, T4, T5, T6, T7> handler)
  • public IResponseContext Pickup<TReq, T>(Guid correlationId, Action<TReq, T> handler)
  • public IResponseContext Pickup<TReq, T1, T2>(Guid correlationId, Action<TReq, T1, T2> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3>(Guid correlationId, Action<TReq, T1, T2, T3> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3, T4>(Guid correlationId, Action<TReq, T1, T2, T3, T4> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3, T4, T5>(Guid correlationId, Action<TReq, T1, T2, T3, T4, T5> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3, T4, T5, T6>(Guid correlationId, Action<TReq, T1, T2, T3, T4, T5, T6> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3, T4, T5, T6, T7>(Guid correlationId, Action<TReq, T1, T2, T3, T4, T5, T6, T7> handler)
  • public void Publish<T>(T request)
  • public void ReplyTo<TReq, TRes>(Func<TReq, TRes> handler)
  • public void Call<TReq, TRes>(TReq request, Action<TRes> handler, string address = null, Action<Action> marshal = null)
  • public TRes Call<TReq, TRes>(TReq request, string address = null, int timeout = 10000, Func<Func<TReq, TRes>, TReq, TRes> marshal = null)
  • public string Call<TReq>(TReq request, Action<TReq> timeoutHandler = null, string address = null, int timeout = 10000, Action<Action> marshal = null)
  • public Task<TRes> CallAsync<TReq, TRes>(TReq request, string address = null, int timeout = 10000, Func<Func<TReq, TRes>, TReq, TRes> marshal = null)
  • public IResponseContext Dequeue<T>(Action<T> handler, string address = null, Action<Action> marshal = null)
  • public void FrameMessage(IMessageFrame o)
  • public void GeneralTransportException(Exception ex)
  • public Diagnose GetDiagnose()
  • public void Initialize(Action<IBusConfigurator> initializationHandler)
  • public TRes InternalCall<TReq, TRes>(TReq request, string address = null, int timeout = 10000)
  • public IResponseContext On<T>(Action<T> handler, string address = null, Action<Action> marshal = null)
  • public IResponseContext OnRawData(Action<string> handler, Action<Action> marshal = null)
  • public IResponseContext OnRawMessage(Action<object> handler, Action<Action> marshal = null)
  • public IResponseContext OnReply<TReq, T>(Action<TReq, T> handler, Action<Action> marshal = null)
  • public IResponseContext OnReply<TReq, T1, T2>(Action<TReq, T1, T2> handler, Action<Action> marshal = null)
  • public IResponseContext OnReply<TReq, T1, T2, T3>(Action<TReq, T1, T2, T3> handler, Action<Action> marshal = null)
  • public IResponseContext OnReply<TReq, T1, T2, T3, T4>(Action<TReq, T1, T2, T3, T4> handler, Action<Action> marshal = null)
  • public IResponseContext OnReply<TReq, T1, T2, T3, T4, T5>(Action<TReq, T1, T2, T3, T4, T5> handler, Action<Action> marshal = null)
  • public IResponseContext OnReply<TReq, T1, T2, T3, T4, T5, T6>(Action<TReq, T1, T2, T3, T4, T5, T6> handler, Action<Action> marshal = null)
  • public IResponseContext OnReply<TReq, T1, T2, T3, T4, T5, T6, T7>(Action<TReq, T1, T2, T3, T4, T5, T6, T7> handler, Action<Action> marshal = null)
  • public void ProcessCatchAllEvents(Synchronous eventFrame, string address)
  • public void ProcessEvents(Event eventFrame, string address)
  • public void ProcessSynchronousMessages(Synchronous synchronousFrame, string address)
  • public void Publish<T>(T request, string address = null, Action<Action> marshal = null)
  • public void Queue<T>(T request, string address = null, Action<Action> marshal = null)
  • public void RawData(string data)
  • public void RawMessage(object o)
  • public void ReplyTo<TReq, TRes>(Func<TReq, TRes> handler, string address = null, Func<Func<TReq, TRes>, TReq, TRes> marshal = null)
  • public void UnableToCreateMessage(Exception ex)
• public class Diagnose
  • public int NumberOfItemsForTimeout { get; set; }
  • public ulong ReceivedMessages { get; set; }
  • public ulong SentMessages { get; set; }
  • public int SynchronizationContexts { get; set; }
  • public Diagnose()
• public enum LogLevel
  • Error = 1
  • Fatal = 0
  • Info = 3
  • None = 5
  • Trace = 4
  • Warning = 2
• public class SynchronousMessageFrame

Succubus.Core.Diagnostics

• public class ExceptionEventArgs : EventArgs
  • public Exception Exception { get; set; }
  • public ExceptionEventArgs()
• public class Ping : Diagnostic
  • public Ping()
• public class Pong : Diagnostic
  • public Pong()

Succubus.Core.Interfaces

• public interface IBus
  • string Name { get; }
  • event EventHandler<ExceptionEventArgs> Exception
  • event EventHandler<ExceptionEventArgs> HandlerException
  • event EventHandler<ExceptionEventArgs> MessageCreationException
  • event EventHandler<ExceptionEventArgs> TransportException
  • void Call<TReq, TRes>(TReq request, Action<TRes> handler, string address = null, Action<Action> marshal = null)
  • TRes Call<TReq, TRes>(TReq request, string address = null, int timeout = 10000, Func<Func<TReq, TRes>, TReq, TRes> marshal = null)
  • string Call<TReq>(TReq request, Action<TReq> timeoutHandler = null, string address = null, int timeout = 60000, Action<Action> marshal = null)
  • Task<TRes> CallAsync<TReq, TRes>(TReq request, string address = null, int timeout = 10000, Func<Func<TReq, TRes>, TReq, TRes> marshal = null)
  • IResponseContext Dequeue<T>(Action<T> handler, string address = null, Action<Action> marshal = null)
  • Diagnose GetDiagnose()
  • void Initialize(Action<IBusConfigurator> initializationHandler)
  • IResponseContext On<T>(Action<T> handler, string address = null, Action<Action> marshal = null)
  • IResponseContext OnRawData(Action<string> handler, Action<Action> marshal = null)
  • IResponseContext OnRawMessage(Action<object> handler, Action<Action> marshal = null)
  • IResponseContext OnReply<TReq, T>(Action<TReq, T> handler, Action<Action> marshal = null)
  • IResponseContext OnReply<TReq, T1, T2>(Action<TReq, T1, T2> handler, Action<Action> marshal = null)
  • IResponseContext OnReply<TReq, T1, T2, T3>(Action<TReq, T1, T2, T3> handler, Action<Action> marshal = null)
  • IResponseContext OnReply<TReq, T1, T2, T3, T4>(Action<TReq, T1, T2, T3, T4> handler, Action<Action> marshal = null)
  • IResponseContext OnReply<TReq, T1, T2, T3, T4, T5>(Action<TReq, T1, T2, T3, T4, T5> handler, Action<Action> marshal = null)
  • IResponseContext OnReply<TReq, T1, T2, T3, T4, T5, T6>(Action<TReq, T1, T2, T3, T4, T5, T6> handler, Action<Action> marshal = null)
  • IResponseContext OnReply<TReq, T1, T2, T3, T4, T5, T6, T7>(Action<TReq, T1, T2, T3, T4, T5, T6, T7> handler, Action<Action> marshal = null)
  • void Publish<T>(T request, string address = null, Action<Action> marshal = null)
  • void Queue<T>(T request, string address = null, Action<Action> marshal = null)
  • void ReplyTo<TReq, TRes>(Func<TReq, TRes> handler, string address = null, Func<Func<TReq, TRes>, TReq, TRes> marshal = null)
• public interface IBusConfigurator
  • ITransportBridge Bridge { get; set; }
  • ICorrelationIdProvider CorrelationIdProvider { get; set; }
  • bool IncludeMessageOriginator { get; set; }
  • LogLevel LogLevel { get; set; }
  • TextWriter LogWriter { get; set; }
  • string Name { get; set; }
  • ISubscriptionManager SubscriptionManager { get; set; }
  • ITransport Transport { get; set; }
• public interface ICorrelationIdProvider
  • string CreateCorrelationId(object o)
• public interface IMessageFrame
  • object Message { get; set; }
• public interface IResponseContext
  • IResponseContext On<T>(Action<T> handler)
  • IResponseContext Then<T>(Action<T> handler)
• public interface ISerializer
  • object Deserialize(string message, Type type)
  • string Serialize(object o)
• public interface ISubscriptionManager
  • void Subscribe(string address)
  • void SubscribeAll()
• public interface ITransport
  • void BusPublish(object message, string address, Action<Action> marshal = null)
  • void QueuePublish(object message, string address, Action<Action> marshal = null)
• public interface ITransportBridge
  • void GeneralTransportException(Exception exception)
  • void ProcessCatchAllEvents(Synchronous eventFrame, string address)
  • void ProcessEvents(Event eventFrame, string address)
  • void ProcessSynchronousMessages(Synchronous synchronousFrame, string address)
  • void RawData(string data)
  • void RawMessage(object o)
  • void UnableToCreateMessage(Exception exception)

Succubus.Core.MessageFrames

• public class Diagnostic : MessageBase, IMessageFrame
  • public Diagnostic()
• public class Event : MessageBase, IMessageFrame
  • public Event()
• public abstract class MessageBase
  • public string EmbeddedType { get; set; }
  • public object Message { get; set; }
  • public string Originator { get; set; }
  • protected MessageBase()
• public class Synchronous : MessageBase, IMessageFrame
  • public string CorrelationId { get; set; }
  • public object Request { get; set; }
  • public string RequestType { get; set; }
  • public string Responder { get; set; }
  • public Synchronous()
• public class WorkItem : MessageBase, IMessageFrame
  • public WorkItem()

Succubus.Serialization

• public static class JsonFrame