import lombok.Getter;
import org.onap.policy.common.endpoints.listeners.RequestIdDispatcher;
+import org.onap.policy.models.pdp.concepts.PdpMessage;
import org.onap.policy.models.pdp.concepts.PdpStatus;
import org.onap.policy.pap.main.comm.Publisher;
import org.onap.policy.pap.main.comm.TimerManager;
*/
@Getter
public class RequestParams {
- private Publisher publisher;
+ private Publisher<PdpMessage> pdpPublisher;
private RequestIdDispatcher<PdpStatus> responseDispatcher;
private Object modifyLock;
private TimerManager timers;
private int maxRetryCount;
- public RequestParams setPublisher(Publisher publisher) {
- this.publisher = publisher;
+ public RequestParams setPdpPublisher(Publisher<PdpMessage> publisher) {
+ this.pdpPublisher = publisher;
return this;
}
* Validates the parameters.
*/
public void validate() {
- if (publisher == null) {
+ if (pdpPublisher == null) {
throw new IllegalArgumentException("missing publisher");
}