Compare commits
2 Commits
652355f486
...
371c4fa5aa
Author | SHA1 | Date | |
---|---|---|---|
371c4fa5aa | |||
559633e58a |
@ -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,
|
||||
|
@ -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,
|
||||
|
@ -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)
|
||||
}
|
||||
}
|
@ -3,5 +3,5 @@ package com.cubetiqs.demo.axon.query
|
||||
import java.util.UUID
|
||||
|
||||
data class FindBankAccountQuery(
|
||||
val accountId: UUID
|
||||
val id: UUID
|
||||
)
|
@ -44,6 +44,4 @@ class AccountCommandServiceImpl @Autowired constructor(
|
||||
)
|
||||
)
|
||||
}
|
||||
|
||||
|
||||
}
|
@ -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
|
Loading…
Reference in New Issue
Block a user