AmazonBus<TRequest> Class

Definition

Namespace

Savvyio.Extensions.SimpleQueueService

Assemblies

Savvyio.Extensions.SimpleQueueService.dll

Source

src/Savvyio.Extensions.SimpleQueueService/AmazonBus.cs

Represents the base class from which all implementations in need of bus capabilities should derive.

public abstract class AmazonBus<TRequest> : AmazonMessage<TRequest>, IConfigurable<AmazonMessageOptions>, IPublishSubscribeChannel<TRequest>, IPublisher<TRequest>, ISubscriber<TRequest> where TRequest : IRequest

Type Parameters

TRequest

The type of the model to handle.

Inheritance

object

AmazonMessage<TRequest>

AmazonBus<TRequest>

Implements

IConfigurable<AmazonMessageOptions>

IPublishSubscribeChannel<TRequest>

IPublisher<TRequest>

ISubscriber<TRequest>

Derived

AmazonEventBus

Inherited Members

AmazonMessage<TRequest>.MessageTypeAttributeKey

AmazonMessage<TRequest>.UseFirstInFirstOut

AmazonMessage<TRequest>.Marshaller

AmazonMessage<TRequest>.Options

AmazonMessage<TRequest>.RetrieveMessagesAsync(CancellationToken)

AmazonMessage<TRequest>.CreateSimpleQueueServiceClient()

Constructors

Name	Description
AmazonBus(IMarshaller, AmazonMessageOptions)	Initializes a new instance of the AmazonBus<TRequest> class.

Methods

Name	Description
PublishAsync(IMessage<TRequest>, Action<AsyncOptions>)	Publishes the specified message asynchronous using Publish-Subscribe Channel/Pub-Sub MEP.
SubscribeAsync(Func<IMessage<TRequest>, CancellationToken, Task>, Action<SubscribeAsyncOptions>)	Subscribe to one or more message(s) asynchronous using Publish-Subscribe Channel/Pub-Sub MEP.

See Also

AmazonMessage<TRequest>

IPublishSubscribeChannel<TRequest>