@@ -314,21 +314,20 @@ A `JpaSequencedDeadLetterQueue` configuration example:
314314{% tabs %}
315315{% tab title="Axon Configuration API" %}
316316``` java
317- public class DeadLetterQueueExampleConfig {
318-
319- public ConfigurerModule configureDeadLetterQueueFor (EventProcessingConfigurer configurer ) {
320- return configurer - > configurer. eventProcessing(
321- eventProcessingConfigurer - > eventProcessingConfigurer. registerDeadLetterQueue(
322- " MyProcessingGroup" ,
323- configuration - > JpaSequencedDeadLetterQueue . builder()
324- .processingGroup(" MyProcessingGroup" )
325- .maxSequences(256 )
326- .maxSequenceSize(256 )
327- .entityManagerProvider(configuration. getComponent(EntityManagerProvider . class))
328- .transactionManager(configuration. getComponent(TransactionManager . class))
329- .serializer(configuration. serializer())
330- .build()
331- )
317+ public class AxonConfig {
318+ // ...
319+ public void configureDeadLetterQueue (EventProcessingConfigurer processingConfigurer ) {
320+ // Replace "my-processing-group" for the processing group you want to configure the DLQ on.
321+ processingConfigurer. registerDeadLetterQueue(
322+ " my-processing-group" ,
323+ config - > JpaSequencedDeadLetterQueue . builder()
324+ .processingGroup(" my-processing-group" )
325+ .maxSequences(256 )
326+ .maxSequenceSize(256 )
327+ .entityManagerProvider(config. getComponent(EntityManagerProvider . class))
328+ .transactionManager(config. getComponent(TransactionManager . class))
329+ .serializer(config. serializer())
330+ .build()
332331 );
333332 }
334333}
@@ -337,22 +336,21 @@ public class DeadLetterQueueExampleConfig {
337336{% tab title="Spring Boot AutoConfiguration" %}
338337``` java
339338@Configuration
340- public class DeadLetterQueueExampleConfig {
341-
342- @Autowired
343- public ConfigurerModule configureDeadLetterQueueFor (EventProcessingConfigurer configurer ) {
344- return configurer - > configurer. eventProcessing(
345- eventProcessingConfigurer - > eventProcessingConfigurer. registerDeadLetterQueue(
346- " MyProcessingGroup" ,
347- configuration - > JpaSequencedDeadLetterQueue . builder()
348- .processingGroup(" MyProcessingGroup" )
349- .maxSequences(256 )
350- .maxSequenceSize(256 )
351- .entityManagerProvider(configuration. getComponent(EntityManagerProvider . class))
352- .transactionManager(configuration. getComponent(TransactionManager . class))
353- .serializer(configuration. serializer())
354- .build()
355- )
339+ public class AxonConfig {
340+ // ...
341+ @Bean
342+ public ConfigurerModule deadLetterQueueConfigurerModule () {
343+ // Replace "my-processing-group" for the processing group you want to configure the DLQ on.
344+ return configurer - > configurer. eventProcessing(). registerDeadLetterQueue(
345+ " my-processing-group" ,
346+ config - > JpaSequencedDeadLetterQueue . builder()
347+ .processingGroup(" my-processing-group" )
348+ .maxSequences(256 )
349+ .maxSequenceSize(256 )
350+ .entityManagerProvider(config. getComponent(EntityManagerProvider . class))
351+ .transactionManager(config. getComponent(TransactionManager . class))
352+ .serializer(config. serializer())
353+ .build()
356354 );
357355 }
358356}
@@ -514,23 +512,25 @@ See the following example for configuring our custom policy:
514512{% tabs %}
515513{% tab title="Axon Configuration API" %}
516514``` java
517- public class EnqueuePolicyConfigurer {
518-
515+ public class AxonConfig {
516+ // ...
519517 public void configureEnqueuePolicy (EventProcessingConfigurer configurer ) {
520- configurer. registerDeadLetterPolicy(" MyProcessingGroup" , config - > new MyEnqueuePolicy ());
518+ // Replace "my-processing-group" for the processing group you want to configure the policy on.
519+ configurer. registerDeadLetterPolicy(" my-processing-group" , config - > new MyEnqueuePolicy ());
521520 }
522521}
523522```
524523{% endtab %}
525524{% tab title="Spring Boot AutoConfiguration" %}
526525``` java
527526@Configuration
528- public class EnqueuePolicyConfigurer {
527+ public class AxonConfig {
529528
530529 @Bean
531- public ConfigurerModule configureEnqueuePolicy (EventProcessingConfigurer configurer ) {
530+ public ConfigurerModule enqueuePolicyConfigurerModule () {
531+ // Replace "my-processing-group" for the processing group you want to configure the policy on.
532532 return configurer - > configurer. eventProcessing()
533- .registerDeadLetterPolicy(" MyProcessingGroup " , config - > new MyEnqueuePolicy ());
533+ .registerDeadLetterPolicy(" my-processing-group " , config - > new MyEnqueuePolicy ());
534534 }
535535}
536536```
0 commit comments