Class KinesisEventHandler

The event handler for processing domain events and publishing them to an AWS Kinesis stream.

Inheritance

object

AwsBaseService

DataProducer<DomainEvent>

KinesisEventHandler

Implements

IDisposable

IEventHandler

Inherited Members

DataProducer<DomainEvent>.Publish(DomainEvent, CancellationToken)

DataProducer<DomainEvent>.Publish(IEnumerable<DomainEvent>, CancellationToken)

DataProducer<DomainEvent>.DisposeServices()

AwsBaseService.Configuration

AwsBaseService.ExponentialBackoffInSeconds

AwsBaseService.Logger

AwsBaseService.Dispose()

AwsBaseService.GetServiceRegionEndPoint()

AwsBaseService.CreateService<T>()

AwsBaseService.CreateDefaultRetryAsyncPolicy()

AwsBaseService.CreateDefaultRetryPolicy()

AwsBaseService.CreateRetryAsyncPolicy<T>()

AwsBaseService.CreateRetryAsyncPolicy<T, T1>()

AwsBaseService.CreateRetryAsyncPolicy<T, T1, T2>()

AwsBaseService.CreateRetryAsyncPolicy<T, T1, T2, T3>()

AwsBaseService.CreateRetryAsyncPolicy<T, T1, T2, T3, T4>()

AwsBaseService.CreateCircuitBreaker<T, T1>()

AwsBaseService.Dispose(bool)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Innovt.Cloud.AWS.Kinesis

Assembly: Innovt.Cloud.AWS.Kinesis.dll

Syntax

public class KinesisEventHandler : DataProducer<DomainEvent>, IDisposable, IEventHandler

Constructors

KinesisEventHandler(string, ILogger, IAwsConfiguration)

Initializes a new instance of the KinesisEventHandler class with the specified parameters.

Declaration

public KinesisEventHandler(string busName, ILogger logger, IAwsConfiguration configuration)

Parameters

Type	Name	Description
string	busName	The name of the AWS Kinesis stream to publish events to.
ILogger	logger	The logger instance for logging events.
IAwsConfiguration	configuration	The AWS configuration for accessing AWS services.

KinesisEventHandler(string, ILogger, IAwsConfiguration, string)

Initializes a new instance of the KinesisEventHandler class with the specified parameters.

Declaration

public KinesisEventHandler(string busName, ILogger logger, IAwsConfiguration configuration, string region)

Parameters

Type	Name	Description
string	busName	The name of the AWS Kinesis stream to publish events to.
ILogger	logger	The logger instance for logging events.
IAwsConfiguration	configuration	The AWS configuration for accessing AWS services.
string	region	The AWS region to use.

Implements

IDisposable

IEventHandler

Extension Methods

Extensions.IsNull(object)

Extensions.ToStringOrDefault(object)

SimpleMapper.MapTo<T1>(object)