@@ -316,12 +316,12 @@ A `JpaSequencedDeadLetterQueue` configuration example:
316316``` java
317317public class DeadLetterQueueExampleConfig {
318318
319- public ConfigurerModule configureDeadLetterQueueFor (String processingGroup ) {
319+ public ConfigurerModule configureDeadLetterQueueFor (EventProcessingConfigurer configurer ) {
320320 return configurer - > configurer. eventProcessing(
321321 eventProcessingConfigurer - > eventProcessingConfigurer. registerDeadLetterQueue(
322- processingGroup ,
322+ " MyProcessingGroup " ,
323323 configuration - > JpaSequencedDeadLetterQueue . builder()
324- .processingGroup(processingGroup )
324+ .processingGroup(" MyProcessingGroup " )
325325 .maxSequences(256 )
326326 .maxSequenceSize(256 )
327327 .entityManagerProvider(configuration. getComponent(EntityManagerProvider . class))
@@ -340,12 +340,12 @@ public class DeadLetterQueueExampleConfig {
340340public class DeadLetterQueueExampleConfig {
341341
342342 @Autowired
343- public ConfigurerModule configureDeadLetterQueueFor (String processingGroup ) {
343+ public ConfigurerModule configureDeadLetterQueueFor (EventProcessingConfigurer configurer ) {
344344 return configurer - > configurer. eventProcessing(
345345 eventProcessingConfigurer - > eventProcessingConfigurer. registerDeadLetterQueue(
346- processingGroup ,
346+ " MyProcessingGroup " ,
347347 configuration - > JpaSequencedDeadLetterQueue . builder()
348- .processingGroup(processingGroup )
348+ .processingGroup(" MyProcessingGroup " )
349349 .maxSequences(256 )
350350 .maxSequenceSize(256 )
351351 .entityManagerProvider(configuration. getComponent(EntityManagerProvider . class))
@@ -516,8 +516,8 @@ See the following example for configuring our custom policy:
516516``` java
517517public class EnqueuePolicyConfigurer {
518518
519- public void configureEnqueuePolicy (EventProcessingConfigurer configurer , String processingGroup ) {
520- configurer. registerDeadLetterPolicy(processingGroup , config - > new MyEnqueuePolicy ());
519+ public void configureEnqueuePolicy (EventProcessingConfigurer configurer ) {
520+ configurer. registerDeadLetterPolicy(" MyProcessingGroup " , config - > new MyEnqueuePolicy ());
521521 }
522522}
523523```
@@ -528,9 +528,9 @@ public class EnqueuePolicyConfigurer {
528528public class EnqueuePolicyConfigurer {
529529
530530 @Bean
531- public ConfigurerModule configureEnqueuePolicy (String processingGroup ) {
531+ public ConfigurerModule configureEnqueuePolicy (EventProcessingConfigurer configurer ) {
532532 return configurer - > configurer. eventProcessing()
533- .registerDeadLetterPolicy(processingGroup , config - > new MyEnqueuePolicy ());
533+ .registerDeadLetterPolicy(" MyProcessingGroup " , config - > new MyEnqueuePolicy ());
534534 }
535535}
536536```
0 commit comments