Package com.broadleafcommerce.datafeed.messaging.payload

Class StartDataFeedProcessExecutionRequest

java.lang.Object

com.broadleafcommerce.datafeed.messaging.payload.StartDataFeedProcessExecutionRequest

All Implemented Interfaces:

Serializable

public class StartDataFeedProcessExecutionRequest
extends Object
implements Serializable

When a DataFeedProcessExecution is marked DefaultDataFeedExecutionStatuses.REQUESTED, this message should simultaneously be emitted for it.

This represents a request to actually start running the execution and processing data for it.

The expectation is for the data feed microservice itself to publish and consume these messages. By separating the 'request' and 'run' phases of an execution via this messaging process, we ensure the (lengthy) run step can happen in the background rather than tying up a request thread. Furthermore, it opens up the possibility of better load-balancing across instances of data feed services depending on message consumer configuration - the node emitting the StartDataFeedProcessExecutionRequest does not have to be the one to actually consume and process it.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
StartDataFeedProcessExecutionRequest()

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
boolean	equals(Object o)
String	getDataFeedProcessExecutionId()	The DataFeedProcessExecution.getId() which needs to be run.
String	getTenantId()	The ID of the tenant who owns the DataFeedProcessExecution.
int	hashCode()
void	setDataFeedProcessExecutionId(String dataFeedProcessExecutionId)	The DataFeedProcessExecution.getId() which needs to be run.
void	setTenantId(String tenantId)	The ID of the tenant who owns the DataFeedProcessExecution.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

StartDataFeedProcessExecutionRequest

public StartDataFeedProcessExecutionRequest()

Method Details

getDataFeedProcessExecutionId

public String getDataFeedProcessExecutionId()

The DataFeedProcessExecution.getId() which needs to be run.

getTenantId

public String getTenantId()

The ID of the tenant who owns the DataFeedProcessExecution.

setDataFeedProcessExecutionId

public void setDataFeedProcessExecutionId(String dataFeedProcessExecutionId)

The DataFeedProcessExecution.getId() which needs to be run.

setTenantId

public void setTenantId(String tenantId)

The ID of the tenant who owns the DataFeedProcessExecution.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

canEqual

protected boolean canEqual(Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object