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 DataFeedPublication
s 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
-
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
boolean
TheDataFeedPublication.getId()
which needs to be run.The ID of the tenant who owns theDataFeedPublication
.int
hashCode()
void
setDataFeedPublicationId
(String dataFeedPublicationId) TheDataFeedPublication.getId()
which needs to be run.void
setTenantId
(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
-