Class DefaultMessagePublisher

Inheritance

object

DefaultMessagePublisher

Implements

IMessagePublisher

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Namespace: LemonEdge.Messaging.Core.Publishers

Assembly: LemonEdge.Messaging.Core.dll

Syntax

public class DefaultMessagePublisher : IMessagePublisher

Constructors

DefaultMessagePublisher()

Declaration

public DefaultMessagePublisher()

Methods

InitializeAsync(CancellationToken)

Performs all tasks required to initialize this message publisher

Declaration

public Task InitializeAsync(CancellationToken token = default)

Parameters

Type	Name	Description
CancellationToken	token

Returns

Type	Description
Task

PublishAsync<T>(string, T, CancellationToken)

Publishes a message of type {T}

Declaration

public Task PublishAsync<T>(string topicName, T message, CancellationToken token = default) where T : class

Parameters

Type	Name	Description
string	topicName	The topic to which the message will be published
T	message	The message to publish
CancellationToken	token

Returns

Type	Description
Task

Type Parameters

Name	Description
T

Implements

IMessagePublisher

Extension Methods

LinqExtensions.AsArray<T>(T)

LinqExtensions.ToArrayOfOne<T>(T)

LinqExtensions.ToListOfOne<T>(T)

MiscExtensions.SetIfNotEqual<T, TP>(T, Expression<Func<T, TP>>, TP)

WeakReferenceExtensions.WeakReference(object)

SQLExtensions.ToSQLValue(object, bool)

ReflectionExtensions.ClearEventInvocations(object, string)

StringExtensions.ToCSVFormatString(object, Type)