Class MessageTransformingHandler

Namespace

Steeltoe.Integration.Transformer

Assembly

Steeltoe.Integration.IntegrationBase.dll

public class MessageTransformingHandler : AbstractReplyProducingMessageHandler, IMessageHandler, IServiceNameAware, IOrdered, IMessageProducer, IHeaderPropagation, ILifecycle

Inheritance

object

AbstractMessageHandler

AbstractMessageProducingHandler

AbstractReplyProducingMessageHandler

MessageTransformingHandler

Implements

IMessageHandler

IServiceNameAware

IOrdered

IMessageProducer

IHeaderPropagation

ILifecycle

Inherited Members

AbstractReplyProducingMessageHandler.RequiresReply

AbstractReplyProducingMessageHandler.HandleMessageInternal(IMessage)

AbstractMessageProducingHandler.OutputChannel

AbstractMessageProducingHandler.OutputChannelName

AbstractMessageProducingHandler.NotPropagatedHeaders

AbstractMessageProducingHandler.SendTimeout

AbstractMessageProducingHandler.UpdateNotPropagatedHeaders(IList<string>, bool)

AbstractMessageProducingHandler.SendOutputs(object, IMessage)

AbstractMessageProducingHandler.ProduceOutput(object, IMessage)

AbstractMessageProducingHandler.SendOutput(object, object, bool)

AbstractMessageProducingHandler.ShouldSplitOutput(IEnumerable)

AbstractMessageProducingHandler.CreateOutputMessage(object, IMessageHeaders)

AbstractMessageHandler.IntegrationServices

AbstractMessageHandler.ApplicationContext

AbstractMessageHandler.ComponentType

AbstractMessageHandler.ServiceName

AbstractMessageHandler.ComponentName

AbstractMessageHandler.Order

AbstractMessageHandler.HandleMessage(IMessage)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

MessageTransformingHandler(IApplicationContext, ITransformer)

public MessageTransformingHandler(IApplicationContext context, ITransformer transformer)

Parameters

context IApplicationContext

transformer ITransformer

Properties

IsRunning

Gets a value indicating whether gets a value indicating if its running

public bool IsRunning { get; }

Property Value

bool

ShouldCopyRequestHeaders

protected override bool ShouldCopyRequestHeaders { get; }

Property Value

bool

Transformer

public ITransformer Transformer { get; }

Property Value

ITransformer

Methods

AddNotPropagatedHeaders(params string[])

Add headers that will not be copied from the inbound message if handler is configured to copy headers

public override void AddNotPropagatedHeaders(params string[] headers)

Parameters

headers string[]

the headers to not copy

HandleRequestMessage(IMessage)

protected override object HandleRequestMessage(IMessage requestMessage)

Parameters

requestMessage IMessage

Returns

object

Initialize()

public override void Initialize()

Start()

Start this component

public Task Start()

Returns

Task

a task to signal completion

Stop()

Stop this component

public Task Stop()

Returns

Task

a task to signal completion