Class PublishPipeSpecification

Namespace

MassTransit.Configuration

Assembly

MassTransit.Abstractions.dll

public class PublishPipeSpecification : IPublishPipeConfigurator, IPipeConfigurator<PublishContext>, IPublishPipeSpecification, IPublishPipeSpecificationObserverConnector, ISpecification

Inheritance

object

PublishPipeSpecification

Implements

IPublishPipeConfigurator

IPipeConfigurator<PublishContext>

IPublishPipeSpecification

IPublishPipeSpecificationObserverConnector

ISpecification

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Extension Methods

DelegateConfigurationExtensions.UseExecuteAsync<TContext>(IPipeConfigurator<TContext>, Func<TContext, Task>)

DelegateConfigurationExtensions.UseExecute<TContext>(IPipeConfigurator<TContext>, Action<TContext>)

FilterConfigurationExtensions.UseFilter<T>(IPipeConfigurator<T>, IFilter<T>)

FilterConfigurationExtensions.UseFilter<TContext, TFilter>(IPipeConfigurator<TContext>, IFilter<TFilter>, MergeFilterContextProvider<TContext, TFilter>, FilterContextProvider<TFilter, TContext>)

FilterConfigurationExtensions.UseFilters<T>(IPipeConfigurator<T>, params IFilter<T>[])

FilterConfigurationExtensions.UseFilters<T>(IPipeConfigurator<T>, IEnumerable<IFilter<T>>)

FilterConfigurationExtensions.UseFilter<T>(IPublishPipeConfigurator, IFilter<PublishContext<T>>)

ValidationResultExtensions.Failure(ISpecification, string)

ValidationResultExtensions.Failure(ISpecification, string, string)

ValidationResultExtensions.Failure(ISpecification, string, string, string)

ValidationResultExtensions.Success(ISpecification, string)

ValidationResultExtensions.Success(ISpecification, string, string)

ValidationResultExtensions.Success(ISpecification, string, string, string)

ValidationResultExtensions.Warning(ISpecification, string)

ValidationResultExtensions.Warning(ISpecification, string, string)

ValidationResultExtensions.Warning(ISpecification, string, string, string)

Constructors

PublishPipeSpecification()

public PublishPipeSpecification()

Methods

AddPipeSpecification(IPipeSpecification<PublishContext>)

Adds a pipe specification to the pipe configurator at the end of the chain

public void AddPipeSpecification(IPipeSpecification<PublishContext> specification)

Parameters

specification IPipeSpecification<PublishContext>

The pipe specification to add

AddPipeSpecification<T>(IPipeSpecification<PublishContext<T>>)

Adds a type-specific pipe specification to the consume pipe

public void AddPipeSpecification<T>(IPipeSpecification<PublishContext<T>> specification) where T : class

Parameters

specification IPipeSpecification<PublishContext<T>>

Type Parameters

T

The message type

ConnectPublishPipeSpecificationObserver(IPublishPipeSpecificationObserver)

public ConnectHandle ConnectPublishPipeSpecificationObserver(IPublishPipeSpecificationObserver observer)

Parameters

observer IPublishPipeSpecificationObserver

Returns

ConnectHandle

GetMessageSpecification<T>()

Returns the specification for the message type

public IMessagePublishPipeSpecification<T> GetMessageSpecification<T>() where T : class

Returns

IMessagePublishPipeSpecification<T>

Type Parameters

T

The message type

Validate()

Validate the specification, ensuring that a successful build will occur.

public IEnumerable<ValidationResult> Validate()

Returns

IEnumerable<ValidationResult>