/*
 * Copyright (c) 2019, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
 *
 * WSO2 Inc. licenses this file to you under the Apache License,
 * Version 2.0 (the "License"); you may not use this file except
 * in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied. See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */

package io.siddhi.core.stream;

import java.util.HashMap;
import java.util.Map;

/**
 * Service related information to the deployment
 */
public class ServiceDeploymentInfo {

    private ServiceProtocol serviceProtocol = ServiceProtocol.TCP;
    private boolean isPulling = true;
    private boolean secured = false;
    private int port;
    private Map<String, String> deploymentProperties = new HashMap<>();

    /**
     * @param serviceProtocol the protocol used by the service
     * @param port            the port of the service
     * @param secured         is the service protocol secured
     * @param isPulling       is the source pulling
     */
    public ServiceDeploymentInfo(ServiceProtocol serviceProtocol, int port, boolean secured,
                                 boolean isPulling) {
        this.serviceProtocol = serviceProtocol;
        this.port = port;
        this.secured = secured;
        this.isPulling = isPulling;
    }

    /**
     * Service related information to the deployment
     *
     * @param port           the port of the service
     * @param secured        is the service protocol secured
     * @param isPulling      is the source pulling
     */
    public ServiceDeploymentInfo(int port, boolean secured, boolean isPulling) {
        this.port = port;
        this.secured = secured;
        this.isPulling = isPulling;
    }

    public ServiceDeploymentInfo() {
    }

    public ServiceProtocol getServiceProtocol() {
        return serviceProtocol;
    }

    public void setServiceProtocol(ServiceProtocol serviceProtocol) {
        this.serviceProtocol = serviceProtocol;
    }

    public boolean isSecured() {
        return secured;
    }

    public int getPort() {
        return port;
    }

    public void setPort(int port) {
        this.port = port;
    }

    public void setSecured(boolean secured) {
        this.secured = secured;
    }

    public boolean isPulling() {
        return isPulling;
    }

    public void setPulling(boolean pulling) {
        isPulling = pulling;
    }

    public Map<String, String> getDeploymentProperties() {
        return deploymentProperties;
    }

    public void addDeploymentProperties(Map<String, String> deploymentProperties) {
        for (Map.Entry<String, String> entry : deploymentProperties.entrySet()) {
            this.deploymentProperties.putIfAbsent(entry.getKey(), entry.getValue());
        }
    }

    /**
     * Service protocols
     */
    public enum ServiceProtocol {
        TCP, UDP, SCTP,
    }
}

@@ -1268,60 +1268,8 @@
 red%0A
-     * @param isPulling       is the source pulling%0A
     
@@ -1367,60 +1367,8 @@
 ured
-,%0A                                 boolean isPulling
 ) %7B%0A
@@ -1494,33 +1494,29 @@
 isPulling = 
-isPulling
+false
 ;%0A    %7D%0A%0A   
@@ -1698,59 +1698,8 @@
 red%0A
-     * @param isPulling      is the source pulling%0A
     
@@ -1764,27 +1764,8 @@
 ured
-, boolean isPulling
 ) %7B%0A
@@ -1847,25 +1847,21 @@
 lling = 
-isPulling
+false
 ;%0A    %7D%0A

Update ServiceDeploymentInfo.java