Compare commits
No commits in common. "371c4fa5aa7de64681ffd871c9d3ceef31ac3e46" and "652355f48684b79038508e6ff0a33dccffcab992" have entirely different histories.
371c4fa5aa
...
652355f486
@ -16,14 +16,14 @@ import java.math.BigDecimal
|
|||||||
import java.util.UUID
|
import java.util.UUID
|
||||||
|
|
||||||
@Aggregate
|
@Aggregate
|
||||||
class BankAccountAggregate() {
|
class BankAccountAggregate(
|
||||||
@AggregateIdentifier
|
@AggregateIdentifier
|
||||||
private var id: UUID? = null
|
private var id: UUID? = null,
|
||||||
private var balance: BigDecimal? = null
|
private var balance: BigDecimal? = null,
|
||||||
private var owner: String? = null
|
private var owner: String? = null
|
||||||
|
) {
|
||||||
@CommandHandler
|
@CommandHandler
|
||||||
constructor(command: CreateAccountCommand) : this() {
|
constructor(command: CreateAccountCommand) {
|
||||||
AggregateLifecycle.apply(
|
AggregateLifecycle.apply(
|
||||||
AccountCreatedEvent(
|
AccountCreatedEvent(
|
||||||
command.accountId,
|
command.accountId,
|
||||||
|
@ -4,6 +4,8 @@ import java.io.Serializable
|
|||||||
import java.math.BigDecimal
|
import java.math.BigDecimal
|
||||||
import java.util.UUID
|
import java.util.UUID
|
||||||
import javax.persistence.Entity
|
import javax.persistence.Entity
|
||||||
|
import javax.persistence.GeneratedValue
|
||||||
|
import javax.persistence.GenerationType
|
||||||
import javax.persistence.Id
|
import javax.persistence.Id
|
||||||
import javax.persistence.Table
|
import javax.persistence.Table
|
||||||
|
|
||||||
@ -11,6 +13,7 @@ import javax.persistence.Table
|
|||||||
@Table(name = "bank_accounts")
|
@Table(name = "bank_accounts")
|
||||||
data class BankAccount(
|
data class BankAccount(
|
||||||
@Id
|
@Id
|
||||||
|
@GeneratedValue(strategy = GenerationType.AUTO)
|
||||||
var id: UUID? = null,
|
var id: UUID? = null,
|
||||||
|
|
||||||
var owner: String? = null,
|
var owner: String? = null,
|
||||||
|
@ -62,6 +62,6 @@ class BankAccountProjection @Autowired constructor(
|
|||||||
@QueryHandler
|
@QueryHandler
|
||||||
fun handle(query: FindBankAccountQuery): BankAccount? {
|
fun handle(query: FindBankAccountQuery): BankAccount? {
|
||||||
log.debug("Handling FindBankAccountQuery query: {}", query)
|
log.debug("Handling FindBankAccountQuery query: {}", query)
|
||||||
return this.bankAccountRepository.findById(query.id).orElse(null)
|
return this.bankAccountRepository.findById(query.accountId).orElse(null)
|
||||||
}
|
}
|
||||||
}
|
}
|
@ -3,5 +3,5 @@ package com.cubetiqs.demo.axon.query
|
|||||||
import java.util.UUID
|
import java.util.UUID
|
||||||
|
|
||||||
data class FindBankAccountQuery(
|
data class FindBankAccountQuery(
|
||||||
val id: UUID
|
val accountId: UUID
|
||||||
)
|
)
|
@ -44,4 +44,6 @@ class AccountCommandServiceImpl @Autowired constructor(
|
|||||||
)
|
)
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
@ -2,8 +2,6 @@ server:
|
|||||||
port: 8182
|
port: 8182
|
||||||
|
|
||||||
spring:
|
spring:
|
||||||
application:
|
|
||||||
name: axon-demo
|
|
||||||
datasource:
|
datasource:
|
||||||
driverClassName: org.postgresql.Driver
|
driverClassName: org.postgresql.Driver
|
||||||
url: jdbc:postgresql://${POSTGRES_HOST:192.168.0.202}:${POSTGRES_PORT:5432}/${POSTGRES_DB:axon_demo}
|
url: jdbc:postgresql://${POSTGRES_HOST:192.168.0.202}:${POSTGRES_PORT:5432}/${POSTGRES_DB:axon_demo}
|
||||||
@ -36,8 +34,3 @@ spring:
|
|||||||
axon:
|
axon:
|
||||||
serializer:
|
serializer:
|
||||||
general: jackson
|
general: jackson
|
||||||
axonserver:
|
|
||||||
servers: 192.168.0.202
|
|
||||||
|
|
||||||
logging:
|
|
||||||
level.root: debug
|
|
Loading…
Reference in New Issue
Block a user