Class AbstractMessageSendingTemplate<D>

Inheritance

System.Object

AbstractMessageSendingTemplate<D>

AbstractMessageReceivingTemplate<D>

Implements

IMessageSendingOperations<D>

Namespace: Steeltoe.Messaging.Core

Assembly: Steeltoe.Messaging.MessagingBase.dll

Syntax

public abstract class AbstractMessageSendingTemplate<D> : object, IMessageSendingOperations<D>

Type Parameters

Name	Description
D

Fields

| Edit this page View Source

CONVERSION_HINT_HEADER

Declaration

public const string CONVERSION_HINT_HEADER = null

Field Value

Type	Description
System.String

Properties

| Edit this page View Source

DefaultSendDestination

Declaration

public virtual D DefaultSendDestination { get; set; }

Property Value

Type	Description
D

| Edit this page View Source

MessageConverter

Declaration

public virtual IMessageConverter MessageConverter { get; set; }

Property Value

Type	Description
IMessageConverter

| Edit this page View Source

RequiredDefaultSendDestination

Declaration

protected virtual D RequiredDefaultSendDestination { get; }

Property Value

Type	Description
D

Methods

| Edit this page View Source

ConvertAndSend(D, Object)

Declaration

public virtual void ConvertAndSend(D destination, object payload)

Parameters

Type	Name	Description
D	destination
System.Object	payload

| Edit this page View Source

ConvertAndSend(D, Object, IDictionary<String, Object>)

Declaration

public virtual void ConvertAndSend(D destination, object payload, IDictionary<string, object> headers)

Parameters

Type	Name	Description
D	destination
System.Object	payload
IDictionary<System.String, System.Object>	headers

| Edit this page View Source

ConvertAndSend(D, Object, IDictionary<String, Object>, IMessagePostProcessor)

Declaration

public virtual void ConvertAndSend(D destination, object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor)

Parameters

Type	Name	Description
D	destination
System.Object	payload
IDictionary<System.String, System.Object>	headers
IMessagePostProcessor	postProcessor

| Edit this page View Source

ConvertAndSend(D, Object, IMessagePostProcessor)

Declaration

public virtual void ConvertAndSend(D destination, object payload, IMessagePostProcessor postProcessor)

Parameters

Type	Name	Description
D	destination
System.Object	payload
IMessagePostProcessor	postProcessor

| Edit this page View Source

ConvertAndSend(Object)

Declaration

public virtual void ConvertAndSend(object payload)

Parameters

Type	Name	Description
System.Object	payload

| Edit this page View Source

ConvertAndSend(Object, IMessagePostProcessor)

Declaration

public virtual void ConvertAndSend(object payload, IMessagePostProcessor postProcessor)

Parameters

Type	Name	Description
System.Object	payload
IMessagePostProcessor	postProcessor

| Edit this page View Source

ConvertAndSendAsync(D, Object, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(D destination, object payload, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
System.Object	payload
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(D, Object, IDictionary<String, Object>, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(D destination, object payload, IDictionary<string, object> headers, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
System.Object	payload
IDictionary<System.String, System.Object>	headers
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(D, Object, IDictionary<String, Object>, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(D destination, object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
System.Object	payload
IDictionary<System.String, System.Object>	headers
IMessagePostProcessor	postProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(D, Object, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(D destination, object payload, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
System.Object	payload
IMessagePostProcessor	postProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(Object, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(object payload, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	payload
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ConvertAndSendAsync(Object, IMessagePostProcessor, CancellationToken)

Declaration

public virtual Task ConvertAndSendAsync(object payload, IMessagePostProcessor postProcessor, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
System.Object	payload
IMessagePostProcessor	postProcessor
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

DoConvert(Object, IDictionary<String, Object>, IMessagePostProcessor)

Declaration

protected virtual IMessage DoConvert(object payload, IDictionary<string, object> headers, IMessagePostProcessor postProcessor)

Parameters

Type	Name	Description
System.Object	payload
IDictionary<System.String, System.Object>	headers
IMessagePostProcessor	postProcessor

Returns

Type	Description
IMessage

| Edit this page View Source

DoSend(D, IMessage)

Declaration

protected abstract void DoSend(D destination, IMessage message)

Parameters

Type	Name	Description
D	destination
IMessage	message

| Edit this page View Source

DoSendAsync(D, IMessage, CancellationToken)

Declaration

protected abstract Task DoSendAsync(D destination, IMessage message, CancellationToken cancellationToken)

Parameters

Type	Name	Description
D	destination
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

ProcessHeadersToSend(IDictionary<String, Object>)

Declaration

protected virtual IDictionary<string, object> ProcessHeadersToSend(IDictionary<string, object> headers)

Parameters

Type	Name	Description
IDictionary<System.String, System.Object>	headers

Returns

Type	Description
IDictionary<System.String, System.Object>

| Edit this page View Source

Send(D, IMessage)

Declaration

public virtual void Send(D destination, IMessage message)

Parameters

Type	Name	Description
D	destination
IMessage	message

| Edit this page View Source

Send(IMessage)

Declaration

public virtual void Send(IMessage message)

Parameters

Type	Name	Description
IMessage	message

| Edit this page View Source

SendAsync(D, IMessage, CancellationToken)

Declaration

public virtual Task SendAsync(D destination, IMessage message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
D	destination
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
Task

| Edit this page View Source

SendAsync(IMessage, CancellationToken)

Declaration

public virtual Task SendAsync(IMessage message, CancellationToken cancellationToken = null)

Parameters

Type	Name	Description
IMessage	message
CancellationToken	cancellationToken

Returns

Type	Description
Task

Implements

IMessageSendingOperations<D>