Class QueueForwarder<TSource, TDest>

Inheritance

object

QueueForwarder<TSource, TDest>

Implements

IEquatable<QueueForwarder<TSource, TDest>>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: CrashCABN.DataAccess.Queues

Assembly: CrashCABN.DataAccess.Queues.dll

Syntax

public sealed record QueueForwarder<TSource, TDest> : IEquatable<QueueForwarder<TSource, TDest>>

Type Parameters

Name	Description
TSource
TDest

Constructors

View Source

QueueForwarder(IQueueStorageProvider, ILogger<QueueForwarder<TSource, TDest>>)

Declaration

public QueueForwarder(IQueueStorageProvider Queue, ILogger<QueueForwarder<TSource, TDest>> Logger)

Parameters

Type	Name	Description
IQueueStorageProvider	Queue
ILogger<QueueForwarder<TSource, TDest>>	Logger

Properties

View Source

Logger

Declaration

public ILogger<QueueForwarder<TSource, TDest>> Logger { get; init; }

Property Value

Type	Description
ILogger<QueueForwarder<TSource, TDest>>

View Source

Queue

Declaration

public IQueueStorageProvider Queue { get; init; }

Property Value

Type	Description
IQueueStorageProvider

Methods

View Source

ForwardAsync(string, string, int, Func<TSource, TDest?>, Action<TDest>?)

Declaration

public Task ForwardAsync(string sourceQueue, string destinationQueue, int limit, Func<TSource, TDest?> createForwardMessage, Action<TDest>? onMessageForwarded = null)

Parameters

Type	Name	Description
string	sourceQueue
string	destinationQueue
int	limit
Func<TSource, TDest>	createForwardMessage
Action<TDest>	onMessageForwarded

Returns

Type	Description
Task

Implements

IEquatable<T>