Package com.broadleafcommerce.workflow.messaging.autoconfigure

Class WorkflowMessagingAutoConfiguration

java.lang.Object

com.broadleafcommerce.workflow.messaging.autoconfigure.WorkflowMessagingAutoConfiguration

@Configuration
@ConditionalOnPropertyOrGroup(name="broadleaf.workflow.messaging.active",
                              group="broadleaf.basic.messaging.enabled",
                              matchIfMissing=true)
@DurableProducer(output=WorkflowProducer.class,
                 name="WORKFLOW",
                 configurationPrefix="broadleaf.workflow.execution",
                 componentPrefix="workflowExecution")
@EnableBinding({WorkflowConsumer.class,WorkflowProducer.class})
public class WorkflowMessagingAutoConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
WorkflowMessagingAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
Ack	kafkaAck()
WorkflowListener	workflowListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentMessageConsumptionService, WorkflowRepository<com.broadleafcommerce.data.tracking.core.Trackable> repository, WorkflowLauncher workflowLauncher, List<Ack> acks, ExecutionProperties executionProperties, org.springframework.core.env.ConfigurableEnvironment environment)
com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository	workflowPersistenceEventIgnore()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WorkflowMessagingAutoConfiguration

public WorkflowMessagingAutoConfiguration()

Method Details

workflowPersistenceEventIgnore

@Bean
public com.broadleafcommerce.common.messaging.notification.IgnoredNotificationStateRepository workflowPersistenceEventIgnore()

workflowListener

@Bean
@ConditionalOnMissingBean(name="workflowListener")
public WorkflowListener workflowListener(com.broadleafcommerce.common.messaging.service.IdempotentMessageConsumptionService idempotentMessageConsumptionService,
 WorkflowRepository<com.broadleafcommerce.data.tracking.core.Trackable> repository,
 WorkflowLauncher workflowLauncher,
 List<Ack> acks,
 ExecutionProperties executionProperties,
 org.springframework.core.env.ConfigurableEnvironment environment)

kafkaAck

@Bean
@ConditionalOnMissingBean(name="kafkaAck")
public Ack kafkaAck()