Skip to content
Snippets Groups Projects
Commit 4edb8946 authored by Felix Reichenbach's avatar Felix Reichenbach
Browse files

OZG-7573 publish vorgang forwared event

parent 1beba748
No related branches found
No related tags found
No related merge requests found
package de.ozgcloud.command;
public class VorgangForwardedEvent extends CommandExecutedEvent {
public VorgangForwardedEvent(Command command) {
super(command);
}
}
...@@ -33,6 +33,7 @@ import org.springframework.stereotype.Component; ...@@ -33,6 +33,7 @@ import org.springframework.stereotype.Component;
import de.ozgcloud.command.Command; import de.ozgcloud.command.Command;
import de.ozgcloud.command.CommandCreatedEvent; import de.ozgcloud.command.CommandCreatedEvent;
import de.ozgcloud.command.CommandFailedEvent; import de.ozgcloud.command.CommandFailedEvent;
import de.ozgcloud.command.VorgangForwardedEvent;
import de.ozgcloud.command.VorgangLockedEvent; import de.ozgcloud.command.VorgangLockedEvent;
import de.ozgcloud.nachrichten.email.MailSendErrorEvent; import de.ozgcloud.nachrichten.email.MailSendErrorEvent;
import de.ozgcloud.nachrichten.email.MailSendRequest; import de.ozgcloud.nachrichten.email.MailSendRequest;
...@@ -104,6 +105,7 @@ public class ForwardingEventListener { ...@@ -104,6 +105,7 @@ public class ForwardingEventListener {
lockVorgangOnForwarding(command); lockVorgangOnForwarding(command);
service.forward(incrementVersion(forwardingRequestMapper.fromCommand(command))); service.forward(incrementVersion(forwardingRequestMapper.fromCommand(command)));
publisher.publishEvent(new VorgangLockedEvent(command)); publisher.publishEvent(new VorgangLockedEvent(command));
publisher.publishEvent(new VorgangForwardedEvent(command));
} }
private void lockVorgangOnForwarding(Command command) { private void lockVorgangOnForwarding(Command command) {
......
...@@ -45,6 +45,7 @@ import com.thedeanda.lorem.LoremIpsum; ...@@ -45,6 +45,7 @@ import com.thedeanda.lorem.LoremIpsum;
import de.ozgcloud.command.Command; import de.ozgcloud.command.Command;
import de.ozgcloud.command.CommandCreatedEvent; import de.ozgcloud.command.CommandCreatedEvent;
import de.ozgcloud.command.CommandFailedEvent; import de.ozgcloud.command.CommandFailedEvent;
import de.ozgcloud.command.VorgangForwardedEvent;
import de.ozgcloud.command.VorgangLockedEvent; import de.ozgcloud.command.VorgangLockedEvent;
import de.ozgcloud.common.errorhandling.TechnicalException; import de.ozgcloud.common.errorhandling.TechnicalException;
import de.ozgcloud.nachrichten.email.MailSentEventTestFactory; import de.ozgcloud.nachrichten.email.MailSentEventTestFactory;
...@@ -150,6 +151,8 @@ class ForwardingEventListenerTest { ...@@ -150,6 +151,8 @@ class ForwardingEventListenerTest {
@Captor @Captor
private ArgumentCaptor<VorgangLockedEvent> lockedEventCaptor; private ArgumentCaptor<VorgangLockedEvent> lockedEventCaptor;
@Captor @Captor
private ArgumentCaptor<VorgangForwardedEvent> forwardedEventCaptor;
@Captor
private ArgumentCaptor<ForwardingRequest> requestCaptor; private ArgumentCaptor<ForwardingRequest> requestCaptor;
@BeforeEach @BeforeEach
...@@ -206,6 +209,14 @@ class ForwardingEventListenerTest { ...@@ -206,6 +209,14 @@ class ForwardingEventListenerTest {
assertThat(lockedEventCaptor.getValue().getCommand()).isSameAs(command); assertThat(lockedEventCaptor.getValue().getCommand()).isSameAs(command);
} }
@Test
void shouldPublishVorgangForwardedEvent() {
handleForwardVorgangCommand();
verify(publisher).publishEvent(forwardedEventCaptor.capture());
assertThat(forwardedEventCaptor.getValue().getCommand()).isSameAs(command);
}
private void handleForwardVorgangCommand() { private void handleForwardVorgangCommand() {
listener.handleForwardVorgangCommand(command); listener.handleForwardVorgangCommand(command);
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment