Class StartDataFeedPublicationRequest
- All Implemented Interfaces:
Serializable
DataFeedPublication is marked
DefaultDataFeedPublicationStatuses.REQUESTED, this message should simultaneously be
emitted for it.
This represents a request to actually start running the publication 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 a publication via this messaging process, we
ensure the (lengthy) run step can happen in the background rather than tying up a request thread.
It allows parallel/distributed processing of DataFeedPublications for a given
DataFeedProcessExecution. 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 StartDataFeedPublicationRequest does not have to be the one to
actually consume and process it.
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected booleanbooleanTheDataFeedPublication.getId()which needs to be run.The ID of the tenant who owns theDataFeedPublication.inthashCode()voidsetDataFeedPublicationId(String dataFeedPublicationId) TheDataFeedPublication.getId()which needs to be run.voidsetTenantId(String tenantId) The ID of the tenant who owns theDataFeedPublication.toString()
-
Constructor Details
-
StartDataFeedPublicationRequest
public StartDataFeedPublicationRequest()
-
-
Method Details
-
getDataFeedPublicationId
TheDataFeedPublication.getId()which needs to be run. -
getTenantId
The ID of the tenant who owns theDataFeedPublication. -
setDataFeedPublicationId
TheDataFeedPublication.getId()which needs to be run. -
setTenantId
The ID of the tenant who owns theDataFeedPublication. -
equals
-
canEqual
-
hashCode
public int hashCode() -
toString
-