Class StreamListenerMessageHandler

Namespace

Steeltoe.Stream.Binding

Assembly

Steeltoe.Stream.StreamBase.dll

public class StreamListenerMessageHandler : AbstractReplyProducingMessageHandler, IMessageHandler, IServiceNameAware, IOrdered, IMessageProducer, IHeaderPropagation

Inheritance

object

AbstractMessageHandler

AbstractMessageProducingHandler

AbstractReplyProducingMessageHandler

StreamListenerMessageHandler

Implements

IMessageHandler

IServiceNameAware

IOrdered

IMessageProducer

IHeaderPropagation

Inherited Members

AbstractReplyProducingMessageHandler.RequiresReply

AbstractReplyProducingMessageHandler.HandleMessageInternal(IMessage)

AbstractMessageProducingHandler.OutputChannel

AbstractMessageProducingHandler.OutputChannelName

AbstractMessageProducingHandler.NotPropagatedHeaders

AbstractMessageProducingHandler.AddNotPropagatedHeaders(params string[])

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

StreamListenerMessageHandler(IApplicationContext, IInvocableHandlerMethod, bool, IList<string>)

public StreamListenerMessageHandler(IApplicationContext context, IInvocableHandlerMethod invocableHandlerMethod, bool copyHeaders, IList<string> notPropagatedHeaders)

Parameters

context IApplicationContext

invocableHandlerMethod IInvocableHandlerMethod

copyHeaders bool

notPropagatedHeaders IList<string>

Properties

IsVoid

public bool IsVoid { get; }

Property Value

bool

ShouldCopyRequestHeaders

protected override bool ShouldCopyRequestHeaders { get; }

Property Value

bool

Methods

HandleRequestMessage(IMessage)

protected override object HandleRequestMessage(IMessage requestMessage)

Parameters

requestMessage IMessage

Returns

object

Initialize()

public override void Initialize()