This repository was archived by the owner on Nov 6, 2023. It is now read-only.
File tree 21 files changed +31
-33
lines changed
test/tv/codely/mooc/video/application/publish
21 files changed +31
-33
lines changed File renamed without changes.
File renamed without changes.
File renamed without changes.
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc .notification .module . push . application .create ;
1
+ package tv .codely .mooc .notification .application .create ;
2
2
3
- import tv .codely .mooc .video .module . video . domain .VideoPublished ;
4
- import tv .codely .mooc . shared .application .DomainEventSubscriber ;
3
+ import tv .codely .mooc .video .domain .VideoPublished ;
4
+ import tv .codely .shared .application .DomainEventSubscriber ;
5
5
6
6
public class SendPushToSubscribersOnVideoPublished implements DomainEventSubscriber <VideoPublished > {
7
7
@ Override
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc .video .module . video . application .publish ;
1
+ package tv .codely .mooc .video .application .publish ;
2
2
3
- import tv .codely .mooc .video .module . video . domain .Video ;
4
- import tv .codely .mooc .video .module . video . domain .VideoDescription ;
5
- import tv .codely .mooc .video .module . video . domain .VideoTitle ;
6
- import tv .codely .mooc . shared .domain .EventBus ;
3
+ import tv .codely .mooc .video .domain .Video ;
4
+ import tv .codely .mooc .video .domain .VideoDescription ;
5
+ import tv .codely .mooc .video .domain .VideoTitle ;
6
+ import tv .codely .shared .domain .EventBus ;
7
7
8
8
public final class VideoPublisher {
9
9
private final EventBus eventBus ;
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc .video .module . video . domain ;
1
+ package tv .codely .mooc .video .domain ;
2
2
3
- import tv .codely .mooc . shared .domain .AggregateRoot ;
3
+ import tv .codely .shared .domain .AggregateRoot ;
4
4
5
5
public final class Video extends AggregateRoot {
6
6
private final VideoTitle title ;
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc .video .module . video . domain ;
1
+ package tv .codely .mooc .video .domain ;
2
2
3
3
public final class VideoDescription {
4
4
private final String value ;
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc .video .module . video . domain ;
1
+ package tv .codely .mooc .video .domain ;
2
2
3
- import tv .codely .mooc . shared .domain .DomainEvent ;
3
+ import tv .codely .shared .domain .DomainEvent ;
4
4
5
5
public final class VideoPublished implements DomainEvent {
6
6
private static final String FULL_QUALIFIED_EVENT_NAME = "codelytv.video.video.event.1.video.published" ;
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc .video .module . video . domain ;
1
+ package tv .codely .mooc .video .domain ;
2
2
3
3
public final class VideoTitle {
4
4
private final String value ;
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc .video .module . video . infrastructure ;
1
+ package tv .codely .mooc .video .infrastructure ;
2
2
3
- import tv .codely .mooc .notification .module . push . application .create .SendPushToSubscribersOnVideoPublished ;
4
- import tv .codely .mooc .video .module . video . application .publish .VideoPublisher ;
5
- import tv .codely .mooc . shared .application .DomainEventSubscriber ;
6
- import tv .codely .mooc . shared .domain .EventBus ;
7
- import tv .codely .mooc . shared .infrastructure .bus .ReactorEventBus ;
3
+ import tv .codely .mooc .notification .application .create .SendPushToSubscribersOnVideoPublished ;
4
+ import tv .codely .mooc .video .application .publish .VideoPublisher ;
5
+ import tv .codely .shared .application .DomainEventSubscriber ;
6
+ import tv .codely .shared .domain .EventBus ;
7
+ import tv .codely .shared .infrastructure .bus .ReactorEventBus ;
8
8
9
9
import java .util .Set ;
10
10
Original file line number Diff line number Diff line change 1
1
package tv .codely .mooc .video .application .publish ;
2
2
3
3
import org .junit .jupiter .api .Test ;
4
- import tv .codely .mooc .video .module .video .application .publish .VideoPublisher ;
5
- import tv .codely .mooc .video .module .video .domain .VideoPublished ;
6
- import tv .codely .mooc .shared .domain .EventBus ;
4
+ import tv .codely .mooc .video .domain .VideoPublished ;
5
+ import tv .codely .shared .domain .EventBus ;
7
6
8
7
import java .util .List ;
9
8
Original file line number Diff line number Diff line change 1
1
dependencies {
2
- // compile project('src:shared')
3
2
}
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc . shared .application ;
1
+ package tv .codely .shared .application ;
2
2
3
- import tv .codely .mooc . shared .domain .DomainEvent ;
3
+ import tv .codely .shared .domain .DomainEvent ;
4
4
5
5
public interface DomainEventSubscriber <EventType extends DomainEvent > {
6
6
Class <EventType > subscribedTo ();
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc . shared .domain ;
1
+ package tv .codely .shared .domain ;
2
2
3
3
import java .util .LinkedList ;
4
4
import java .util .List ;
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc . shared .domain ;
1
+ package tv .codely .shared .domain ;
2
2
3
3
public interface DomainEvent {
4
4
String fullQualifiedEventName ();
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc . shared .domain ;
1
+ package tv .codely .shared .domain ;
2
2
3
3
import java .util .List ;
4
4
Original file line number Diff line number Diff line change 1
- package tv .codely .mooc . shared .infrastructure .bus ;
1
+ package tv .codely .shared .infrastructure .bus ;
2
2
3
3
import reactor .bus .Event ;
4
4
import reactor .bus .EventBus ;
5
5
import reactor .bus .selector .Selector ;
6
6
import reactor .fn .Consumer ;
7
- import tv .codely .mooc . shared .domain .DomainEvent ;
8
- import tv .codely .mooc . shared .application .DomainEventSubscriber ;
7
+ import tv .codely .shared .domain .DomainEvent ;
8
+ import tv .codely .shared .application .DomainEventSubscriber ;
9
9
10
10
import java .util .List ;
11
11
import java .util .Set ;
12
12
13
13
import static reactor .bus .selector .Selectors .$ ;
14
14
15
- public class ReactorEventBus implements tv .codely .mooc . shared .domain .EventBus {
15
+ public class ReactorEventBus implements tv .codely .shared .domain .EventBus {
16
16
private final EventBus bus ;
17
17
18
18
public ReactorEventBus (final Set <DomainEventSubscriber > subscribers ) {
You can’t perform that action at this time.
0 commit comments