Succubus.Core by Succubus.io

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

---

API Diff between 0.1.30 and 0.1.21

53 Additions 38 Removals

Succubus.Collections

• public class TimeoutHandler<TKey, TValue> where TValue : IExpiring<TKey>
  • public int NumberOfItemsForTimeout()

Succubus.Collections.Interfaces

• public interface IExpiring<T>
  • void OnTimeout()

Succubus.Core

• public class Bus : IBusConfigurator, IBus, ITransportBridge
  • public bool IncludeMessageOriginator { get; set; }
  • public LogLevel LogLevel { get; set; }
  • public TextWriter LogWriter { get; set; }
  • public string Name { get; set; }
  • public event EventHandler<ExceptionEventArgs> Exception
  • public event EventHandler<ExceptionEventArgs> TransportException
  • public IResponseContext Defer<TReq, TRes>()
  • 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 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 IResponseContext OnRaw(Action<object> handler, 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 Pickup<TReq, T>(string correlationId, Action<TReq, T> handler)
  • public IResponseContext Pickup<TReq, T1, T2>(string correlationId, Action<TReq, T1, T2> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3>(string correlationId, Action<TReq, T1, T2, T3> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3, T4>(string correlationId, Action<TReq, T1, T2, T3, T4> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3, T4, T5>(string correlationId, Action<TReq, T1, T2, T3, T4, T5> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3, T4, T5, T6>(string correlationId, Action<TReq, T1, T2, T3, T4, T5, T6> handler)
  • public IResponseContext Pickup<TReq, T1, T2, T3, T4, T5, T6, T7>(string correlationId, Action<TReq, T1, T2, T3, T4, T5, T6, T7> handler)
  • public void Queue<T>(T request, string address = null, Action<Action> marshal = null)
  • public void RawData(string data)
• 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

Succubus.Core.Interfaces

• public interface IBus
  • string Name { get; }
  • event EventHandler<ExceptionEventArgs> Exception
  • event EventHandler<ExceptionEventArgs> TransportException
  • IResponseContext Defer<TReq, T>()
  • IResponseContext Defer<TReq, T1, T2>()
  • IResponseContext Defer<TReq, T1, T2, T3>()
  • IResponseContext Defer<TReq, T1, T2, T3, T4>()
  • IResponseContext Defer<TReq, T1, T2, T3, T4, T5>()
  • IResponseContext Defer<TReq, T1, T2, T3, T4, T5, T6>()
  • IResponseContext Defer<TReq, T1, T2, T3, T4, T5, T6, T7>()
  • IResponseContext Dequeue<T>(Action<T> handler, string address = null, Action<Action> marshal = null)
  • Diagnose GetDiagnose()
  • IResponseContext OnRaw(Action<object> handler, Action<Action> marshal = null)
  • IResponseContext OnRawData(Action<string> handler, Action<Action> marshal = null)
  • IResponseContext OnRawMessage(Action<object> handler, Action<Action> marshal = null)
  • IResponseContext Pickup<TReq, T>(string correlationId, Action<TReq, T> handler)
  • IResponseContext Pickup<TReq, T1, T2>(string correlationId, Action<TReq, T1, T2> handler)
  • IResponseContext Pickup<TReq, T1, T2, T3>(string correlationId, Action<TReq, T1, T2, T3> handler)
  • IResponseContext Pickup<TReq, T1, T2, T3, T4>(string correlationId, Action<TReq, T1, T2, T3, T4> handler)
  • IResponseContext Pickup<TReq, T1, T2, T3, T4, T5>(string correlationId, Action<TReq, T1, T2, T3, T4, T5> handler)
  • IResponseContext Pickup<TReq, T1, T2, T3, T4, T5, T6>(string correlationId, Action<TReq, T1, T2, T3, T4, T5, T6> handler)
  • IResponseContext Pickup<TReq, T1, T2, T3, T4, T5, T6, T7>(string correlationId, Action<TReq, T1, T2, T3, T4, T5, T6, T7> handler)
  • void Queue<T>(T request, string address = null, Action<Action> marshal = null)
• public interface IBusConfigurator
  • bool IncludeMessageOriginator { get; set; }
  • LogLevel LogLevel { get; set; }
  • TextWriter LogWriter { get; set; }
  • string Name { get; set; }
• public interface ITransport
  • void ObjectPublish(object message, string address, Action<Action> marshal = null)
  • 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 RawData(string data)

Succubus.Core.MessageFrames

• public class Diagnostic : MessageBase, IMessageFrame
  • public string EmbeddedType { get; set; }
  • public object Message { get; set; }
• public class Event : MessageBase, IMessageFrame
  • public string EmbeddedType { get; set; }
  • public object Message { get; set; }
• 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 EmbeddedType { get; set; }
  • public object Message { get; set; }
  • public string ParentType { get; set; }
  • public string Responder { get; set; }
• public class WorkItem : MessageBase, IMessageFrame
  • public WorkItem()