Skip to content

Commit f344304

Browse files
✨ feat: CorrelationDataProvider with gameId, playerId and the Axon defaults (#24)
1 parent 3f1aadf commit f344304

2 files changed

Lines changed: 14 additions & 1 deletion

File tree

src/main/java/com/dddheroes/heroesofddd/GameConfiguration.java

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,9 @@
33
import com.dddheroes.heroesofddd.shared.application.GameMetaData;
44
import org.axonframework.eventhandling.EventMessage;
55
import org.axonframework.eventhandling.async.SequencingPolicy;
6+
import org.axonframework.messaging.correlation.CorrelationDataProvider;
7+
import org.axonframework.messaging.correlation.MessageOriginProvider;
8+
import org.axonframework.messaging.correlation.SimpleCorrelationDataProvider;
69
import org.springframework.context.annotation.Bean;
710
import org.springframework.context.annotation.Configuration;
811

@@ -13,4 +16,14 @@ public class GameConfiguration {
1316
public SequencingPolicy<EventMessage<?>> gameIdSequencingPolicy() {
1417
return e -> e.getMetaData().get(GameMetaData.GAME_ID_KEY);
1518
}
19+
20+
@Bean
21+
public CorrelationDataProvider gameDataProvider() {
22+
return new SimpleCorrelationDataProvider(GameMetaData.GAME_ID_KEY, GameMetaData.PLAYER_ID_KEY);
23+
}
24+
25+
@Bean
26+
public CorrelationDataProvider messageOriginProvider() {
27+
return new MessageOriginProvider();
28+
}
1629
}

src/main/java/com/dddheroes/heroesofddd/creaturerecruitment/read/getdwellingbyid/GetDwellingByIdRestApi.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ CompletableFuture<DwellingReadModel> getDwellings(
2424
@PathVariable String gameId,
2525
@PathVariable String dwellingId
2626
) {
27-
var query = GetDwellingById.query(dwellingId, gameId);
27+
var query = GetDwellingById.query(gameId, dwellingId);
2828

2929
return queryGateway.query(
3030
query,

0 commit comments

Comments
 (0)