Skip to content

Commit 2aab717

Browse files
committed
Rename CombiningCommandCallback to more appropriate name
1 parent d006f71 commit 2aab717

File tree

3 files changed

+10
-10
lines changed

3 files changed

+10
-10
lines changed

kotlin/src/main/kotlin/org/axonframework/extensions/kotlin/CommandGatewayExtensions.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ fun <C : Any, R : Any?> CommandGateway.send(
3333
command: C,
3434
onSuccess: (commandMessage: CommandMessage<out C>, result: R, metaData: MetaData) -> Unit = { _, _, _ -> },
3535
onError: (commandMessage: CommandMessage<out C>, exception: Throwable, metaData: MetaData) -> Unit = { _, _, _ -> }
36-
): Unit = this.send(command, CombiningCommandCallback<C, R>(onError, onSuccess))
36+
): Unit = this.send(command, ResultDiscriminatorCommandCallback<C, R>(onSuccess, onError))
3737

3838
/**
3939
* Reified version of [CommandGateway.sendAndWait]

kotlin/src/main/kotlin/org/axonframework/extensions/kotlin/CombiningCommandCallback.kt renamed to kotlin/src/main/kotlin/org/axonframework/extensions/kotlin/ResultDiscriminatorCommandCallback.kt

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,9 +29,9 @@ import org.axonframework.messaging.MetaData
2929
* @see CommandCallback
3030
* @author Stefan Andjelkovic
3131
*/
32-
internal class CombiningCommandCallback<C, R>(
33-
val onError: (commandMessage: CommandMessage<out C>, exception: Throwable, metaData: MetaData) -> Unit,
34-
val onSuccess: (commandMessage: CommandMessage<out C>, result: R, metaData: MetaData) -> Unit
32+
internal class ResultDiscriminatorCommandCallback<C, R>(
33+
val onSuccess: (commandMessage: CommandMessage<out C>, result: R, metaData: MetaData) -> Unit,
34+
val onError: (commandMessage: CommandMessage<out C>, exception: Throwable, metaData: MetaData) -> Unit
3535
) : CommandCallback<C, R> {
3636
override fun onResult(commandMessage: CommandMessage<out C>, commandResultMessage: CommandResultMessage<out R>) {
3737
val metaData = commandResultMessage.metaData ?: MetaData.emptyInstance()

kotlin/src/test/kotlin/org/axonframework/extensions/kotlin/CombiningCommandCallbackTest.kt renamed to kotlin/src/test/kotlin/org/axonframework/extensions/kotlin/ResultDiscriminatorCommandCallbackTest.kt

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -28,11 +28,11 @@ import kotlin.test.Test
2828
import kotlin.test.fail
2929

3030
/**
31-
* Tests [CombiningCommandCallback] to verify that it correctly invokes given callbacks.
31+
* Tests [ResultDiscriminatorCommandCallback] to verify that it correctly invokes given callbacks.
3232
*
3333
* @author Stefan Andjelkovic
3434
*/
35-
class CombiningCommandCallbackTest {
35+
class ResultDiscriminatorCommandCallbackTest {
3636
private val command = ExampleCommand("1")
3737
private val commandMessage: CommandMessage<ExampleCommand> = GenericCommandMessage.asCommandMessage(command)
3838
private val responsePayloadUUID = UUID.randomUUID().toString()
@@ -45,7 +45,7 @@ class CombiningCommandCallbackTest {
4545
val onSuccessMock = mockk<(commandMessage: CommandMessage<out ExampleCommand>, result: String, metaData: MetaData) -> Unit>()
4646
every { onSuccessMock.invoke(commandMessage, responsePayloadUUID, any()) } returns Unit
4747

48-
val subject = CombiningCommandCallback<ExampleCommand, String>(
48+
val subject = ResultDiscriminatorCommandCallback<ExampleCommand, String>(
4949
onError = { _, _, _ -> fail("onError should not be called") },
5050
onSuccess = onSuccessMock
5151
)
@@ -60,7 +60,7 @@ class CombiningCommandCallbackTest {
6060
val onSuccessMock = mockk<(commandMessage: CommandMessage<out ExampleCommand>, result: String, metaData: MetaData) -> Unit>()
6161
every { onSuccessMock.invoke(commandMessage, responsePayloadUUID, any()) } returns Unit
6262

63-
val subject = CombiningCommandCallback(
63+
val subject = ResultDiscriminatorCommandCallback(
6464
onError = { _, _, _ -> fail("onError should not be called") },
6565
onSuccess = onSuccessMock
6666
)
@@ -75,7 +75,7 @@ class CombiningCommandCallbackTest {
7575
val onError = mockk<(commandMessage: CommandMessage<out ExampleCommand>, exception: Throwable, metaData: MetaData) -> Unit>()
7676
every { onError.invoke(commandMessage, exceptionalCommandResultMessage.exceptionResult(), any()) } returns Unit
7777

78-
val subject = CombiningCommandCallback<ExampleCommand, String>(
78+
val subject = ResultDiscriminatorCommandCallback<ExampleCommand, String>(
7979
onError = onError,
8080
onSuccess = { _, _, _ -> fail("onSuccess should not be called") }
8181
)
@@ -91,7 +91,7 @@ class CombiningCommandCallbackTest {
9191
val onError = mockk<(commandMessage: CommandMessage<out ExampleCommand>, exception: Throwable, metaData: MetaData) -> Unit>()
9292
every { onError.invoke(commandMessage, exceptionalCommandResultMessage.exceptionResult(), any()) } returns Unit
9393

94-
val subject = CombiningCommandCallback<ExampleCommand, String>(
94+
val subject = ResultDiscriminatorCommandCallback<ExampleCommand, String>(
9595
onError = onError,
9696
onSuccess = { _, _, _ -> fail("onSuccess should not be called") }
9797
)

0 commit comments

Comments
 (0)