Skip to content

Commit 3b345af

Browse files
committed
update a bit #5
1 parent 11ff7d2 commit 3b345af

File tree

2 files changed

+4
-32
lines changed

2 files changed

+4
-32
lines changed

README.md

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,13 @@
22

33
The practical repository uses coolstore domain which is mainly borrowed from `https://github.com/zkavtaskin/Domain-Driven-Design-Example` to demonstrate how to apply Domain Driven Design seamlessly with Clean Architecture.
44

5+
[![Sparkline](https://stars.medv.io/thangchung/practical-clean-ddd.svg)](https://stars.medv.io/thangchung/practical-clean-ddd)
6+
57
## Give a star ⭐
68

7-
A bright future of the .NET Community! What you LIKE or SHARE on `practical-clean-ddd` repository will help to strengthen and spread-out the way YOU develop the cloud-native application with the .NET platform and toolings as well as microservices development on Dapr and Kubernetes with .NET toolkit.
9+
If you're using this repository for your samples, workshop, your project or whatever, please give a star ⭐. Thank you very much :+1:
810

9-
So if you use this repository for your samples, workshop, your project or whatever you did, please give a star ⭐ for it. Thank you very much :+1:
11+
> Plz, use this project with care because we're using this repository for brainstorming new ideas in .NET and containerization worlds!
1012
1113
# Give it a try!
1214

src/Customer/CustomerService.Application/V1/Endpoints/TransactionalOutbox/CustomerTransactionalOutboxProcessor.cs

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -23,36 +23,6 @@ public CustomerTransactionalOutboxProcessor(ITransactionalOutboxProcessor outbox
2323
{
2424
await _outboxProcessor.HandleAsync(typeof(CoolStore.IntegrationEvents.Anchor), cancellationToken);
2525

26-
/*_logger.LogInformation("{CustomerOutboxProcessor}: Cron @{DateTime}", nameof(CustomerTransactionalOutboxProcessor), DateTime.UtcNow);
27-
28-
var events = await _daprClient.GetStateEntryAsync<List<OutboxEntity>>("statestore", "outbox");
29-
30-
if (events?.Value != null && events?.Value.Count > 0)
31-
{
32-
var deletedEventIds = new List<Guid>();
33-
34-
foreach (var domainEvent in events.Value)
35-
{
36-
if (domainEvent.Id.Equals(Guid.Empty) || string.IsNullOrEmpty(domainEvent.Type) || string.IsNullOrEmpty(domainEvent.Data)) continue;
37-
38-
var @event = domainEvent.RecreateMessage(typeof(CoolStore.IntegrationEvents.Anchor).Assembly);
39-
40-
await _eventBus.PublishAsync(@event);
41-
42-
deletedEventIds.Add(domainEvent.Id);
43-
}
44-
45-
if (deletedEventIds.Count > 0)
46-
{
47-
foreach (var deletedEventId in deletedEventIds)
48-
{
49-
events.Value.RemoveAll(e => e.Id == deletedEventId);
50-
}
51-
52-
await events.SaveAsync();
53-
}
54-
}*/
55-
5626
return Ok();
5727
}
5828
}

0 commit comments

Comments
 (0)