Compare commits

...

2 Commits

Author SHA1 Message Date
371c4fa5aa Updated command qeury and model id 2020-08-21 11:59:08 +07:00
559633e58a Fixed the bank account aggregate class 2020-08-21 11:37:27 +07:00
6 changed files with 15 additions and 13 deletions

View File

@ -16,14 +16,14 @@ import java.math.BigDecimal
import java.util.UUID
@Aggregate
class BankAccountAggregate(
class BankAccountAggregate() {
@AggregateIdentifier
private var id: UUID? = null,
private var balance: BigDecimal? = null,
private var id: UUID? = null
private var balance: BigDecimal? = null
private var owner: String? = null
) {
@CommandHandler
constructor(command: CreateAccountCommand) {
constructor(command: CreateAccountCommand) : this() {
AggregateLifecycle.apply(
AccountCreatedEvent(
command.accountId,

View File

@ -4,8 +4,6 @@ import java.io.Serializable
import java.math.BigDecimal
import java.util.UUID
import javax.persistence.Entity
import javax.persistence.GeneratedValue
import javax.persistence.GenerationType
import javax.persistence.Id
import javax.persistence.Table
@ -13,7 +11,6 @@ import javax.persistence.Table
@Table(name = "bank_accounts")
data class BankAccount(
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
var id: UUID? = null,
var owner: String? = null,

View File

@ -62,6 +62,6 @@ class BankAccountProjection @Autowired constructor(
@QueryHandler
fun handle(query: FindBankAccountQuery): BankAccount? {
log.debug("Handling FindBankAccountQuery query: {}", query)
return this.bankAccountRepository.findById(query.accountId).orElse(null)
return this.bankAccountRepository.findById(query.id).orElse(null)
}
}

View File

@ -3,5 +3,5 @@ package com.cubetiqs.demo.axon.query
import java.util.UUID
data class FindBankAccountQuery(
val accountId: UUID
val id: UUID
)

View File

@ -44,6 +44,4 @@ class AccountCommandServiceImpl @Autowired constructor(
)
)
}
}

View File

@ -2,6 +2,8 @@ server:
port: 8182
spring:
application:
name: axon-demo
datasource:
driverClassName: org.postgresql.Driver
url: jdbc:postgresql://${POSTGRES_HOST:192.168.0.202}:${POSTGRES_PORT:5432}/${POSTGRES_DB:axon_demo}
@ -34,3 +36,8 @@ spring:
axon:
serializer:
general: jackson
axonserver:
servers: 192.168.0.202
logging:
level.root: debug