IFramework.MessageQueue.InMemoryMq by Ivan

<PackageReference Include="IFramework.MessageQueue.InMemoryMq" Version="1.0.0" />

 InMemoryClient

public InMemoryClient()

public void Dispose()

public Task PublishAsync(IMessageContext messageContext, string topic, CancellationToken cancellationToken)

public Task SendAsync(IMessageContext messageContext, string queueTopic, CancellationToken cancellationToken)

public ICommitOffsetable StartQueueClient(string commandQueueName, string consumerId, OnMessagesReceived onMessagesReceived, ConsumerConfig consumerConfig = null)

public ICommitOffsetable StartSubscriptionClient(string topic, string subscriptionName, string consumerId, OnMessagesReceived onMessagesReceived, ConsumerConfig consumerConfig = null)

public IMessageContext WrapMessage(object message, string correlationId = null, string topic = null, string key = null, string replyEndPoint = null, string messageId = null, SagaInfo sagaInfo = null, string producer = null)