diff --git a/apps/bgpflowspec/BUCK b/apps/bgpflowspec/BUCK
new file mode 100755
index 0000000..fbcc903
--- /dev/null
+++ b/apps/bgpflowspec/BUCK
@@ -0,0 +1,12 @@
+BUNDLES = [
+    '//apps/bgpflowspec/flowapi:onos-apps-bgpflowspec-flowapi',
+    '//apps/bgpflowspec/flowmgr:onos-apps-bgpflowspec-flowmgr',
+    '//apps/bgpflowspec/bgpweb:onos-apps-bgpflowspec-web',
+]
+
+onos_app (
+  title = 'BGP App',
+  url = 'http://onosproject.org',
+  included_bundles = BUNDLES,
+  description = 'ONOS framework applications',
+)
diff --git a/apps/bgpflowspec/app/app.xml b/apps/bgpflowspec/app/app.xml
new file mode 100755
index 0000000..cb1de47
--- /dev/null
+++ b/apps/bgpflowspec/app/app.xml
@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright 2016-present Open Networking Laboratory
+  ~
+  ~ Licensed 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.
+  -->
+<app name="org.onosproject.bgpflow" origin="ON.Lab" version="${project.version}"
+     category="default" url="http://onosproject.org"
+     featuresRepo="mvn:${project.groupId}/${project.artifactId}/${project.version}/xml/features"
+     features="${project.artifactId}">
+    <description>${project.description}</description>
+    <artifact>mvn:${project.groupId}/onos-app-bgp-flowmgr/${project.version}</artifact>
+    <artifact>mvn:${project.groupId}/onos-app-bgp-web/${project.version}</artifact>
+    <artifact>mvn:${project.groupId}/onos-app-bgp-flowapi/${project.version}</artifact>
+</app>
diff --git a/apps/bgpflowspec/app/features.xml b/apps/bgpflowspec/app/features.xml
new file mode 100755
index 0000000..d638a57
--- /dev/null
+++ b/apps/bgpflowspec/app/features.xml
@@ -0,0 +1,26 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<!--
+  ~ Copyright 2016-present Open Networking Laboratory
+  ~
+  ~ Licensed 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.
+  -->
+<features xmlns="http://karaf.apache.org/xmlns/features/v1.2.0" name="${project.artifactId}-${project.version}">
+    <feature name="${project.artifactId}" version="${project.version}"
+             description="${project.description}">
+        <feature>onos-api</feature>
+        <feature>onos-drivers</feature>
+        <bundle>mvn:${project.groupId}/onos-app-bgp-flowapi/${project.version}</bundle>
+        <bundle>mvn:${project.groupId}/onos-app-bgp-flowmgr/${project.version}</bundle>
+        <bundle>mvn:${project.groupId}/onos-app-bgp-web/${project.version}</bundle>
+    </feature>
+</features>
diff --git a/apps/bgpflowspec/app/pom.xml b/apps/bgpflowspec/app/pom.xml
new file mode 100755
index 0000000..53f4d67
--- /dev/null
+++ b/apps/bgpflowspec/app/pom.xml
@@ -0,0 +1,51 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright 2016-present Open Networking Laboratory
+  ~
+  ~ Licensed 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.
+  -->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.onosproject</groupId>
+        <artifactId>onos-app-bgpflow</artifactId>
+        <version>1.6.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>onos-app-bgp-flow</artifactId>
+    <packaging>pom</packaging>
+
+    <description>ONOS framework applications</description>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onos-app-bgp-flowapi</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onos-app-bgp-flowmgr</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onos-app-bgp-web</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+    </dependencies>
+
+</project>
diff --git a/apps/bgpflowspec/bgpweb/BUCK b/apps/bgpflowspec/bgpweb/BUCK
new file mode 100755
index 0000000..a5ef9e7
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/BUCK
@@ -0,0 +1,12 @@
+COMPILE_DEPS = [
+    '//lib:CORE_DEPS',
+    '//lib:javax.ws.rs-api',
+    '//utils/rest:onlab-rest',
+    '//apps/bgpflowspec/flowapi:onos-apps-bgpflowspec-flowapi',
+    '//apps/bgpflowspec/flowmgr:onos-apps-bgpflowspec-flowmgr',
+]
+
+osgi_jar_with_tests (
+    name = 'onos-apps-bgpflowspec-web',
+    deps = COMPILE_DEPS,
+)
diff --git a/apps/bgpflowspec/bgpweb/pom.xml b/apps/bgpflowspec/bgpweb/pom.xml
new file mode 100755
index 0000000..036a7d1
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/pom.xml
@@ -0,0 +1,78 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright 2016-present Open Networking Laboratory
+  ~
+  ~ Licensed 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.
+  -->
+<project
+        xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
+        xmlns="http://maven.apache.org/POM/4.0.0"
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.onosproject</groupId>
+        <artifactId>onos-app-bgpflow</artifactId>
+        <version>1.6.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>onos-app-bgp-web</artifactId>
+    <packaging>bundle</packaging>
+    <properties>
+        <web.context>/onos/bgp</web.context>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>javax.ws.rs</groupId>
+            <artifactId>javax.ws.rs-api</artifactId>
+            <version>2.0.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onos-app-bgp-flowmgr</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onos-rest</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava-testlib</artifactId>
+        </dependency>
+    </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.felix</groupId>
+                <artifactId>maven-bundle-plugin</artifactId>
+                <extensions>true</extensions>
+                <configuration>
+                    <instructions>
+                        <_wab>src/main/webapp/</_wab>
+                        <Bundle-SymbolicName>
+                            ${project.groupId}.${project.artifactId}
+                        </Bundle-SymbolicName>
+                        <Import-Package>
+                            *,org.glassfish.jersey.servlet
+                        </Import-Package>
+                        <Web-ContextPath>${web.context}</Web-ContextPath>
+                    </instructions>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>
diff --git a/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/BgpFlowWebResource.java b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/BgpFlowWebResource.java
new file mode 100755
index 0000000..44ba4a4
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/BgpFlowWebResource.java
@@ -0,0 +1,352 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.bgpweb.resources;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.node.ArrayNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.onosproject.flow.manager.BgpFlowService;
+import org.onosproject.flowapi.DefaultExtWideCommunityInt;
+import org.onosproject.flowapi.ExtFlowContainer;
+import org.onosproject.flowapi.ExtFlowTypes;
+import org.onosproject.flowapi.ExtTrafficAction;
+import org.onosproject.flowapi.ExtWideCommunityInt;
+import org.onosproject.rest.AbstractWebResource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import javax.ws.rs.Consumes;
+import javax.ws.rs.DELETE;
+import javax.ws.rs.GET;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.List;
+import java.util.ListIterator;
+
+import static javax.ws.rs.core.Response.Status.NOT_ACCEPTABLE;
+import static javax.ws.rs.core.Response.Status.OK;
+
+/**
+ * Bgp flow web resource.
+ */
+
+@Path("flow")
+public class BgpFlowWebResource extends AbstractWebResource {
+
+    private BgpFlowService flowService = get(BgpFlowService.class);
+    protected static final String BGPFLOW = "bgp_flow";
+    protected static final String DEVICEID = "deviceId";
+    protected static final int LOCAL_PERF = 20;
+    private final Logger log = LoggerFactory.getLogger(BgpFlowWebResource.class);
+
+    /**
+     * Get the Bgp flow.
+     *
+     * @return 200 OK
+     */
+    @GET
+    @Produces(MediaType.APPLICATION_JSON)
+    public Response getBgpFlow() {
+        Boolean result = true;
+        //TODO
+        return ok(result.toString()).build();
+    }
+
+    /**
+     * Push the the Bgp flow spec.
+     *
+     * @param stream bgp flow spec in JSON
+     * @return status of the request - CREATED if the JSON is correct,
+     * BAD_REQUEST if the JSON is invalid
+     */
+    @POST
+    @Consumes(MediaType.APPLICATION_JSON)
+    @Produces(MediaType.APPLICATION_JSON)
+    public Response createBgpFlow(InputStream stream) {
+        try {
+            ObjectNode jsonTree = (ObjectNode) mapper().readTree(stream);
+            JsonNode flow = jsonTree.get(BGPFLOW);
+            String devId = jsonTree.get(DEVICEID).asText();
+            boolean status;
+
+            List<ExtFlowTypes> list;
+            ExtFlowContainer container;
+
+            list = codec(ExtFlowTypes.class).decode((ArrayNode) flow, this);
+
+            if (!validateRpd(list)) {
+                return Response.status(NOT_ACCEPTABLE).entity(Boolean.FALSE.toString()).build();
+            }
+
+            container = new ExtFlowContainer(list);
+            container.setDeviceId(devId);
+
+
+            status = flowService.onBgpFlowCreated(container);
+            Boolean isSuccess = Boolean.valueOf(status);
+            if (!status) {
+                return Response.status(NOT_ACCEPTABLE).entity(isSuccess.toString()).build();
+            }
+
+            return Response.status(OK).entity(isSuccess.toString()).build();
+        } catch (IOException e) {
+            log.error("Exception while parsing bgp flow.", e.toString());
+            throw new IllegalArgumentException(e);
+        }
+    }
+
+    /**
+     * Validates the rpd and flow spec classes.
+     *
+     * @param list list of types
+     * @return a true if the validation succeeds else false
+     */
+    boolean validateRpd(List<ExtFlowTypes> list) {
+        ListIterator<ExtFlowTypes> iterator = list.listIterator();
+        ExtFlowTypes flow;
+        boolean key = false;
+        boolean rpd = false;
+        boolean nonRpd = false;
+        ExtTrafficAction flowAction = null;
+        boolean dstPfx = false;
+        boolean wcFlg = false;
+        boolean wcHop = false;
+        boolean wcWc = false;
+        boolean wcCAs = false;
+        boolean wcLAs = false;
+        boolean wcTarget = false;
+        boolean wcETarget = false;
+        boolean wcParm = false;
+
+        while (iterator.hasNext()) {
+            flow = iterator.next();
+            switch (flow.type()) {
+                case EXT_FLOW_RULE_KEY:
+                    key = true;
+                    break;
+                case IPV4_DST_PFX:
+                    dstPfx = true;
+                    break;
+                case IPV4_SRC_PFX:
+                    nonRpd = true;
+                    break;
+                case IP_PROTO_LIST:
+                    nonRpd = true;
+                    break;
+                case IN_PORT_LIST:
+                    nonRpd = true;
+                    break;
+                case DST_PORT_LIST:
+                    nonRpd = true;
+                    break;
+                case SRC_PORT_LIST:
+                    nonRpd = true;
+                    break;
+                case ICMP_TYPE_LIST:
+                    nonRpd = true;
+                    break;
+                case ICMP_CODE_LIST:
+                    nonRpd = true;
+                    break;
+                case TCP_FLAG_LIST:
+                    nonRpd = true;
+                    break;
+                case PACKET_LENGTH_LIST:
+                    nonRpd = true;
+                    break;
+                case DSCP_VALUE_LIST:
+                    nonRpd = true;
+                    break;
+                case FRAGMENT_LIST:
+                    nonRpd = true;
+                    break;
+                case TRAFFIC_ACTION:
+                    flowAction = (ExtTrafficAction) flow;
+                    if (flowAction.rpd()) {
+                        rpd = true;
+                    }
+                    break;
+                case TRAFFIC_RATE:
+                    nonRpd = true;
+                    break;
+                case TRAFFIC_REDIRECT:
+                    nonRpd = true;
+                    break;
+                case TRAFFIC_MARKING:
+                    nonRpd = true;
+                    break;
+                case WIDE_COMM_FLAGS:
+                    wcFlg = true;
+                    break;
+                case WIDE_COMM_HOP_COUNT:
+                    wcHop = true;
+                    break;
+                case WIDE_COMM_COMMUNITY:
+                    wcWc = true;
+                    break;
+                case WIDE_COMM_CONTEXT_AS:
+                    wcCAs = true;
+                    break;
+                case WIDE_COMM_LOCAL_AS:
+                    wcLAs = true;
+                    break;
+                case WIDE_COMM_TARGET:
+                    wcTarget = true;
+                    break;
+                case WIDE_COMM_EXT_TARGET:
+                    wcETarget = true;
+                    break;
+                case WIDE_COMM_PARAMETER:
+                    wcParm = true;
+                    break;
+                default:
+                    log.error("error: this type is not supported");
+                    break;
+            }
+        }
+
+        if (!key) {
+            return false;
+        }
+
+        /** checking for non Rpd. */
+        if (!rpd) {
+            if (wcFlg || wcHop || wcWc
+                    || wcCAs || wcLAs || wcParm) {
+                return false;
+            }
+        }
+
+        /** checking for Rpd. */
+        if (nonRpd || !dstPfx || !wcFlg || !wcHop
+                || !wcWc || !wcCAs || !wcLAs || !wcParm) {
+            return false;
+        }
+
+        /** If it is rpd then either of these two or both should be present.*/
+        if (!wcTarget && !wcETarget) {
+            rpd = false;
+        }
+
+        if (!handleRpdLocalPerf(list)) {
+            return false;
+        }
+
+        return rpd;
+    }
+
+    /**
+     * Validate and format the rpd local perf.
+     *
+     * @param list list of types
+     * @return a true if the validation succeeds else false
+     */
+    boolean handleRpdLocalPerf(List<ExtFlowTypes> list) {
+        ListIterator<ExtFlowTypes> iterator = list.listIterator();
+        ExtFlowTypes flow;
+
+        ExtWideCommunityInt wcComm = null;
+        ExtWideCommunityInt wcParam = null;
+        ListIterator<Integer> wcInt = null;
+        int community = 0;
+        int param = 0;
+
+        while (iterator.hasNext()) {
+            flow = iterator.next();
+            switch (flow.type()) {
+                case WIDE_COMM_COMMUNITY:
+                    wcComm = (ExtWideCommunityInt) flow;
+                    wcInt = wcComm.communityInt().listIterator();
+                    community = wcInt.next().intValue();
+                    break;
+
+                case WIDE_COMM_PARAMETER:
+                    wcParam = (ExtWideCommunityInt) flow;
+                    wcInt = wcParam.communityInt().listIterator();
+                    param = wcInt.next().intValue();
+                    break;
+                default:
+                    log.error("error: this type is not supported");
+                    break;
+            }
+        }
+
+        if (community == LOCAL_PERF) {
+            if (param > 127 || param < -127) {
+                return false;
+            }
+
+            /** if -ve then make it 1 bye value and set it, if it is positive then no issue.*/
+            if (param < 0) {
+                param = ~param + 129;
+                list.remove(wcParam);
+                ExtWideCommunityInt.Builder resultBuilder = new DefaultExtWideCommunityInt.Builder();
+                resultBuilder.setwCommInt(Integer.valueOf(param));
+                resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_PARAMETER);
+                list.add(resultBuilder.build());
+            }
+        }
+
+        return true;
+    }
+
+    /**
+     * Delete the the Bgp flow spec.
+     *
+     * @param stream bgp flow spec in JSON
+     * @return status of the request - CREATED if the JSON is correct,
+     * BAD_REQUEST if the JSON is invalid
+     */
+    @DELETE
+    @Consumes(MediaType.APPLICATION_JSON)
+    @Produces(MediaType.APPLICATION_JSON)
+    public Response deleteBgpFlow(InputStream stream) {
+        try {
+            ObjectNode jsonTree = (ObjectNode) mapper().readTree(stream);
+            JsonNode flow = jsonTree.get(BGPFLOW);
+            String devId = jsonTree.get(DEVICEID).asText();
+            boolean status;
+
+            List<ExtFlowTypes> list;
+            ExtFlowContainer container;
+
+            list = codec(ExtFlowTypes.class).decode((ArrayNode) flow, this);
+
+            if (!validateRpd(list)) {
+                return Response.status(NOT_ACCEPTABLE).entity(Boolean.FALSE.toString()).build();
+            }
+
+            container = new ExtFlowContainer(list);
+            container.setDeviceId(devId);
+
+
+            status = flowService.onBgpFlowDeleted(container);
+            Boolean isSuccess = Boolean.valueOf(status);
+            if (!status) {
+                return Response.status(NOT_ACCEPTABLE).entity(isSuccess.toString()).build();
+            }
+            return Response.status(OK).entity(isSuccess.toString()).build();
+        } catch (IOException e) {
+            log.error("Exception while parsing bgp flow.", e.toString());
+            throw new IllegalArgumentException(e);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/BgpWebApplication.java b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/BgpWebApplication.java
new file mode 100755
index 0000000..4ab7777
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/BgpWebApplication.java
@@ -0,0 +1,31 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.bgpweb.resources;
+
+import org.onlab.rest.AbstractWebApplication;
+import java.util.Set;
+
+/**
+ * BGP REST API web application.
+ */
+public class BgpWebApplication extends AbstractWebApplication {
+    @Override
+    public Set<Class<?>> getClasses() {
+        return getClasses(BgpFlowWebResource.class);
+    }
+}
+
diff --git a/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/package-info.java b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/package-info.java
new file mode 100755
index 0000000..09c5210
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/resources/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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.
+ */
+
+/**
+ * BGP web that used rest to create BGP resources.
+ */
+package org.onosproject.bgpweb.resources;
diff --git a/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpCodecRegistrator.java b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpCodecRegistrator.java
new file mode 100755
index 0000000..1140fda
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpCodecRegistrator.java
@@ -0,0 +1,50 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.bgpweb.web;
+
+import org.apache.felix.scr.annotations.Activate;
+import org.apache.felix.scr.annotations.Component;
+import org.apache.felix.scr.annotations.Deactivate;
+import org.apache.felix.scr.annotations.Reference;
+import org.apache.felix.scr.annotations.ReferenceCardinality;
+import org.onosproject.codec.CodecService;
+import org.onosproject.flowapi.ExtFlowTypes;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/**
+ * Implementation of the JSON codec brokering service for BGP app.
+ */
+@Component(immediate = true)
+public class BgpCodecRegistrator {
+
+    private static Logger log = LoggerFactory.getLogger(BgpCodecRegistrator.class);
+
+    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+    protected CodecService codecService;
+
+    @Activate
+    public void activate() {
+        codecService.registerCodec(ExtFlowTypes.class, new BgpFlowExtensionCodec());
+        System.out.print("BgpCodecRegistrator started");
+        log.info("Started");
+    }
+
+    @Deactivate
+    public void deactivate() {
+        log.info("Stopped");
+    }
+}
diff --git a/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpFlowExtensionCodec.java b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpFlowExtensionCodec.java
new file mode 100755
index 0000000..5c6f250
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpFlowExtensionCodec.java
@@ -0,0 +1,77 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.bgpweb.web;
+
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.onosproject.codec.CodecContext;
+import org.onosproject.codec.JsonCodec;
+import org.onosproject.flowapi.ExtFlowTypes;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public final class BgpFlowExtensionCodec extends JsonCodec<ExtFlowTypes> {
+
+    protected static final Logger log =
+            LoggerFactory.getLogger(BgpFlowExtensionCodec.class);
+
+    protected static final String TYPE = "type";
+    protected static final String NAME = "name";
+    protected static final String PREFIX = "prefix";
+    protected static final String PROTOCOLS = "protocols";
+    protected static final String PORT = "port";
+    protected static final String DST_PORT = "destinationPort";
+    protected static final String SRC_PORT = "sourcePort";
+    protected static final String ICMP_TYPE = "icmpType";
+    protected static final String ICMP_CODE = "icmpCode";
+    protected static final String TCP_FLAG = "tcpFlag";
+    protected static final String PACKET_LENGTH = "packetLength";
+    protected static final String DSCP_VALUE = "dscpValue";
+    protected static final String FRAGMENT = "fragment";
+
+    protected static final String TRAFFIC_RATE = "trafficRate";
+    protected static final String TRAFFIC_ACTION = "trafficAction";
+    protected static final String TRAFFIC_REDIRECTION = "trafficRedirection";
+    protected static final String TRAFFIC_MARKING = "trafficMarking";
+
+    protected static final String TRAFFIC_RATE_ASN = "asn";
+    protected static final String TRAFFIC_RATE_RATE = "rate";
+    protected static final String TRAFFIC_ACTION_TERMINAL = "terminal";
+    protected static final String TRAFFIC_ACTION_SAMPLE = "sample";
+    protected static final String TRAFFIC_ACTION_RPD = "rpd";
+
+    protected static final String WIDE_COMM_FLAGS = "widecommunityFlags";
+    protected static final String WIDE_COMM_HOP_COUNT = "widecommunityHopCount";
+    protected static final String WIDE_COMM_COMMUNITY = "widecommunityCommunity";
+    protected static final String WIDE_COMM_CONTEXT_AS = "widecommunityContextAs";
+    protected static final String WIDE_COMM_LOCAL_AS = "widecommunityLocalAs";
+    protected static final String WIDE_COMM_TARGET = "widecommunityTarget";
+    protected static final String WIDE_COMM_EXT_TARGET = "widecommunityExtTarget";
+    protected static final String WIDE_COMM_PARAMETER = "widecommunityParameter";
+
+    protected static final String WIDE_COMM_TGT_LOCAL_SP = "localSpeaker";
+    protected static final String WIDE_COMM_TGT_REMOTE_SP = "remoteSpeaker";
+
+    @Override
+    public ObjectNode encode(ExtFlowTypes flowTypes, CodecContext context) {
+        return null;
+    }
+
+    @Override
+    public ExtFlowTypes decode(ObjectNode json, CodecContext context) {
+        DecodeBgpFlowExtnCodecHelper decoder = new DecodeBgpFlowExtnCodecHelper(json);
+        return decoder.decode();
+    }
+}
diff --git a/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpParseAttributes.java b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpParseAttributes.java
new file mode 100755
index 0000000..464b388
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/BgpParseAttributes.java
@@ -0,0 +1,402 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.bgpweb.web;
+
+import org.onosproject.flowapi.ExtOperatorValue;
+import org.slf4j.Logger;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.slf4j.LoggerFactory.getLogger;
+
+public class BgpParseAttributes {
+
+    private final Logger log = getLogger(getClass());
+
+    /** Bits as per flow spec rfc 5575.*/
+    final byte endBit = (byte) 0x80;
+    final byte andBit = 0x40;
+    final byte twoByteLen = (byte) (0x01 << 4);
+    final byte fourByteLen = (byte) (0x02 << 4);
+    final byte lessThan = 0x04;
+    final byte greaterThan = 0x02;
+    final byte equal = 0x01;
+
+    /** Protocol types.*/
+    protected static final byte ICMP = 1;
+    protected static final byte IGMP = 2;
+    protected static final byte TCP = 6;
+    protected static final byte UDP = 17;
+    protected static final byte IPV4 = 4;
+    protected static final byte IPV6 = 41;
+
+    /** TCP Flags.*/
+    static final byte FIN = (1 << 0);
+    static final byte SYN = (1 << 1);
+    static final byte RST = (1 << 2);
+    static final byte PSH = (1 << 3);
+    static final byte ACK = (1 << 4);
+    static final byte URG = (1 << 5);
+
+    final byte notBit = 0x02;
+    final byte matchBit = 0x01;
+
+    /** Fragment Flags.*/
+    static final byte DF = (1 << 0);
+    static final byte IF = (1 << 1);
+    static final byte FF = (1 << 2);
+    static final byte LF = (1 << 3);
+
+    List<ExtOperatorValue> parsePort(String string) {
+        List<ExtOperatorValue> operatorValue = null;
+
+        operatorValue = createOperatorValue(string);
+
+        return operatorValue;
+    }
+
+    List<ExtOperatorValue> parseIpProtocol(String string) {
+        List<ExtOperatorValue> operatorValue  = null;
+
+        string = string.replaceAll("ICMP", Byte.valueOf(ICMP).toString());
+        string = string.replaceAll("icmp", Byte.valueOf(ICMP).toString());
+        string = string.replaceAll("IPv4", Byte.valueOf(IPV4).toString());
+        string = string.replaceAll("ipv4", Byte.valueOf(IPV4).toString());
+        string = string.replaceAll("TCP", Byte.valueOf(TCP).toString());
+        string = string.replaceAll("tcp", Byte.valueOf(TCP).toString());
+        string = string.replaceAll("UDP", Byte.valueOf(UDP).toString());
+        string = string.replaceAll("udp", Byte.valueOf(UDP).toString());
+        string = string.replaceAll("IPv6", Byte.valueOf(IPV6).toString());
+        string = string.replaceAll("ipv6", Byte.valueOf(IPV6).toString());
+        string = string.replaceAll("igmp", Byte.valueOf(IGMP).toString());
+        string = string.replaceAll("IGMP", Byte.valueOf(IGMP).toString());
+
+        operatorValue = createOperatorValue(string);
+
+        return operatorValue;
+    }
+
+    List<ExtOperatorValue> parseIcmpType(String string) {
+        List<ExtOperatorValue> operatorValue  = null;
+
+        operatorValue = createOperatorValue(string);
+
+        return operatorValue;
+    }
+
+    List<ExtOperatorValue> parseIcmpCode(String string) {
+        List<ExtOperatorValue> operatorValue  = null;
+
+        operatorValue = createOperatorValue(string);
+
+        return operatorValue;
+    }
+
+
+    List<ExtOperatorValue> parseTcpFlags(String string) {
+        List<ExtOperatorValue> operatorValue  = new ArrayList<>();
+        Token token;
+        int index = 0;
+
+        string = string.replaceAll("FIN", Byte.valueOf(FIN).toString());
+        string = string.replaceAll("fin", Byte.valueOf(FIN).toString());
+        string = string.replaceAll("SYN", Byte.valueOf(SYN).toString());
+        string = string.replaceAll("syn", Byte.valueOf(SYN).toString());
+        string = string.replaceAll("RST", Byte.valueOf(RST).toString());
+        string = string.replaceAll("rst", Byte.valueOf(RST).toString());
+        string = string.replaceAll("PSH", Byte.valueOf(PSH).toString());
+        string = string.replaceAll("psh", Byte.valueOf(PSH).toString());
+        string = string.replaceAll("ACK", Byte.valueOf(ACK).toString());
+        string = string.replaceAll("ack", Byte.valueOf(ACK).toString());
+        string = string.replaceAll("URG", Byte.valueOf(URG).toString());
+        string = string.replaceAll("urg", Byte.valueOf(URG).toString());
+
+        do {
+            token = parseTcpTokenValue(string, index);
+            if (token.error) {
+                log.error("Error in parsing the TCP value list");
+                return null;
+            }
+            operatorValue.add(new ExtOperatorValue(token.operator, token.value));
+            index = token.index;
+        } while ((token.operator & endBit) != endBit);
+
+        return operatorValue;
+    }
+
+    List<ExtOperatorValue> parsePacketLength(String string) {
+        List<ExtOperatorValue> operatorValue  = null;
+        operatorValue = createOperatorValue(string);
+
+        return operatorValue;
+    }
+
+    List<ExtOperatorValue> parseDscp(String string) {
+        List<ExtOperatorValue> operatorValue  = null;
+
+        operatorValue = createOperatorValue(string);
+
+        return operatorValue;
+    }
+
+    List<ExtOperatorValue> parseFragment(String string) {
+
+        List<ExtOperatorValue> operatorValue  = null;
+
+        string = string.replaceAll("DF", Byte.valueOf(DF).toString());
+        string = string.replaceAll("df", Byte.valueOf(DF).toString());
+        string = string.replaceAll("IF", Byte.valueOf(IF).toString());
+        string = string.replaceAll("if", Byte.valueOf(IF).toString());
+        string = string.replaceAll("FF", Byte.valueOf(FF).toString());
+        string = string.replaceAll("ff", Byte.valueOf(FF).toString());
+        string = string.replaceAll("LF", Byte.valueOf(LF).toString());
+        string = string.replaceAll("lf", Byte.valueOf(LF).toString());
+
+        operatorValue = createOperatorValue(string);
+        return operatorValue;
+    }
+
+    private class Token {
+        byte operator;
+        byte[] value;
+        int index;
+        boolean error;
+    }
+
+    List<ExtOperatorValue> createOperatorValue(String string) {
+        List<ExtOperatorValue> operatorValue  = new ArrayList<>();
+        Token token;
+        int index = 0;
+
+        do {
+            token = parseMultiTokenValue(string, index);
+            if (token.error) {
+                log.error("Error in parsing the operator value list");
+                return null;
+            }
+            operatorValue.add(new ExtOperatorValue(token.operator, token.value));
+            index = token.index;
+        } while ((token.operator & endBit) != endBit);
+
+        return operatorValue;
+    }
+
+
+    Token parseMultiTokenValue(String str, int index) {
+        Token token = new Token();
+        token.error = true;
+        int number = 0;
+        int cur = 0;
+        byte operator = 0;
+        boolean prevNumber = false;
+        boolean bLess = false;
+        boolean bGreater = false;
+        boolean bAnd = false;
+        boolean bEqual = false;
+
+        while (str.length() > index) {
+
+            switch (str.charAt(index)) {
+                case '=':
+                    if (bEqual) {
+                        return token;
+                    }
+                    bEqual = true;
+                    if (prevNumber) {
+                        return windUp(str, index, number, operator);
+                    }
+                    operator = (byte) (operator | equal);
+                    break;
+                case '>':
+                    if (bGreater) {
+                        return token;
+                    }
+                    bGreater = true;
+                    if (prevNumber) {
+                        return windUp(str, index, number, operator);
+                    }
+                    operator = (byte) (operator | greaterThan);
+                    break;
+                case '<':
+                    if (bLess) {
+                        return token;
+                    }
+                    bLess = true;
+                    if (prevNumber) {
+                        return windUp(str, index, number, operator);
+                    }
+                    operator = (byte) (operator | lessThan);
+                    break;
+                case '&':
+                    if (bAnd) {
+                        return token;
+                    }
+                    bAnd = true;
+                    if (prevNumber) {
+                        return windUp(str, index, number, operator);
+                    }
+                    operator = (byte) (operator | andBit);
+                    break;
+                case '0':
+                case '1':
+                case '2':
+                case '3':
+                case '4':
+                case '5':
+                case '6':
+                case '7':
+                case '8':
+                case '9':
+                    prevNumber = true;
+                    bLess = false;
+                    bGreater = false;
+                    bAnd = false;
+                    bEqual = false;
+                    cur =  str.charAt(index);
+                    number = (number * 10) + cur - '0';
+                    break;
+
+                default:
+                    log.error("Error in parsing the token character" + str.charAt(index));
+                    return token;
+            }
+            index++;
+        }
+
+        if (prevNumber) {
+            return windUp(str, index, number, operator);
+        }
+
+        return token;
+    }
+
+    Token windUp(String str, int index, int number, byte operator) {
+        Token token = new Token();
+        byte[] array = new byte[1];
+
+        if (str.length() == index) {
+            operator = (byte) (operator | endBit);
+        }
+
+        if (number <= 255) {
+            array[0] = (byte) number;
+        } else if (number > 255 && number <= Short.MAX_VALUE) {
+            operator = (byte) (operator | twoByteLen);
+            array = shortToByteStream((short) number);
+        } else if (number > Short.MAX_VALUE) {
+            operator = (byte) (operator | fourByteLen);
+            array = intToByteStream(number);
+        }
+
+        token.value = array;
+        token.operator = operator;
+        token.index = index;
+        token.error = false;
+        return token;
+    }
+
+    byte[] intToByteStream(int val) {
+        return new byte[] {
+                (byte) (val >>> 24),
+                (byte) (val >>> 16),
+                (byte) (val >>> 8),
+                (byte) val};
+    }
+
+    byte[] shortToByteStream(short val) {
+        return new byte[] {
+                (byte) (val >>> 8),
+                (byte) val};
+    }
+
+    Token parseTcpTokenValue(String str, int index) {
+        Token token = new Token();
+        token.error = true;
+        int number = 0;
+        int cur = 0;
+        byte operator = 0;
+        boolean prevNumber = false;
+
+        boolean bNotBit = false;
+        boolean bAnd = false;
+        boolean bMatchBit = false;
+
+        while (str.length() > index) {
+
+            switch (str.charAt(index)) {
+                case '=':
+                    if (bMatchBit) {
+                        return token;
+                    }
+                    bMatchBit = true;
+                    if (prevNumber) {
+                        return windUp(str, index, number, operator);
+                    }
+                    operator = (byte) (operator | matchBit);
+                    break;
+                case '!':
+                    if (bNotBit) {
+                        return token;
+                    }
+                    bNotBit = true;
+                    if (prevNumber) {
+                        return windUp(str, index, number, operator);
+                    }
+                    operator = (byte) (operator | notBit);
+                    break;
+                case '&':
+                    if (bAnd) {
+                        return token;
+                    }
+                    bAnd = true;
+                    if (prevNumber) {
+                        return windUp(str, index, number, operator);
+                    }
+                    operator = (byte) (operator | andBit);
+                    break;
+                case '0':
+                case '1':
+                case '2':
+                case '3':
+                case '4':
+                case '5':
+                case '6':
+                case '7':
+                case '8':
+                case '9':
+                    prevNumber = true;
+                    bNotBit = false;
+                    bAnd = false;
+                    bMatchBit = false;
+                    cur =  str.charAt(index);
+                    number = (number * 10) + cur - '0';
+                    break;
+
+                default:
+                    log.error("Error in parsing the TCP token character" + str.charAt(index));
+                    return token;
+            }
+            index++;
+        }
+
+        if (prevNumber) {
+            return windUp(str, index, number, operator);
+        }
+
+        return token;
+    }
+}
diff --git a/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/DecodeBgpFlowExtnCodecHelper.java b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/DecodeBgpFlowExtnCodecHelper.java
new file mode 100755
index 0000000..3aafde1
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/DecodeBgpFlowExtnCodecHelper.java
@@ -0,0 +1,721 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.bgpweb.web;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.onlab.packet.IpAddress;
+import org.onlab.packet.IpPrefix;
+import org.onosproject.flowapi.DefaultExtDscpValue;
+import org.onosproject.flowapi.DefaultExtFragment;
+import org.onosproject.flowapi.DefaultExtIcmpCode;
+import org.onosproject.flowapi.DefaultExtIcmpType;
+import org.onosproject.flowapi.DefaultExtIpProtocol;
+import org.onosproject.flowapi.DefaultExtKeyName;
+import org.onosproject.flowapi.DefaultExtPacketLength;
+import org.onosproject.flowapi.DefaultExtPort;
+import org.onosproject.flowapi.DefaultExtPrefix;
+import org.onosproject.flowapi.DefaultExtTarget;
+import org.onosproject.flowapi.DefaultExtTcpFlag;
+import org.onosproject.flowapi.DefaultExtTrafficAction;
+import org.onosproject.flowapi.DefaultExtTrafficMarking;
+import org.onosproject.flowapi.DefaultExtTrafficRate;
+import org.onosproject.flowapi.DefaultExtTrafficRedirect;
+import org.onosproject.flowapi.DefaultExtWideCommunityInt;
+import org.onosproject.flowapi.ExtDscpValue;
+import org.onosproject.flowapi.ExtFlowTypes;
+import org.onosproject.flowapi.ExtFragment;
+import org.onosproject.flowapi.ExtIcmpCode;
+import org.onosproject.flowapi.ExtIcmpType;
+import org.onosproject.flowapi.ExtIpProtocol;
+import org.onosproject.flowapi.ExtKeyName;
+import org.onosproject.flowapi.ExtPacketLength;
+import org.onosproject.flowapi.ExtPort;
+import org.onosproject.flowapi.ExtPrefix;
+import org.onosproject.flowapi.ExtTarget;
+import org.onosproject.flowapi.ExtTcpFlag;
+import org.onosproject.flowapi.ExtTrafficAction;
+import org.onosproject.flowapi.ExtTrafficMarking;
+import org.onosproject.flowapi.ExtTrafficRate;
+import org.onosproject.flowapi.ExtTrafficRedirect;
+import org.onosproject.flowapi.ExtWideCommunityInt;
+
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+
+import static org.onlab.util.Tools.nullIsIllegal;
+
+/**
+ * Decode the Ext extension codec.
+ */
+public final class DecodeBgpFlowExtnCodecHelper {
+
+    private final ObjectNode json;
+
+    protected static final String MISSING_MEMBER_MESSAGE =
+            " member is required in ExtTypes";
+
+    protected static final String MALFORMED_MEMBER_MESSAGE =
+            " member is malformed";
+
+    private interface ExtensionDecoder {
+        ExtFlowTypes decodeExtension(ObjectNode json);
+    }
+
+    private final Map<String, ExtensionDecoder> decoderMap;
+
+    BgpParseAttributes parse = new BgpParseAttributes();
+
+    /**
+     * Creates a decode extension codec object.
+     * Initializes the lookup map for Bgp extension types.
+     *
+     * @param json JSON object to decode
+     */
+    public DecodeBgpFlowExtnCodecHelper(ObjectNode json) {
+        this.json = json;
+        decoderMap = new HashMap<>();
+
+        decoderMap.put(ExtFlowTypes.ExtType.IPV4_SRC_PFX.name(), new BgpSourcePrefixDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.IPV4_DST_PFX.name(), new BgpDestinationPrefixDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.EXT_FLOW_RULE_KEY.name(), new BgpFlowRuleKeyDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.IP_PROTO_LIST.name(), new BgpIpProtocolDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.IN_PORT_LIST.name(), new BgpInPortDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.DST_PORT_LIST.name(), new BgpDestinationPortDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.SRC_PORT_LIST.name(), new BgpSourcePortDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.ICMP_TYPE_LIST.name(), new BgpIcmpTypeDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.ICMP_CODE_LIST.name(), new BgpIcmpCodeDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.TCP_FLAG_LIST.name(), new BgpTcpFlagDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.PACKET_LENGTH_LIST.name(), new BgpPacketLengthDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.DSCP_VALUE_LIST.name(), new BgpDscpValueDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.FRAGMENT_LIST.name(), new BgpFragmentDecode());
+
+        decoderMap.put(ExtFlowTypes.ExtType.TRAFFIC_RATE.name(), new BgpTrafficRateDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.TRAFFIC_ACTION.name(), new BgpTrafficActionDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.TRAFFIC_REDIRECT.name(), new BgpTrafficRedirectDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.TRAFFIC_MARKING.name(), new BgpTrafficMarkingDecode());
+
+        decoderMap.put(ExtFlowTypes.ExtType.WIDE_COMM_FLAGS.name(), new BgpWcommFlagsDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.WIDE_COMM_HOP_COUNT.name(), new BgpWcommHopCountDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.WIDE_COMM_COMMUNITY.name(), new BgpWcommCommunityDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.WIDE_COMM_CONTEXT_AS.name(), new BgpWcommContextAsDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.WIDE_COMM_LOCAL_AS.name(), new BgpWcommLocalAsDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.WIDE_COMM_TARGET.name(), new BgpWcommTargetDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.WIDE_COMM_EXT_TARGET.name(), new BgpWcommExtTargetDecode());
+        decoderMap.put(ExtFlowTypes.ExtType.WIDE_COMM_PARAMETER.name(), new BgpWcommParameterDecode());
+    }
+
+    /** Source prefix decoder.*/
+    private class BgpSourcePrefixDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtPrefix.Builder resultBuilder = new DefaultExtPrefix.Builder();
+
+            String ip = nullIsIllegal(json.get(BgpFlowExtensionCodec.PREFIX),
+                    BgpFlowExtensionCodec.PREFIX + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setPrefix(IpPrefix.valueOf(ip));
+            resultBuilder.setType(ExtFlowTypes.ExtType.IPV4_SRC_PFX);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Destination prefix decoder.*/
+    private class BgpDestinationPrefixDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtPrefix.Builder resultBuilder = new DefaultExtPrefix.Builder();
+
+            String ip = nullIsIllegal(json.get(BgpFlowExtensionCodec.PREFIX),
+                    BgpFlowExtensionCodec.PREFIX + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setPrefix(IpPrefix.valueOf(ip));
+            resultBuilder.setType(ExtFlowTypes.ExtType.IPV4_DST_PFX);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Flow rule key decoder.*/
+    private class BgpFlowRuleKeyDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtKeyName.Builder resultBuilder = new DefaultExtKeyName.Builder();
+
+            String name = nullIsIllegal(json.get(BgpFlowExtensionCodec.NAME),
+                    BgpFlowExtensionCodec.NAME + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setKeyName(name);
+            resultBuilder.setType(ExtFlowTypes.ExtType.EXT_FLOW_RULE_KEY);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Ip protocol decoder.*/
+    private class BgpIpProtocolDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtIpProtocol.Builder resultBuilder = new DefaultExtIpProtocol.Builder();
+
+            String protocols = nullIsIllegal(json.get(BgpFlowExtensionCodec.PROTOCOLS),
+                    BgpFlowExtensionCodec.PROTOCOLS + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setIpProtocol(parse.parseIpProtocol(protocols));
+            resultBuilder.setType(ExtFlowTypes.ExtType.IP_PROTO_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** In port decoder.*/
+    private class BgpInPortDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtPort.Builder resultBuilder = new DefaultExtPort.Builder();
+
+            String portList = nullIsIllegal(json.get(BgpFlowExtensionCodec.PORT),
+                    BgpFlowExtensionCodec.PORT + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setPort(parse.parsePort(portList));
+            resultBuilder.setType(ExtFlowTypes.ExtType.IN_PORT_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Destination decoder.*/
+    private class BgpDestinationPortDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtPort.Builder resultBuilder = new DefaultExtPort.Builder();
+
+            String portList = nullIsIllegal(json.get(BgpFlowExtensionCodec.DST_PORT),
+                    BgpFlowExtensionCodec.DST_PORT + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setPort(parse.parsePort(portList));
+            resultBuilder.setType(ExtFlowTypes.ExtType.DST_PORT_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Source decoder.*/
+    private class BgpSourcePortDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtPort.Builder resultBuilder = new DefaultExtPort.Builder();
+
+            String portList = nullIsIllegal(json.get(BgpFlowExtensionCodec.SRC_PORT),
+                    BgpFlowExtensionCodec.SRC_PORT + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setPort(parse.parsePort(portList));
+            resultBuilder.setType(ExtFlowTypes.ExtType.SRC_PORT_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Icmp type decoder.*/
+    private class BgpIcmpTypeDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtIcmpType.Builder resultBuilder = new DefaultExtIcmpType.Builder();
+
+            String icmpType = nullIsIllegal(json.get(BgpFlowExtensionCodec.ICMP_TYPE),
+                    BgpFlowExtensionCodec.ICMP_TYPE + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setIcmpType(parse.parseIcmpType(icmpType));
+            resultBuilder.setType(ExtFlowTypes.ExtType.ICMP_TYPE_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Icmp code decoder.*/
+    private class BgpIcmpCodeDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtIcmpCode.Builder resultBuilder = new DefaultExtIcmpCode.Builder();
+
+            String icmpCode = nullIsIllegal(json.get(BgpFlowExtensionCodec.ICMP_CODE),
+                    BgpFlowExtensionCodec.ICMP_CODE + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setIcmpCode(parse.parseIcmpCode(icmpCode));
+            resultBuilder.setType(ExtFlowTypes.ExtType.ICMP_CODE_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Tcp flag decoder.*/
+    private class BgpTcpFlagDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtTcpFlag.Builder resultBuilder = new DefaultExtTcpFlag.Builder();
+
+            String tcpFlag = nullIsIllegal(json.get(BgpFlowExtensionCodec.TCP_FLAG),
+                    BgpFlowExtensionCodec.TCP_FLAG + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setTcpFlag(parse.parseTcpFlags(tcpFlag));
+            resultBuilder.setType(ExtFlowTypes.ExtType.TCP_FLAG_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Packet length decoder.*/
+    private class BgpPacketLengthDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtPacketLength.Builder resultBuilder = new DefaultExtPacketLength.Builder();
+
+            String packetLength = nullIsIllegal(json.get(BgpFlowExtensionCodec.PACKET_LENGTH),
+                    BgpFlowExtensionCodec.PACKET_LENGTH + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setPacketLength(parse.parsePacketLength(packetLength));
+            resultBuilder.setType(ExtFlowTypes.ExtType.PACKET_LENGTH_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Dscp value decoder.*/
+    private class BgpDscpValueDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtDscpValue.Builder resultBuilder = new DefaultExtDscpValue.Builder();
+
+            String dscpValue = nullIsIllegal(json.get(BgpFlowExtensionCodec.DSCP_VALUE),
+                    BgpFlowExtensionCodec.DSCP_VALUE + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setDscpValue(parse.parseDscp(dscpValue));
+            resultBuilder.setType(ExtFlowTypes.ExtType.DSCP_VALUE_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Fragment decoder.*/
+    private class BgpFragmentDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtFragment.Builder resultBuilder = new DefaultExtFragment.Builder();
+
+            String fragment = nullIsIllegal(json.get(BgpFlowExtensionCodec.FRAGMENT),
+                    BgpFlowExtensionCodec.FRAGMENT + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setFragment(parse.parseFragment(fragment));
+            resultBuilder.setType(ExtFlowTypes.ExtType.FRAGMENT_LIST);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Traffic rate decoder.*/
+    private class BgpTrafficRateDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtTrafficRate.Builder resultBuilder = new DefaultExtTrafficRate.Builder();
+
+            String rate = nullIsIllegal(json.get(BgpFlowExtensionCodec.TRAFFIC_RATE),
+                    BgpFlowExtensionCodec.TRAFFIC_RATE + MISSING_MEMBER_MESSAGE).asText();
+
+            String[] commaPart = rate.split(",");
+            String[] valuePart = commaPart[0].split("=");
+
+            if (valuePart[0].matches(BgpFlowExtensionCodec.TRAFFIC_RATE_ASN)) {
+                short s = Short.decode(valuePart[1].trim()).shortValue();
+                resultBuilder.setAsn(s);
+            } else {
+                nullIsIllegal(valuePart[0], BgpFlowExtensionCodec.TRAFFIC_RATE + MALFORMED_MEMBER_MESSAGE);
+            }
+
+            valuePart = commaPart[1].split("=");
+            if (valuePart[0].matches(BgpFlowExtensionCodec.TRAFFIC_RATE_RATE)) {
+                float f = Float.parseFloat(valuePart[1].trim());
+                resultBuilder.setRate(f);
+            } else {
+                nullIsIllegal(valuePart[0], BgpFlowExtensionCodec.TRAFFIC_RATE + MALFORMED_MEMBER_MESSAGE);
+            }
+
+            resultBuilder.setType(ExtFlowTypes.ExtType.TRAFFIC_RATE);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Traffic action decoder.*/
+    private class BgpTrafficActionDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtTrafficAction.Builder resultBuilder = new DefaultExtTrafficAction.Builder();
+
+            String rate = nullIsIllegal(json.get(BgpFlowExtensionCodec.TRAFFIC_ACTION),
+                    BgpFlowExtensionCodec.TRAFFIC_ACTION + MISSING_MEMBER_MESSAGE).asText();
+
+            String[] commaPart = rate.split(",");
+            String[] valuePart = commaPart[0].split("=");
+
+            if (valuePart[0].matches(BgpFlowExtensionCodec.TRAFFIC_ACTION_TERMINAL)) {
+                boolean terminal = Boolean.parseBoolean(valuePart[1].trim());
+                resultBuilder.setTerminal(terminal);
+            } else {
+                nullIsIllegal(valuePart[0], BgpFlowExtensionCodec.TRAFFIC_ACTION_TERMINAL + MISSING_MEMBER_MESSAGE);
+            }
+
+            valuePart = commaPart[1].split("=");
+            if (valuePart[0].matches(BgpFlowExtensionCodec.TRAFFIC_ACTION_SAMPLE)) {
+                boolean sample = Boolean.parseBoolean(valuePart[1].trim());
+                resultBuilder.setSample(sample);
+            } else {
+                nullIsIllegal(valuePart[0], BgpFlowExtensionCodec.TRAFFIC_ACTION_SAMPLE + MISSING_MEMBER_MESSAGE);
+            }
+
+            valuePart = commaPart[2].split("=");
+            if (valuePart[0].matches(BgpFlowExtensionCodec.TRAFFIC_ACTION_RPD)) {
+                boolean rpd = Boolean.parseBoolean(valuePart[1].trim());
+                resultBuilder.setRpd(rpd);
+            } else {
+                nullIsIllegal(valuePart[0], BgpFlowExtensionCodec.TRAFFIC_ACTION_RPD + MISSING_MEMBER_MESSAGE);
+            }
+
+            resultBuilder.setType(ExtFlowTypes.ExtType.TRAFFIC_ACTION);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Traffic redirect decoder.*/
+    private class BgpTrafficRedirectDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtTrafficRedirect.Builder resultBuilder = new DefaultExtTrafficRedirect.Builder();
+
+            String action = nullIsIllegal(json.get(BgpFlowExtensionCodec.TRAFFIC_REDIRECTION),
+                    BgpFlowExtensionCodec.TRAFFIC_REDIRECTION + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setRedirect(action);
+            resultBuilder.setType(ExtFlowTypes.ExtType.TRAFFIC_REDIRECT);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Traffic marking decoder.*/
+    private class BgpTrafficMarkingDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtTrafficMarking.Builder resultBuilder = new DefaultExtTrafficMarking.Builder();
+
+            String action = nullIsIllegal(json.get(BgpFlowExtensionCodec.TRAFFIC_MARKING),
+                    BgpFlowExtensionCodec.TRAFFIC_MARKING + MISSING_MEMBER_MESSAGE).asText();
+
+            if ((action.length() != 1) || action.isEmpty()) {
+                nullIsIllegal(action, BgpFlowExtensionCodec.TRAFFIC_MARKING + MALFORMED_MEMBER_MESSAGE);
+            }
+
+            resultBuilder.setMarking((byte) action.charAt(0));
+            resultBuilder.setType(ExtFlowTypes.ExtType.TRAFFIC_MARKING);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Wide community flag decoder.*/
+    private class BgpWcommFlagsDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtWideCommunityInt.Builder resultBuilder = new DefaultExtWideCommunityInt.Builder();
+
+            String wideComm = nullIsIllegal(json.get(BgpFlowExtensionCodec.WIDE_COMM_FLAGS),
+                    BgpFlowExtensionCodec.WIDE_COMM_FLAGS + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setwCommInt(Integer.valueOf(wideComm));
+            resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_FLAGS);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Wide community hop count decoder.*/
+    private class BgpWcommHopCountDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtWideCommunityInt.Builder resultBuilder = new DefaultExtWideCommunityInt.Builder();
+
+            String wideComm = nullIsIllegal(json.get(BgpFlowExtensionCodec.WIDE_COMM_HOP_COUNT),
+                    BgpFlowExtensionCodec.WIDE_COMM_HOP_COUNT + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setwCommInt(Integer.valueOf(wideComm));
+            resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_HOP_COUNT);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Wide community decoder.*/
+    private class BgpWcommCommunityDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtWideCommunityInt.Builder resultBuilder = new DefaultExtWideCommunityInt.Builder();
+
+            String wideComm = nullIsIllegal(json.get(BgpFlowExtensionCodec.WIDE_COMM_COMMUNITY),
+                    BgpFlowExtensionCodec.WIDE_COMM_COMMUNITY + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setwCommInt(Integer.valueOf(wideComm));
+            resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_COMMUNITY);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Wide community context AS decoder.*/
+    private class BgpWcommContextAsDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtWideCommunityInt.Builder resultBuilder = new DefaultExtWideCommunityInt.Builder();
+
+            String wideComm = nullIsIllegal(json.get(BgpFlowExtensionCodec.WIDE_COMM_CONTEXT_AS),
+                    BgpFlowExtensionCodec.WIDE_COMM_CONTEXT_AS + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setwCommInt(Integer.valueOf(wideComm));
+            resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_CONTEXT_AS);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Wide community local AS decoder.*/
+    private class BgpWcommLocalAsDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtWideCommunityInt.Builder resultBuilder = new DefaultExtWideCommunityInt.Builder();
+
+            String wideComm = nullIsIllegal(json.get(BgpFlowExtensionCodec.WIDE_COMM_LOCAL_AS),
+                    BgpFlowExtensionCodec.WIDE_COMM_LOCAL_AS + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setwCommInt(Integer.valueOf(wideComm));
+            resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_LOCAL_AS);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Wide community parameter decoder.*/
+    private class BgpWcommParameterDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtWideCommunityInt.Builder resultBuilder = new DefaultExtWideCommunityInt.Builder();
+
+            String wideComm = nullIsIllegal(json.get(BgpFlowExtensionCodec.WIDE_COMM_PARAMETER),
+                    BgpFlowExtensionCodec.WIDE_COMM_PARAMETER + MISSING_MEMBER_MESSAGE).asText();
+            resultBuilder.setwCommInt(Integer.valueOf(wideComm));
+            resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_PARAMETER);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Wide community target decoder.*/
+    private class BgpWcommTargetDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtTarget.Builder resultBuilder = new DefaultExtTarget.Builder();
+
+            JsonNode jsonNodes = json.get(BgpFlowExtensionCodec.WIDE_COMM_TARGET);
+            if (jsonNodes == null) {
+                nullIsIllegal(json.get(BgpFlowExtensionCodec.WIDE_COMM_TARGET),
+                        BgpFlowExtensionCodec.WIDE_COMM_TARGET + MISSING_MEMBER_MESSAGE).asText();
+            }
+
+            JsonNode array = jsonNodes.path(BgpFlowExtensionCodec.WIDE_COMM_TGT_LOCAL_SP);
+            if (array == null) {
+                nullIsIllegal(array, BgpFlowExtensionCodec.WIDE_COMM_TGT_LOCAL_SP + MISSING_MEMBER_MESSAGE).asText();
+            }
+
+            ExtPrefix.Builder resultBuilderPfx = parseIpArrayToPrefix(array);
+            resultBuilderPfx.setType(ExtFlowTypes.ExtType.IPV4_SRC_PFX);
+            resultBuilder.setLocalSpeaker(resultBuilderPfx.build());
+
+            array = jsonNodes.path(BgpFlowExtensionCodec.WIDE_COMM_TGT_REMOTE_SP);
+            if (array == null) {
+                nullIsIllegal(array, BgpFlowExtensionCodec.WIDE_COMM_TGT_REMOTE_SP + MISSING_MEMBER_MESSAGE).asText();
+            }
+
+            resultBuilderPfx = parseIpArrayToPrefix(array);
+            resultBuilderPfx.setType(ExtFlowTypes.ExtType.IPV4_DST_PFX);
+            resultBuilder.setRemoteSpeaker(resultBuilderPfx.build());
+            resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_TARGET);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Wide community extended target decoder.*/
+    private class BgpWcommExtTargetDecode implements ExtensionDecoder {
+        @Override
+        public ExtFlowTypes decodeExtension(ObjectNode json) {
+            if (json == null || !json.isObject()) {
+                return null;
+            }
+
+            ExtTarget.Builder resultBuilder = new DefaultExtTarget.Builder();
+
+            JsonNode jsonNodes = json.get(BgpFlowExtensionCodec.WIDE_COMM_EXT_TARGET);
+            if (jsonNodes == null) {
+                nullIsIllegal(json.get(BgpFlowExtensionCodec.WIDE_COMM_EXT_TARGET),
+                        BgpFlowExtensionCodec.WIDE_COMM_EXT_TARGET + MISSING_MEMBER_MESSAGE).asText();
+            }
+
+            JsonNode array = jsonNodes.path(BgpFlowExtensionCodec.WIDE_COMM_TGT_LOCAL_SP);
+            if (array == null) {
+                nullIsIllegal(array, BgpFlowExtensionCodec.WIDE_COMM_TGT_LOCAL_SP + MISSING_MEMBER_MESSAGE).asText();
+            }
+
+            ExtPrefix.Builder resultBuilderPfx = parseIpArrayToPrefix(array);
+            resultBuilderPfx.setType(ExtFlowTypes.ExtType.IPV4_SRC_PFX);
+            resultBuilder.setLocalSpeaker(resultBuilderPfx.build());
+
+            array = jsonNodes.path(BgpFlowExtensionCodec.WIDE_COMM_TGT_REMOTE_SP);
+            if (array == null) {
+                nullIsIllegal(array, BgpFlowExtensionCodec.WIDE_COMM_TGT_REMOTE_SP + MISSING_MEMBER_MESSAGE).asText();
+            }
+
+            resultBuilderPfx = parseIpArrayToPrefix(array);
+            resultBuilderPfx.setType(ExtFlowTypes.ExtType.IPV4_DST_PFX);
+            resultBuilder.setRemoteSpeaker(resultBuilderPfx.build());
+            resultBuilder.setType(ExtFlowTypes.ExtType.WIDE_COMM_EXT_TARGET);
+
+            return resultBuilder.build();
+        }
+    }
+
+    /** Ip address parser decoder.*/
+    public ExtPrefix.Builder parseIpArrayToPrefix(JsonNode array) {
+
+        ExtPrefix.Builder resultBuilder = new DefaultExtPrefix.Builder();
+        String ip;
+        IpPrefix prefix;
+        IpAddress ipAddr;
+
+        Iterator<JsonNode> itr =  array.iterator();
+        while (itr.hasNext()) {
+            ip = itr.next().asText();
+            ipAddr = IpAddress.valueOf(ip);
+            prefix = IpPrefix.valueOf(ipAddr, 32);
+            resultBuilder.setPrefix(prefix);
+        }
+
+        return resultBuilder;
+    }
+
+    /**
+     * Decodes the JSON into a BgpFlowType extension object.
+     *
+     * @return ExtFlowTypes object
+     * @throws IllegalArgumentException if the JSON is invalid
+     */
+    public ExtFlowTypes decode() {
+        String type = json.get(BgpFlowExtensionCodec.TYPE).asText();
+
+        ExtensionDecoder decoder = decoderMap.get(type);
+        if (decoder != null) {
+            return decoder.decodeExtension(json);
+        }
+
+        throw new IllegalArgumentException("Type " + type + " is unknown");
+    }
+}
diff --git a/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/package-info.java b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/package-info.java
new file mode 100755
index 0000000..2f6d844
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/java/org/onosproject/bgpweb/web/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2016-prensent Open Networking Laboratory
+ *
+ * Licensed 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.
+ */
+
+/**
+ * Codec for bgp flow.
+ */
+package org.onosproject.bgpweb.web;
diff --git a/apps/bgpflowspec/bgpweb/src/main/webapp/WEB-INF/web.xml b/apps/bgpflowspec/bgpweb/src/main/webapp/WEB-INF/web.xml
new file mode 100755
index 0000000..2a13327
--- /dev/null
+++ b/apps/bgpflowspec/bgpweb/src/main/webapp/WEB-INF/web.xml
@@ -0,0 +1,38 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright 2016-present Open Networking Laboratory
+  ~
+  ~ Licensed 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.
+  -->
+<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee"
+         xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
+         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
+         id="ONOS" version="2.5">
+    <display-name>BGP REST API v1.0</display-name>
+
+
+    <servlet>
+        <servlet-name>JAX-RS Service</servlet-name>
+        <servlet-class>org.glassfish.jersey.servlet.ServletContainer</servlet-class>
+        <init-param>
+            <param-name>javax.ws.rs.Application</param-name>
+            <param-value>org.onosproject.bgpweb.resources.BgpWebApplication</param-value>
+        </init-param>
+        <load-on-startup>1</load-on-startup>
+    </servlet>
+
+    <servlet-mapping>
+        <servlet-name>JAX-RS Service</servlet-name>
+        <url-pattern>/*</url-pattern>
+    </servlet-mapping>
+</web-app>
diff --git a/apps/bgpflowspec/flowapi/BUCK b/apps/bgpflowspec/flowapi/BUCK
new file mode 100755
index 0000000..2686bce
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/BUCK
@@ -0,0 +1,19 @@
+COMPILE_DEPS = [
+    '//utils/osgi:onlab-osgi',
+    '//utils/misc:onlab-misc',
+    '//lib:commons-io',
+    '//lib:guava',
+    '//lib:kryo',
+    '//lib:slf4j-api',
+]
+
+TEST_DEPS = [
+    '//lib:TEST_ADAPTERS',
+]
+
+osgi_jar_with_tests (
+    name = 'onos-apps-bgpflowspec-flowapi',
+    deps = COMPILE_DEPS,
+    test_deps = TEST_DEPS,
+    visibility = ['PUBLIC'],
+)
diff --git a/apps/bgpflowspec/flowapi/pom.xml b/apps/bgpflowspec/flowapi/pom.xml
new file mode 100755
index 0000000..01cb23b
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/pom.xml
@@ -0,0 +1,47 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright 2016-present Open Networking Laboratory
+  ~
+  ~ Licensed 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.
+  -->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.onosproject</groupId>
+        <artifactId>onos-app-bgpflow</artifactId>
+        <version>1.6.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>onos-app-bgp-flowapi</artifactId>
+    <packaging>bundle</packaging>
+
+    <description>api bundle to be accessible across the layers</description>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onlab-misc</artifactId>
+            <version>1.6.0-SNAPSHOT</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava-testlib</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtDscpValue.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtDscpValue.java
new file mode 100755
index 0000000..987c455
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtDscpValue.java
@@ -0,0 +1,111 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * DSCP value extension implementation.
+ */
+public class DefaultExtDscpValue implements ExtDscpValue {
+
+    private List<ExtOperatorValue> dscpValue;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtDscpValue which contains dscp operator value list.
+     *
+     * @param dscpValue is a dscp value rule list
+     * @param type ExtType type
+     */
+    DefaultExtDscpValue(List<ExtOperatorValue> dscpValue, ExtType type) {
+        this.dscpValue = dscpValue;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<ExtOperatorValue> dscpValue() {
+        return dscpValue;
+    }
+
+    @Override
+    public boolean exactMatch(ExtDscpValue value) {
+        return this.equals(value) &&
+                Objects.equals(this.dscpValue, value.dscpValue())
+                && Objects.equals(this.type, value.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(dscpValue, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtDscpValue) {
+            DefaultExtDscpValue that = (DefaultExtDscpValue) obj;
+            return Objects.equals(dscpValue, that.dscpValue())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("dscpValue", dscpValue.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension dscp value.
+     */
+    public static class Builder implements ExtDscpValue.Builder {
+        private List<ExtOperatorValue> dscpValue;
+        private ExtType type;
+
+        @Override
+        public Builder setDscpValue(List<ExtOperatorValue> dscpValue) {
+            this.dscpValue = dscpValue;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtDscpValue build() {
+            checkNotNull(dscpValue, "dscpValue cannot be null");
+            return new DefaultExtDscpValue(dscpValue, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtFragment.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtFragment.java
new file mode 100755
index 0000000..fba5446
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtFragment.java
@@ -0,0 +1,111 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Fragment extension implementation.
+ */
+public class DefaultExtFragment implements ExtFragment {
+
+    private List<ExtOperatorValue> fragment;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtFragment which contains fragment operator value list.
+     *
+     * @param fragment is a fragment value rule list
+     * @param type ExtType type
+     */
+    DefaultExtFragment(List<ExtOperatorValue> fragment, ExtType type) {
+        this.fragment = fragment;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<ExtOperatorValue> fragment() {
+        return fragment;
+    }
+
+    @Override
+    public boolean exactMatch(ExtFragment value) {
+        return this.equals(value) &&
+                Objects.equals(this.fragment, value.fragment())
+                && Objects.equals(this.type, value.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(fragment, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtFragment) {
+            DefaultExtFragment that = (DefaultExtFragment) obj;
+            return Objects.equals(fragment, that.fragment())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("fragment", fragment.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension fragment value.
+     */
+    public static class Builder implements ExtFragment.Builder {
+        private List<ExtOperatorValue> fragment;
+        private ExtType type;
+
+        @Override
+        public Builder setFragment(List<ExtOperatorValue> fragment) {
+            this.fragment = fragment;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtFragment build() {
+            checkNotNull(fragment, "fragment cannot be null");
+            return new DefaultExtFragment(fragment, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIcmpCode.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIcmpCode.java
new file mode 100755
index 0000000..46632d5
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIcmpCode.java
@@ -0,0 +1,111 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Icmp code extension implementation.
+ */
+public class DefaultExtIcmpCode implements ExtIcmpCode {
+
+    private List<ExtOperatorValue> icmpCode;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtIcmpCode which contains ICMP code operator value list.
+     *
+     * @param icmpCode is a icmp code rule list
+     * @param type ExtType type
+     */
+    DefaultExtIcmpCode(List<ExtOperatorValue> icmpCode, ExtType type) {
+        this.icmpCode = icmpCode;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<ExtOperatorValue> icmpCode() {
+        return icmpCode;
+    }
+
+    @Override
+    public boolean exactMatch(ExtIcmpCode icmpCode) {
+        return this.equals(icmpCode) &&
+                Objects.equals(this.icmpCode, icmpCode.icmpCode())
+                && Objects.equals(this.type, icmpCode.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(icmpCode, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtIcmpCode) {
+            DefaultExtIcmpCode that = (DefaultExtIcmpCode) obj;
+            return Objects.equals(icmpCode, that.icmpCode())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("icmpCode", icmpCode.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension icmp type.
+     */
+    public static class Builder implements ExtIcmpCode.Builder {
+        private List<ExtOperatorValue> icmpCode;
+        private ExtType type;
+
+        @Override
+        public Builder setIcmpCode(List<ExtOperatorValue> icmpCode) {
+            this.icmpCode = icmpCode;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtIcmpCode build() {
+            checkNotNull(icmpCode, "icmpCode cannot be null");
+            return new DefaultExtIcmpCode(icmpCode, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIcmpType.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIcmpType.java
new file mode 100755
index 0000000..3b5d723
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIcmpType.java
@@ -0,0 +1,111 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Icmp type extension implementation.
+ */
+public class DefaultExtIcmpType implements ExtIcmpType {
+
+    private List<ExtOperatorValue> icmpType;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtIcmpType which contains ICMP type operator value list.
+     *
+     * @param icmpType is a icmp type rule list
+     * @param type ExtType type
+     */
+    DefaultExtIcmpType(List<ExtOperatorValue> icmpType, ExtType type) {
+        this.icmpType = icmpType;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<ExtOperatorValue> icmpType() {
+        return icmpType;
+    }
+
+    @Override
+    public boolean exactMatch(ExtIcmpType icmpType) {
+        return this.equals(icmpType) &&
+                Objects.equals(this.icmpType, icmpType.icmpType())
+                && Objects.equals(this.type, icmpType.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(icmpType, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtIcmpType) {
+            DefaultExtIcmpType that = (DefaultExtIcmpType) obj;
+            return Objects.equals(icmpType, that.icmpType())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("icmpType", icmpType.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension icmp type.
+     */
+    public static class Builder implements ExtIcmpType.Builder {
+        private List<ExtOperatorValue> icmpType;
+        private ExtType type;
+
+        @Override
+        public Builder setIcmpType(List<ExtOperatorValue> icmpType) {
+            this.icmpType = icmpType;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtIcmpType build() {
+            checkNotNull(icmpType, "icmpType cannot be null");
+            return new DefaultExtIcmpType(icmpType, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIpProtocol.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIpProtocol.java
new file mode 100755
index 0000000..d1e0e22
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtIpProtocol.java
@@ -0,0 +1,112 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Ip protocol extension implementation.
+ */
+public final class DefaultExtIpProtocol implements ExtIpProtocol {
+
+    private List<ExtOperatorValue> ipProtocol;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtIpProtocol which contains Ip protocol list.
+     *
+     * @param ipProtocol Ip protocol operator value list
+     * @param type BgpType type
+     */
+    DefaultExtIpProtocol(List<ExtOperatorValue> ipProtocol, ExtType type) {
+        this.ipProtocol = ipProtocol;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<ExtOperatorValue> ipProtocol() {
+        return ipProtocol;
+    }
+
+    @Override
+    public boolean exactMatch(ExtIpProtocol ipProto) {
+        return this.equals(ipProto) &&
+                Objects.equals(this.ipProtocol, ipProto.ipProtocol())
+                && Objects.equals(this.type, ipProto.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(ipProtocol, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtIpProtocol) {
+            DefaultExtIpProtocol that = (DefaultExtIpProtocol) obj;
+            return Objects.equals(ipProtocol, that.ipProtocol())
+                    && Objects.equals(this.type, that.type);
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("ipProtocol", ipProtocol.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension Ip protocol.
+     */
+    public static class Builder implements ExtIpProtocol.Builder {
+        private List<ExtOperatorValue> ipProtocol;
+        private ExtType type;
+
+        @Override
+        public Builder setIpProtocol(List<ExtOperatorValue> ipProtocol) {
+            this.ipProtocol = ipProtocol;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtIpProtocol build() {
+            checkNotNull(ipProtocol, "Ip protocol cannot be null");
+            return new DefaultExtIpProtocol(ipProtocol, type);
+        }
+    }
+}
+
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtKeyName.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtKeyName.java
new file mode 100755
index 0000000..0b9e18d
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtKeyName.java
@@ -0,0 +1,109 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.Objects;
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Key Name for the extension implementation.
+ */
+public class DefaultExtKeyName implements ExtKeyName {
+
+    private String keyName;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtKeyName which name for the flow rule.
+     *
+     * @param keyName is a key for the extended rule
+     * @param type ExtType type
+     */
+    DefaultExtKeyName(String keyName, ExtType type) {
+        this.keyName = keyName;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public String keyName() {
+        return keyName;
+    }
+
+    @Override
+    public boolean exactMatch(ExtKeyName value) {
+        return this.equals(value) &&
+                Objects.equals(this.keyName, value.keyName())
+                && Objects.equals(this.type, value.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(keyName, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtKeyName) {
+            DefaultExtKeyName that = (DefaultExtKeyName) obj;
+            return Objects.equals(keyName, that.keyName())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("keyName", keyName.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for Extended key name for the rule.
+     */
+    public static class Builder implements ExtKeyName.Builder {
+        private String keyName;
+        private ExtType type;
+
+        @Override
+        public Builder setKeyName(String keyName) {
+            this.keyName = keyName;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtKeyName build() {
+            checkNotNull(keyName, "keyName cannot be null");
+            return new DefaultExtKeyName(keyName, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPacketLength.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPacketLength.java
new file mode 100755
index 0000000..3d3c501
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPacketLength.java
@@ -0,0 +1,111 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Packet length extension implementation.
+ */
+public class DefaultExtPacketLength implements ExtPacketLength {
+
+    private List<ExtOperatorValue> packetLength;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtPacketLength which contains packet length list..
+     *
+     * @param packetLength is a packet length rule
+     * @param type ExtType type
+     */
+    DefaultExtPacketLength(List<ExtOperatorValue> packetLength, ExtType type) {
+        this.packetLength = packetLength;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<ExtOperatorValue> packetLength() {
+        return packetLength;
+    }
+
+    @Override
+    public boolean exactMatch(ExtPacketLength length) {
+        return this.equals(packetLength) &&
+                Objects.equals(this.packetLength, length.packetLength())
+                && Objects.equals(this.type, length.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(packetLength, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtPacketLength) {
+            DefaultExtPacketLength that = (DefaultExtPacketLength) obj;
+            return Objects.equals(packetLength, that.packetLength())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("packetLength", packetLength.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension packet length.
+     */
+    public static class Builder implements ExtPacketLength.Builder {
+        private List<ExtOperatorValue> packetLength;
+        private ExtType type;
+
+        @Override
+        public Builder setPacketLength(List<ExtOperatorValue> packetLength) {
+            this.packetLength = packetLength;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtPacketLength build() {
+            checkNotNull(packetLength, "packetLength cannot be null");
+            return new DefaultExtPacketLength(packetLength, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPort.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPort.java
new file mode 100755
index 0000000..65c7297
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPort.java
@@ -0,0 +1,111 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Port extension implementation.
+ */
+public class DefaultExtPort implements ExtPort {
+
+    private List<ExtOperatorValue> port;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtPort which contains port list.
+     *
+     * @param port is a port rule list
+     * @param type ExtType type
+     */
+    DefaultExtPort(List<ExtOperatorValue> port, ExtType type) {
+        this.port = port;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<ExtOperatorValue> port() {
+        return port;
+    }
+
+    @Override
+    public boolean exactMatch(ExtPort port) {
+        return this.equals(port) &&
+                Objects.equals(this.port, port.port())
+                && Objects.equals(this.type, port.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(port, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtPort) {
+            DefaultExtPort that = (DefaultExtPort) obj;
+            return Objects.equals(port, that.port())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("port", port.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension port.
+     */
+    public static class Builder implements ExtPort.Builder {
+        private List<ExtOperatorValue> port;
+        private ExtType type;
+
+        @Override
+        public Builder setPort(List<ExtOperatorValue> port) {
+            this.port = port;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtPort build() {
+            checkNotNull(port, "port cannot be null");
+            return new DefaultExtPort(port, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPrefix.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPrefix.java
new file mode 100755
index 0000000..4b152d2
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtPrefix.java
@@ -0,0 +1,115 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import org.onlab.packet.IpPrefix;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Ip prefix extension implementation.
+ */
+public final class DefaultExtPrefix implements ExtPrefix {
+
+    private List<IpPrefix> prefix;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtPrefix which contains Ip prefix list.
+     *
+     * @param prefix Ip prefix list
+     * @param type ExtType type
+     */
+    DefaultExtPrefix(List<IpPrefix> prefix, ExtType type) {
+        this.prefix = prefix;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<IpPrefix> prefix() {
+        return prefix;
+    }
+
+    @Override
+    public boolean exactMatch(ExtPrefix prefix) {
+        return this.equals(prefix) &&
+                Objects.equals(this.prefix, prefix.prefix())
+                && Objects.equals(this.type, prefix.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(prefix, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtPrefix) {
+            DefaultExtPrefix that = (DefaultExtPrefix) obj;
+            return Objects.equals(prefix, that.prefix())
+                    && Objects.equals(this.type, that.type);
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("prefix", prefix.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension Ip prefix.
+     */
+    public static class Builder implements ExtPrefix.Builder {
+        private List<IpPrefix> prefix = new ArrayList<>();
+        private ExtType type;
+
+        @Override
+        public Builder setPrefix(IpPrefix ip) {
+            this.prefix.add(ip);
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtPrefix build() {
+            checkNotNull(prefix, "Ip prefix cannot be null");
+            return new DefaultExtPrefix(prefix, type);
+        }
+    }
+}
+
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTarget.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTarget.java
new file mode 100755
index 0000000..63c8c2f
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTarget.java
@@ -0,0 +1,146 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Target local and remote speaker implementation for wide community.
+ */
+public final class DefaultExtTarget implements ExtTarget {
+
+    private ExtPrefix localSpeaker;
+    private ExtPrefix remoteSpeaker;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtTarget which contains local and remote speakers.
+     *
+     * @param localSpeaker local speaker prefix list
+     * @param remoteSpeaker remoteSpeaker speaker prefix list
+     * @param type ExtType type
+     */
+    DefaultExtTarget(ExtPrefix localSpeaker, ExtPrefix remoteSpeaker, ExtType type) {
+        this.localSpeaker = localSpeaker;
+        this.remoteSpeaker = remoteSpeaker;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    /**
+     * Returns the local speaker prefix list.
+     *
+     * @return the ExtPrefix
+     */
+    @Override
+    public ExtPrefix localSpeaker() {
+        return localSpeaker;
+    }
+
+    /**
+     * Returns the remote speaker prefix list.
+     *
+     * @return the ExtPrefix
+     */
+    @Override
+    public ExtPrefix remoteSpeaker() {
+        return remoteSpeaker;
+    }
+
+    /**
+     * Returns whether this target is an exact match to the target given
+     * in the argument.
+     *
+     * @param target other target to match
+     * @return true if the target are an exact match, otherwise false
+     */
+    @Override
+    public boolean exactMatch(ExtTarget target) {
+        return this.equals(target) &&
+                Objects.equals(this.localSpeaker, target.localSpeaker())
+                && Objects.equals(this.remoteSpeaker, target.remoteSpeaker())
+                && Objects.equals(this.type, target.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(localSpeaker, remoteSpeaker, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtTarget) {
+            DefaultExtTarget that = (DefaultExtTarget) obj;
+            return Objects.equals(localSpeaker, that.localSpeaker())
+                    && Objects.equals(remoteSpeaker, that.remoteSpeaker())
+                    && Objects.equals(this.type, that.type);
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("localSpeaker", localSpeaker)
+                .add("remoteSpeaker", remoteSpeaker)
+                .add("type", type)
+                .toString();
+    }
+
+    /**
+     * Builder class for wide community target.
+     */
+    public static class Builder implements ExtTarget.Builder {
+        private ExtPrefix localSpeaker;
+        private ExtPrefix remoteSpeaker;
+        private ExtType type;
+
+        @Override
+        public Builder setLocalSpeaker(ExtPrefix localSpeaker) {
+            this.localSpeaker = localSpeaker;
+            return this;
+        }
+
+        @Override
+        public Builder setRemoteSpeaker(ExtPrefix remoteSpeaker) {
+            this.remoteSpeaker = remoteSpeaker;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtTarget build() {
+            checkNotNull(localSpeaker, "localSpeaker cannot be null");
+            checkNotNull(remoteSpeaker, "remoteSpeaker cannot be null");
+            return new DefaultExtTarget(localSpeaker, remoteSpeaker, type);
+        }
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTcpFlag.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTcpFlag.java
new file mode 100755
index 0000000..468e528
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTcpFlag.java
@@ -0,0 +1,111 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Tcp flag extension implementation.
+ */
+public class DefaultExtTcpFlag implements ExtTcpFlag {
+
+    private List<ExtOperatorValue> tcpFlag;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtTcpFlag which contains tcp flag.
+     *
+     * @param tcpFlag is a Tcp Flag rule list
+     * @param type ExtType type
+     */
+    DefaultExtTcpFlag(List<ExtOperatorValue> tcpFlag, ExtType type) {
+        this.tcpFlag = tcpFlag;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<ExtOperatorValue> tcpFlag() {
+        return tcpFlag;
+    }
+
+    @Override
+    public boolean exactMatch(ExtTcpFlag flag) {
+        return this.equals(tcpFlag) &&
+                Objects.equals(this.tcpFlag, flag.tcpFlag())
+                && Objects.equals(this.type, flag.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(tcpFlag, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtTcpFlag) {
+            DefaultExtTcpFlag that = (DefaultExtTcpFlag) obj;
+            return Objects.equals(tcpFlag, that.tcpFlag())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("tcpFlag", tcpFlag.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extension tcp flag.
+     */
+    public static class Builder implements ExtTcpFlag.Builder {
+        private List<ExtOperatorValue> tcpFlag;
+        private ExtType type;
+
+        @Override
+        public Builder setTcpFlag(List<ExtOperatorValue> tcpFlag) {
+            this.tcpFlag = tcpFlag;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtTcpFlag build() {
+            checkNotNull(tcpFlag, "tcpFlag cannot be null");
+            return new DefaultExtTcpFlag(tcpFlag, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficAction.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficAction.java
new file mode 100755
index 0000000..1a2bc27
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficAction.java
@@ -0,0 +1,148 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Extended traffic action implementation.
+ */
+public class DefaultExtTrafficAction implements ExtTrafficAction {
+
+    private boolean terminal;
+    private boolean sample;
+    private boolean rpd;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtTrafficAction which contains traffic action flag.
+     *
+     * @param terminal traffic action terminal bit
+     * @param sample is a traffic action sampling
+     * @param rpd traffic action rpd bit
+     * @param type ExtType type
+     */
+    DefaultExtTrafficAction(boolean terminal, boolean sample, boolean rpd, ExtType type) {
+        this.terminal = terminal;
+        this.sample = sample;
+        this.rpd = rpd;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public boolean terminal() {
+        return terminal;
+    }
+
+    @Override
+    public boolean sample() {
+        return sample;
+    }
+
+    @Override
+    public boolean rpd() {
+        return rpd;
+    }
+
+    @Override
+    public boolean exactMatch(ExtTrafficAction value) {
+        return this.equals(value) &&
+                Objects.equals(this.terminal, value.terminal())
+                && Objects.equals(this.sample, value.sample())
+                && Objects.equals(this.rpd, value.rpd())
+                && Objects.equals(this.type, value.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(terminal, sample, rpd, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtTrafficAction) {
+            DefaultExtTrafficAction that = (DefaultExtTrafficAction) obj;
+            return Objects.equals(terminal, that.terminal())
+                    && Objects.equals(this.sample, that.sample())
+                    && Objects.equals(this.rpd, that.rpd())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("terminal", Boolean.valueOf(terminal).toString())
+                .add("sample",  Boolean.valueOf(sample).toString())
+                .add("rpd",  Boolean.valueOf(rpd).toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extended traffic rate rule.
+     */
+    public static class Builder implements ExtTrafficAction.Builder {
+        private boolean terminal;
+        private boolean sample;
+        private boolean rpd;
+        private ExtType type;
+
+        @Override
+        public Builder setTerminal(boolean terminal) {
+            this.terminal = terminal;
+            return this;
+        }
+
+        @Override
+        public Builder setSample(boolean sample) {
+            this.sample = sample;
+            return this;
+        }
+
+        @Override
+        public Builder setRpd(boolean rpd) {
+            this.rpd = rpd;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtTrafficAction build() {
+            checkNotNull(terminal, "terminal cannot be null");
+            checkNotNull(sample, "sample cannot be null");
+            checkNotNull(rpd, "rpd cannot be null");
+            return new DefaultExtTrafficAction(terminal, sample, rpd, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficMarking.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficMarking.java
new file mode 100755
index 0000000..d014710
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficMarking.java
@@ -0,0 +1,110 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Extended traffic marking implementation.
+ */
+public class DefaultExtTrafficMarking implements ExtTrafficMarking {
+
+    private byte marking;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtTrafficMarking which contains traffic marking byte.
+     *
+     * @param marking is a marking rule
+     * @param type ExtType type
+     */
+    DefaultExtTrafficMarking(byte marking, ExtType type) {
+        this.marking = marking;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public byte marking() {
+        return marking;
+    }
+
+    @Override
+    public boolean exactMatch(ExtTrafficMarking value) {
+        return this.equals(value) &&
+                Objects.equals(this.marking, value.marking())
+                && Objects.equals(this.type, value.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(marking, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtTrafficMarking) {
+            DefaultExtTrafficMarking that = (DefaultExtTrafficMarking) obj;
+            return Objects.equals(marking, that.marking())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("marking", marking)
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extended traffic marking value rule.
+     */
+    public static class Builder implements ExtTrafficMarking.Builder {
+        private byte marking;
+        private ExtType type;
+
+        @Override
+        public Builder setMarking(byte marking) {
+            this.marking = marking;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtTrafficMarking build() {
+            checkNotNull(marking, "marking cannot be null");
+            return new DefaultExtTrafficMarking(marking, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficRate.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficRate.java
new file mode 100755
index 0000000..fc4b2bf
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficRate.java
@@ -0,0 +1,129 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Extended traffic rate implementation.
+ */
+public class DefaultExtTrafficRate implements ExtTrafficRate {
+
+    private Short asn;
+    private Float rate;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtTrafficRate which contains traffic rate action.
+     *
+     * @param asn is a AS number
+     * @param rate is a traffic rate in bytes per second
+     * @param type ExtType type
+     */
+    DefaultExtTrafficRate(short asn, float rate, ExtType type) {
+        this.asn = Short.valueOf(asn);
+        this.rate = Float.valueOf(rate);
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public Short asn() {
+        return asn;
+    }
+
+    @Override
+    public Float rate() {
+        return rate;
+    }
+
+    @Override
+    public boolean exactMatch(ExtTrafficRate value) {
+        return this.equals(value) &&
+                Objects.equals(this.asn, value.asn())
+                && Objects.equals(this.rate, value.rate())
+                && Objects.equals(this.type, value.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(asn, rate, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtTrafficRate) {
+            DefaultExtTrafficRate that = (DefaultExtTrafficRate) obj;
+            return Objects.equals(asn, that.asn())
+                    && Objects.equals(this.rate, that.rate())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("asn", asn.toString())
+                .add("rate", rate.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extended traffic rate rule.
+     */
+    public static class Builder implements ExtTrafficRate.Builder {
+        private Short asn;
+        private Float rate;
+        private ExtType type;
+
+        @Override
+        public Builder setAsn(short asn) {
+            this.asn = Short.valueOf(asn);
+            return this;
+        }
+
+        @Override
+        public Builder setRate(float rate) {
+            this.rate = Float.valueOf(rate);
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtTrafficRate build() {
+            checkNotNull(asn, "asn cannot be null");
+            checkNotNull(rate, "rate cannot be null");
+            return new DefaultExtTrafficRate(asn, rate, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficRedirect.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficRedirect.java
new file mode 100755
index 0000000..2a45d06
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtTrafficRedirect.java
@@ -0,0 +1,110 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Extended traffic redirect implementation.
+ */
+public class DefaultExtTrafficRedirect implements ExtTrafficRedirect {
+
+    private String redirect;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtTrafficRedirect which contains traffic redirect action.
+     *
+     * @param redirect is a redirect rule
+     * @param type ExtType type
+     */
+    DefaultExtTrafficRedirect(String redirect, ExtType type) {
+        this.redirect = redirect;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public String redirect() {
+        return redirect;
+    }
+
+    @Override
+    public boolean exactMatch(ExtTrafficRedirect value) {
+        return this.equals(value) &&
+                Objects.equals(this.redirect, value.redirect())
+                && Objects.equals(this.type, value.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(redirect, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtTrafficRedirect) {
+            DefaultExtTrafficRedirect that = (DefaultExtTrafficRedirect) obj;
+            return Objects.equals(redirect, that.redirect())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("redirect", redirect.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for extended redirect value rule.
+     */
+    public static class Builder implements ExtTrafficRedirect.Builder {
+        private String redirect;
+        private ExtType type;
+
+        @Override
+        public Builder setRedirect(String redirect) {
+            this.redirect = redirect;
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtTrafficRedirect build() {
+            checkNotNull(redirect, "redirect cannot be null");
+            return new DefaultExtTrafficRedirect(redirect, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtWideCommunityInt.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtWideCommunityInt.java
new file mode 100755
index 0000000..05ed379
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/DefaultExtWideCommunityInt.java
@@ -0,0 +1,112 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+import static com.google.common.base.MoreObjects.toStringHelper;
+import static com.google.common.base.Preconditions.checkNotNull;
+
+/**
+ * Wide community attributes for RPD implementation.
+ */
+public class DefaultExtWideCommunityInt implements ExtWideCommunityInt {
+
+    private List<Integer> wCommInt;
+    private ExtType type;
+
+    /**
+     * Creates an object of type DefaultExtWideCommunityInt which contains wide community attributes.
+     *
+     * @param wCommInt is a wide community value
+     * @param type ExtType type
+     */
+    DefaultExtWideCommunityInt(List<Integer> wCommInt, ExtType type) {
+        this.wCommInt = wCommInt;
+        this.type = type;
+    }
+
+    @Override
+    public ExtType type() {
+        return type;
+    }
+
+    @Override
+    public List<Integer> communityInt() {
+        return wCommInt;
+    }
+
+    @Override
+    public boolean exactMatch(ExtWideCommunityInt value) {
+        return this.equals(value) &&
+                Objects.equals(this.wCommInt, value.communityInt())
+                && Objects.equals(this.type, value.type());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(wCommInt, type);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof DefaultExtWideCommunityInt) {
+            DefaultExtWideCommunityInt that = (DefaultExtWideCommunityInt) obj;
+            return Objects.equals(wCommInt, that.communityInt())
+                    && Objects.equals(this.type, that.type());
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return toStringHelper(this)
+                .add("value", wCommInt.toString())
+                .add("type", type.toString())
+                .toString();
+    }
+
+    /**
+     * Builder class for wide community value rule.
+     */
+    public static class Builder implements ExtWideCommunityInt.Builder {
+        private List<Integer> wCommInt = new ArrayList<>();
+        private ExtType type;
+
+        @Override
+        public Builder setwCommInt(Integer wCommInt) {
+            this.wCommInt.add(wCommInt);
+            return this;
+        }
+
+        @Override
+        public Builder setType(ExtType type) {
+            this.type = type;
+            return this;
+        }
+
+        @Override
+        public ExtWideCommunityInt build() {
+            checkNotNull(wCommInt, "value cannot be null");
+            return new DefaultExtWideCommunityInt(wCommInt, type);
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtDscpValue.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtDscpValue.java
new file mode 100755
index 0000000..55b7150
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtDscpValue.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended multivalue Dscp value class.
+ */
+public interface ExtDscpValue extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the dscp value operator value list.
+     *
+     * @return the dscp value operator value list
+     */
+    List<ExtOperatorValue> dscpValue();
+
+    /**
+     * Returns whether this dscp value list is an exact match to the dscp value list given
+     * in the argument.
+     *
+     * @param dscpValue other dscp value to match against
+     * @return true if the dscp value list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtDscpValue dscpValue);
+
+    /**
+     * A dscp value extended builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the dscp operator value to this object.
+         *
+         * @param dscpValue the dscp value
+         * @return this the builder object
+         */
+        Builder setDscpValue(List<ExtOperatorValue> dscpValue);
+
+        /**
+         * Builds a dscp value object.
+         *
+         * @return a dscp value object.
+         */
+        ExtDscpValue build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFlowContainer.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFlowContainer.java
new file mode 100755
index 0000000..14f493c
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFlowContainer.java
@@ -0,0 +1,118 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.base.MoreObjects;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+/**
+ * Representation of Multi value flow container having custom rules.
+ */
+public final class ExtFlowContainer {
+
+    private List<ExtFlowTypes> container = new ArrayList<>();
+    private String deviceId;
+
+    /**
+     * Creates an object of type ExtFlowContainer.
+     */
+    public ExtFlowContainer(List<ExtFlowTypes> container) {
+        this.container = container;
+    }
+
+    /**
+     * Returns the ExtFlowContainer by setting its value.
+     *
+     * @return ExtFlowContainer
+     */
+    public static ExtFlowContainer of(List<ExtFlowTypes> container) {
+        return new ExtFlowContainer(container);
+    }
+
+    /**
+     * Returns the list of  ExtFlowTypes value.
+     *
+     * @return list of ExtFlowTypes
+     */
+    public List<ExtFlowTypes> container() {
+        return container;
+    }
+
+    /**
+     * Returns the device Id.
+     *
+     * @return deviceId
+     */
+    public String deviceId() {
+        return deviceId;
+    }
+
+    /**
+     * Adds the flow type to the container list.
+     *
+     * @param  obj of ExtFlowTypes type
+     */
+    public void add(ExtFlowTypes obj) {
+        container.add(obj);
+    }
+
+    /**
+     * Removes the flow type from the container list.
+     *
+     * @param  obj of ExtFlowTypes type
+     */
+    public void remove(ExtFlowTypes obj) {
+        container.remove(obj);
+    }
+
+    /**
+     * Sets the device Id to this container.
+     *
+     * @param deviceId to be set to this container
+     */
+    public void setDeviceId(String deviceId) {
+        this.deviceId = deviceId;
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(container);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (!(obj instanceof ExtFlowContainer)) {
+            return false;
+        }
+        final ExtFlowContainer other = (ExtFlowContainer) obj;
+        return Objects.equals(this.container, other.container)
+                && Objects.equals(this.deviceId, other.deviceId);
+    }
+
+    @Override
+    public String toString() {
+        return MoreObjects.toStringHelper(this)
+                .add("container", container)
+                .add("deviceId", deviceId)
+                .toString();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFlowTypes.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFlowTypes.java
new file mode 100755
index 0000000..777598c
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFlowTypes.java
@@ -0,0 +1,120 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+/**
+ * Representation of BgpFlow container having custom rules.
+ */
+public interface ExtFlowTypes {
+
+    /**
+     * Bgp types.
+     */
+    public enum ExtType {
+
+        /** Extended flow rule key. */
+        EXT_FLOW_RULE_KEY(0),
+
+        /** IPv4 destination address. */
+        IPV4_DST_PFX(1),
+
+        /** IPv4 source address. */
+        IPV4_SRC_PFX(2),
+
+        /** IP protocol list. */
+        IP_PROTO_LIST(3),
+
+        /** Input port list. */
+        IN_PORT_LIST(4),
+
+        /** Destination port list. */
+        DST_PORT_LIST(5),
+
+        /** Source port list. */
+        SRC_PORT_LIST(6),
+
+        /** ICMP type list. */
+        ICMP_TYPE_LIST(7),
+
+        /** ICMP code list. */
+        ICMP_CODE_LIST(8),
+
+        /** TCP flag list. */
+        TCP_FLAG_LIST(9),
+
+        /** Packet length list. */
+        PACKET_LENGTH_LIST(10),
+
+        /** DSCP Value component. */
+        DSCP_VALUE_LIST(11),
+
+        /** Fragment list. */
+        FRAGMENT_LIST(12),
+
+        /** Wide community flags. */
+        WIDE_COMM_FLAGS(13),
+
+        /** Wide community hop count. */
+        WIDE_COMM_HOP_COUNT(14),
+
+        /** Wide community community attribute. */
+        WIDE_COMM_COMMUNITY(15),
+
+        /** Wide community context AS. */
+        WIDE_COMM_CONTEXT_AS(16),
+
+        /** Wide community local AS. */
+        WIDE_COMM_LOCAL_AS(17),
+
+        /** Wide community target prefixes. */
+        WIDE_COMM_TARGET(18),
+
+        /** Wide community extended target prefixes. */
+        WIDE_COMM_EXT_TARGET(19),
+
+        /** Wide community parameter. */
+        WIDE_COMM_PARAMETER(20),
+
+        /** Traffic filtering actions. */
+
+        TRAFFIC_RATE(0x8006),
+        TRAFFIC_ACTION(0x8007),
+        TRAFFIC_REDIRECT(0x8008),
+        TRAFFIC_MARKING(0x8009);
+
+        private int type;
+
+        /**
+         * Creates a new type.
+         *
+         * @param type type code
+         */
+        ExtType(int type) {
+            this.type = type;
+        }
+
+        /**
+         * Returns the type object for this type code.
+         *
+         * @return ExtType object
+         */
+        public int type() {
+            return (type);
+        }
+    }
+
+    ExtType type();
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFragment.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFragment.java
new file mode 100755
index 0000000..8a606e8
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtFragment.java
@@ -0,0 +1,77 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended multivalue Fragment value list class.
+ */
+public interface ExtFragment extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the fragment operator value list.
+     *
+     * @return the fragment operator value list
+     */
+    List<ExtOperatorValue> fragment();
+
+    /**
+     * Returns whether this fragment value list is an exact match to the fragment value list given
+     * in the argument.
+     *
+     * @param fragment other fragment value to match against
+     * @return true if the fragment value list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtFragment fragment);
+
+    /**
+     * Extended fragment value builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the fragment operator value to this object.
+         *
+         * @param fragment the fragment value
+         * @return this the builder object
+         */
+        Builder setFragment(List<ExtOperatorValue> fragment);
+
+        /**
+         * Builds a fragment value object.
+         *
+         * @return a fragment value object.
+         */
+        ExtFragment build();
+    }
+}
+
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIcmpCode.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIcmpCode.java
new file mode 100755
index 0000000..2e42aa0
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIcmpCode.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended multivalue ICMP code class.
+ */
+public interface ExtIcmpCode extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the Icmp code operator value list.
+     *
+     * @return the Icmp code operator value list
+     */
+    List<ExtOperatorValue> icmpCode();
+
+    /**
+     * Returns whether this Icmp code list is an exact match to the Icmp code list given
+     * in the argument.
+     *
+     * @param icmpCode other Icmp code to match against
+     * @return true if the Icmp code list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtIcmpCode icmpCode);
+
+    /**
+     * An Icmp code extension builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the Icmp code operator value to this object.
+         *
+         * @param icmpCode the Icmp code operator value combination
+         * @return this the builder object
+         */
+        Builder setIcmpCode(List<ExtOperatorValue> icmpCode);
+
+        /**
+         * Builds a Icmp code object.
+         *
+         * @return a Tcmp code object.
+         */
+        ExtIcmpCode build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIcmpType.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIcmpType.java
new file mode 100755
index 0000000..480c73d
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIcmpType.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2016 Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended multivalue ICMP type class.
+ */
+public interface ExtIcmpType extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the Icmp type operator value list.
+     *
+     * @return the Icmp type operator value list
+     */
+    List<ExtOperatorValue> icmpType();
+
+    /**
+     * Returns whether this Icmp type list is an exact match to the Icmp type list given
+     * in the argument.
+     *
+     * @param icmpType other Icmp type to match against
+     * @return true if the Icmp type list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtIcmpType icmpType);
+
+    /**
+     * An Icmp type extension builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the Icmp type operator value to this object.
+         *
+         * @param icmpType the Icmp type operator value combination
+         * @return this the builder object
+         */
+        Builder setIcmpType(List<ExtOperatorValue> icmpType);
+
+        /**
+         * Builds a Icmp type object.
+         *
+         * @return a Tcmp type object.
+         */
+        ExtIcmpType build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIpProtocol.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIpProtocol.java
new file mode 100755
index 0000000..bee44c0
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtIpProtocol.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended multivalue Ip protocol class.
+ */
+public interface ExtIpProtocol extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the Ip protocol operator value list.
+     *
+     * @return the Ip protocol operator value list
+     */
+    List<ExtOperatorValue> ipProtocol();
+
+    /**
+     * Returns whether this Ip protocol list is an exact match to the Ip protocol list given
+     * in the argument.
+     *
+     * @param ipProto other Ip protocols list to match against
+     * @return true if the Ip protocols list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtIpProtocol ipProto);
+
+    /**
+     * Ip protocol extension builder.
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Adds the Ip protocol operator value to this object.
+         *
+         * @param ipProto is the operator-value combination
+         * @return this the builder object
+         */
+        Builder setIpProtocol(List<ExtOperatorValue> ipProto);
+
+        /**
+         * Builds a Ip protocol object.
+         *
+         * @return a Ip protocol object.
+         */
+        ExtIpProtocol build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtKeyName.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtKeyName.java
new file mode 100755
index 0000000..4759ef3
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtKeyName.java
@@ -0,0 +1,74 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+/**
+ * Ext flwo key name class.
+ */
+public interface ExtKeyName extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the key name identifier for the flow.
+     *
+     * @return the key name
+     */
+    String keyName();
+
+    /**
+     * Returns whether this key name is an exact match to the key name given
+     * in the argument.
+     *
+     * @param key other key name to match against
+     * @return true if the key name are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtKeyName key);
+
+    /**
+     * A key name value list builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the key name to this object.
+         *
+         * @param key the key name
+         * @return this the builder object
+         */
+        Builder setKeyName(String key);
+
+        /**
+         * Builds a key name object.
+         *
+         * @return a key name object.
+         */
+        ExtKeyName build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtOperatorValue.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtOperatorValue.java
new file mode 100755
index 0000000..459b993
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtOperatorValue.java
@@ -0,0 +1,85 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.base.MoreObjects;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Arrays;
+import java.util.Objects;
+
+/**
+ * Flow specification type operator and value implementation.
+ */
+public class ExtOperatorValue {
+
+    protected static final Logger log = LoggerFactory.getLogger(ExtOperatorValue.class);
+
+    private final byte option;
+    private final byte[] value;
+
+    /**
+     * Creates an object of type ExtOperatorValue.
+     *
+     * @param option for a specific flow type
+     * @param value for a specific flow type
+     */
+    public ExtOperatorValue(byte option, byte[] value) {
+        this.option = option;
+        this.value = Arrays.copyOf(value, value.length);
+    }
+
+    /**
+     * Returns option of the flow type.
+     *
+     * @return option of the flow type
+     */
+    public byte option() {
+        return option;
+    }
+
+    /**
+     * Returns value of the flow type.
+     *
+     * @return value of the flow type
+     */
+    public byte[] value() {
+        return value;
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(option, Arrays.hashCode(value));
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (this == obj) {
+            return true;
+        }
+        if (obj instanceof ExtOperatorValue) {
+            ExtOperatorValue other = (ExtOperatorValue) obj;
+            return Objects.equals(this.option, other.option) && Arrays.equals(this.value, other.value);
+        }
+        return false;
+    }
+
+    @Override
+    public String toString() {
+        return MoreObjects.toStringHelper(getClass()).add("option", option).add("value", value).toString();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPacketLength.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPacketLength.java
new file mode 100755
index 0000000..6c3dedf
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPacketLength.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended multivalue packet length list class.
+ */
+public interface ExtPacketLength extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the packet length operator value list.
+     *
+     * @return the packet length operator value list
+     */
+    List<ExtOperatorValue> packetLength();
+
+    /**
+     * Returns whether this packet length list is an exact match to the packet length list given
+     * in the argument.
+     *
+     * @param packetLength other packet length to match against
+     * @return true if the packet length list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtPacketLength packetLength);
+
+    /**
+     * A packet length extended builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the packet length list to this object.
+         *
+         * @param packetLength the packet length
+         * @return this the builder object
+         */
+        Builder setPacketLength(List<ExtOperatorValue> packetLength);
+
+        /**
+         * Builds a packet length object.
+         *
+         * @return a packet length object.
+         */
+        ExtPacketLength build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPort.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPort.java
new file mode 100755
index 0000000..a84b8e7
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPort.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended multivalue port class.
+ */
+public interface ExtPort extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the port operator value list.
+     *
+     * @return the port operator value list
+     */
+    List<ExtOperatorValue> port();
+
+    /**
+     * Returns whether this port list is an exact match to the port list given
+     * in the argument.
+     *
+     * @param port other port to match against
+     * @return true if the port list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtPort port);
+
+    /**
+     * An extended port extension builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the port list operator value to this object.
+         *
+         * @param port is the operator-value combination
+         * @return this the builder object
+         */
+        Builder setPort(List<ExtOperatorValue> port);
+
+        /**
+         * Builds a port object.
+         *
+         * @return a port object.
+         */
+        ExtPort build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPrefix.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPrefix.java
new file mode 100755
index 0000000..3539ef2
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtPrefix.java
@@ -0,0 +1,78 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import org.onlab.packet.IpPrefix;
+
+import java.util.List;
+
+/**
+ * Ext Prefix class.
+ */
+public interface ExtPrefix extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the prefix list.
+     *
+     * @return the IpPrefix list
+     */
+    List<IpPrefix> prefix();
+
+    /**
+     * Returns whether this prefix list is an exact match to the prefix list given
+     * in the argument.
+     *
+     * @param prefix other prefix to match against
+     * @return true if the prefix are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtPrefix prefix);
+
+    /**
+     * A prefix builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type the prefix
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Add the prefix to this object.
+         *
+         * @param prefix the prefix
+         * @return this the builder object
+         */
+        Builder setPrefix(IpPrefix prefix);
+
+        /**
+         * Builds a prefix object.
+         *
+         * @return a port chain.
+         */
+        ExtPrefix build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTarget.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTarget.java
new file mode 100755
index 0000000..157ce9a
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTarget.java
@@ -0,0 +1,89 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+/**
+ * Ext target prefix class class.
+ */
+public interface ExtTarget extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the local speaker prefix list.
+     *
+     * @return the prefix list
+     */
+    ExtPrefix localSpeaker();
+
+    /**
+     * Returns the remote speaker prefix list.
+     *
+     * @return the prefix list
+     */
+    ExtPrefix remoteSpeaker();
+
+    /**
+     * Returns whether this prefix list is an exact match to the prefix list given
+     * in the argument.
+     *
+     * @param prefix other prefix to match against
+     * @return true if the prefix are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtTarget prefix);
+
+    /**
+     * A prefix builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type the prefix
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Add the local speaker prefix to this object.
+         *
+         * @param localSpeaker list of local speakers
+         * @return this the builder object
+         */
+        Builder setLocalSpeaker(ExtPrefix localSpeaker);
+
+        /**
+         * Add the remote speaker prefix to this object.
+         *
+         * @param remoteSpeaker list of remote speakers
+         * @return this the builder object
+         */
+        Builder setRemoteSpeaker(ExtPrefix remoteSpeaker);
+
+        /**
+         * Builds a prefix object.
+         *
+         * @return a port chain.
+         */
+        ExtTarget build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTcpFlag.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTcpFlag.java
new file mode 100755
index 0000000..17e5145
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTcpFlag.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended multivalue Tcp Flags list class.
+ */
+public interface ExtTcpFlag extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the Tcp flag Extended multivalue.
+     *
+     * @return the Tcp flag Extended multivalue
+     */
+    List<ExtOperatorValue> tcpFlag();
+
+    /**
+     * Returns whether this Tcp flag list is an exact match to the Tcp flag list given
+     * in the argument.
+     *
+     * @param tcpFlag other Tcp flag to match against
+     * @return true if the Tcp flag list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtTcpFlag tcpFlag);
+
+    /**
+     * A Tcp flag extended builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the Tcp flag operator value to this object.
+         *
+         * @param tcpFlag the Tcp flag
+         * @return this the builder object
+         */
+        Builder setTcpFlag(List<ExtOperatorValue> tcpFlag);
+
+        /**
+         * Builds a Tcp flag object.
+         *
+         * @return a Tcp flag object.
+         */
+        ExtTcpFlag build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficAction.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficAction.java
new file mode 100755
index 0000000..170cd6c
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficAction.java
@@ -0,0 +1,104 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+/**
+ * Extended flow traffic action class.
+ */
+public interface ExtTrafficAction extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the terminal action.
+     *
+     * @return the terminal action is set or not
+     */
+    boolean terminal();
+
+    /**
+     * Returns the traffic sampling.
+     *
+     * @return the traffic sampling set or not
+     */
+    boolean sample();
+
+    /**
+     * Returns the traffic action to be taken is rpd.
+     *
+     * @return the traffic action rpd is set or not
+     */
+    boolean rpd();
+
+    /**
+     * Returns whether this traffic action is an exact match to the traffic action given
+     * in the argument.
+     *
+     * @param trafficAction other traffic action to match against
+     * @return true if the traffic action are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtTrafficAction trafficAction);
+
+    /**
+     * A traffic action builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the terminal action to this object.
+         *
+         * @param terminal action
+         * @return this the builder object
+         */
+        Builder setTerminal(boolean terminal);
+
+        /**
+         * Assigns the traffic sampling to this object.
+         *
+         * @param sample to be done or not
+         * @return this the builder object
+         */
+        Builder setSample(boolean sample);
+
+        /**
+         * Assigns the traffic action rpd to this object.
+         *
+         * @param rpd rpd or not
+         * @return this the builder object
+         */
+        Builder setRpd(boolean rpd);
+
+        /**
+         * Builds a traffic action object.
+         *
+         * @return a traffic action object.
+         */
+        ExtTrafficAction build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficMarking.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficMarking.java
new file mode 100755
index 0000000..ee43ba0
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficMarking.java
@@ -0,0 +1,74 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+/**
+ * Extended traffic marking class.
+ */
+public interface ExtTrafficMarking extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the traffic marking DSCP value.
+     *
+     * @return the marking rule
+     */
+    byte marking();
+
+    /**
+     * Returns whether this traffic marking is an exact match to the traffic marking given
+     * in the argument.
+     *
+     * @param marking other traffic marking to match against
+     * @return true if the traffic marking are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtTrafficMarking marking);
+
+    /**
+     * A traffic marking builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the traffic marking to this object.
+         *
+         * @param marking the marking value
+         * @return this the builder object
+         */
+        Builder setMarking(byte marking);
+
+        /**
+         * Builds a traffic marking object.
+         *
+         * @return a marking value object.
+         */
+        ExtTrafficMarking build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficRate.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficRate.java
new file mode 100755
index 0000000..a903fb7
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficRate.java
@@ -0,0 +1,89 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+/**
+ * Extended flow traffic rate class.
+ */
+public interface ExtTrafficRate extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the AS number.
+     *
+     * @return the 2 byte ASN
+     */
+    Short asn();
+
+    /**
+     * Returns the traffic rate.
+     *
+     * @return the floating point traffic rate
+     */
+    Float rate();
+
+    /**
+     * Returns whether this traffic rate is an exact match to the traffic rate given
+     * in the argument.
+     *
+     * @param trafficRate other traffic rate to match against
+     * @return true if the traffic rate list are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtTrafficRate trafficRate);
+
+    /**
+     * A traffic rate builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the AS number to this object.
+         *
+         * @param asn the ASN
+         * @return this the builder object
+         */
+        Builder setAsn(short asn);
+
+        /**
+         * Assigns the traffic rate to this object.
+         *
+         * @param rate in floating point number bytes per second
+         * @return this the builder object
+         */
+        Builder setRate(float rate);
+
+        /**
+         * Builds a traffic rate object.
+         *
+         * @return a traffic rate object.
+         */
+        ExtTrafficRate build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficRedirect.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficRedirect.java
new file mode 100755
index 0000000..861e667
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtTrafficRedirect.java
@@ -0,0 +1,74 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+/**
+ * Extended flow traffic redirect class.
+ */
+public interface ExtTrafficRedirect extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the traffic redirect in human readable format.
+     *
+     * @return the redirect rule
+     */
+    String redirect();
+
+    /**
+     * Returns whether this traffic redirect is an exact match to the traffic redirect given
+     * in the argument.
+     *
+     * @param redirect other traffic redirect to match against
+     * @return true if the traffic redirect are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtTrafficRedirect redirect);
+
+    /**
+     * A dscp value list builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the traffic redirect to this object.
+         *
+         * @param redirect the redirect value
+         * @return this the builder object
+         */
+        Builder setRedirect(String redirect);
+
+        /**
+         * Builds a traffic redirect object.
+         *
+         * @return a redirect value object.
+         */
+        ExtTrafficRedirect build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtWideCommunityInt.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtWideCommunityInt.java
new file mode 100755
index 0000000..cd23a77
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/ExtWideCommunityInt.java
@@ -0,0 +1,76 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import java.util.List;
+
+/**
+ * Extended wide community integer class.
+ */
+public interface ExtWideCommunityInt extends ExtFlowTypes {
+
+    /**
+     * Returns the ExtType.
+     *
+     * @return the ExtType
+     */
+    ExtType type();
+
+    /**
+     * Returns the wide community integer list.
+     *
+     * @return the wide community integer list
+     */
+    List<Integer> communityInt();
+
+    /**
+     * Returns whether this wide community integer is an exact match to the wide community int given
+     * in the argument.
+     *
+     * @param wCommInt other wide community integer to match against
+     * @return true if the wide community integer are an exact match, otherwise false
+     */
+    boolean exactMatch(ExtWideCommunityInt wCommInt);
+
+    /**
+     * A wide community integer list builder..
+     */
+    interface Builder {
+
+        /**
+         * Assigns the ExtType to this object.
+         *
+         * @param type extended type
+         * @return this the builder object
+         */
+        Builder setType(ExtType type);
+
+        /**
+         * Assigns the wide community integer to this object.
+         *
+         * @param wCommInt the wide community integer
+         * @return this the builder object
+         */
+        Builder setwCommInt(Integer wCommInt);
+
+        /**
+         * Builds a wide community integer object.
+         *
+         * @return a wide community integer value object.
+         */
+        ExtWideCommunityInt build();
+    }
+}
diff --git a/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/package-info.java b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/package-info.java
new file mode 100755
index 0000000..9abf0be
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/main/java/org/onosproject/flowapi/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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.
+ */
+
+/**
+ * API bundle.
+ */
+package org.onosproject.flowapi;
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtDscpValueTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtDscpValueTest.java
new file mode 100644
index 0000000..bd2fca5
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtDscpValueTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended dscp value attribute.
+ */
+public class DefaultExtDscpValueTest {
+
+    private List<ExtOperatorValue> dscpValue = new ArrayList<>();
+    private List<ExtOperatorValue> dscpValue1 = new ArrayList<>();
+    private ExtOperatorValue opVal = new ExtOperatorValue((byte) 1, new byte[100]);
+    private ExtOperatorValue opVal1 = new ExtOperatorValue((byte) 1, new byte[200]);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.DSCP_VALUE_LIST;
+
+    @Test
+    public void basics() {
+        dscpValue.add(opVal);
+        dscpValue1.add(opVal1);
+        DefaultExtDscpValue data = new DefaultExtDscpValue(dscpValue, type);
+        DefaultExtDscpValue sameAsData = new DefaultExtDscpValue(dscpValue, type);
+        DefaultExtDscpValue diffData = new DefaultExtDscpValue(dscpValue1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtFragmentTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtFragmentTest.java
new file mode 100644
index 0000000..df7893c
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtFragmentTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended fragment value attribute.
+ */
+public class DefaultExtFragmentTest {
+
+    private List<ExtOperatorValue> fragment = new ArrayList<>();
+    private List<ExtOperatorValue> fragment1 = new ArrayList<>();
+    private ExtOperatorValue opVal = new ExtOperatorValue((byte) 1, new byte[100]);
+    private ExtOperatorValue opVal1 = new ExtOperatorValue((byte) 1, new byte[200]);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.FRAGMENT_LIST;
+
+    @Test
+    public void basics() {
+        fragment.add(opVal);
+        fragment1.add(opVal1);
+        DefaultExtFragment data = new DefaultExtFragment(fragment, type);
+        DefaultExtFragment sameAsData = new DefaultExtFragment(fragment, type);
+        DefaultExtFragment diffData = new DefaultExtFragment(fragment1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIcmpCodeTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIcmpCodeTest.java
new file mode 100644
index 0000000..105d5bc
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIcmpCodeTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended icmp code value attribute.
+ */
+public class DefaultExtIcmpCodeTest {
+
+    private List<ExtOperatorValue> icmpCode = new ArrayList<>();
+    private List<ExtOperatorValue> icmpCode1 = new ArrayList<>();
+    private ExtOperatorValue opVal = new ExtOperatorValue((byte) 1, new byte[100]);
+    private ExtOperatorValue opVal1 = new ExtOperatorValue((byte) 1, new byte[200]);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.ICMP_CODE_LIST;
+
+    @Test
+    public void basics() {
+        icmpCode.add(opVal);
+        icmpCode1.add(opVal1);
+        DefaultExtIcmpCode data = new DefaultExtIcmpCode(icmpCode, type);
+        DefaultExtIcmpCode sameAsData = new DefaultExtIcmpCode(icmpCode, type);
+        DefaultExtIcmpCode diffData = new DefaultExtIcmpCode(icmpCode1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIcmpTypeTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIcmpTypeTest.java
new file mode 100644
index 0000000..3c313e9
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIcmpTypeTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+        import com.google.common.testing.EqualsTester;
+        import org.junit.Test;
+
+        import java.util.ArrayList;
+        import java.util.List;
+
+/**
+ * Test for extended icmp type value attribute.
+ */
+public class DefaultExtIcmpTypeTest {
+
+    private List<ExtOperatorValue> icmpType = new ArrayList<>();
+    private List<ExtOperatorValue> icmpType1 = new ArrayList<>();
+    private ExtOperatorValue opVal = new ExtOperatorValue((byte) 1, new byte[100]);
+    private ExtOperatorValue opVal1 = new ExtOperatorValue((byte) 1, new byte[200]);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.ICMP_TYPE_LIST;
+
+    @Test
+    public void basics() {
+        icmpType.add(opVal);
+        icmpType1.add(opVal1);
+        DefaultExtIcmpType data = new DefaultExtIcmpType(icmpType, type);
+        DefaultExtIcmpType sameAsData = new DefaultExtIcmpType(icmpType, type);
+        DefaultExtIcmpType diffData = new DefaultExtIcmpType(icmpType1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIpProtocolTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIpProtocolTest.java
new file mode 100644
index 0000000..4ac3685
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtIpProtocolTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended icmp type value attribute.
+ */
+public class DefaultExtIpProtocolTest {
+
+    private List<ExtOperatorValue> ipProtocol = new ArrayList<>();
+    private List<ExtOperatorValue> ipProtocol1 = new ArrayList<>();
+    private ExtOperatorValue opVal = new ExtOperatorValue((byte) 1, new byte[100]);
+    private ExtOperatorValue opVal1 = new ExtOperatorValue((byte) 1, new byte[200]);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.IP_PROTO_LIST;
+
+    @Test
+    public void basics() {
+        ipProtocol.add(opVal);
+        ipProtocol1.add(opVal1);
+        DefaultExtIpProtocol data = new DefaultExtIpProtocol(ipProtocol, type);
+        DefaultExtIpProtocol sameAsData = new DefaultExtIpProtocol(ipProtocol, type);
+        DefaultExtIpProtocol diffData = new DefaultExtIpProtocol(ipProtocol1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtKeyNameTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtKeyNameTest.java
new file mode 100644
index 0000000..64a4b97
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtKeyNameTest.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+/**
+ * Test for extended key name value attribute.
+ */
+public class DefaultExtKeyNameTest {
+
+    private String keyName = new String("hello");
+    private String keyName1 = new String("Hi");
+
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.EXT_FLOW_RULE_KEY;
+
+    @Test
+    public void basics() {
+
+        DefaultExtKeyName data = new DefaultExtKeyName(keyName, type);
+        DefaultExtKeyName sameAsData = new DefaultExtKeyName(keyName, type);
+        DefaultExtKeyName diffData = new DefaultExtKeyName(keyName1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPacketLengthTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPacketLengthTest.java
new file mode 100644
index 0000000..d0d2f9c
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPacketLengthTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended packet length value attribute.
+ */
+public class DefaultExtPacketLengthTest {
+
+    private List<ExtOperatorValue> packetLength = new ArrayList<>();
+    private List<ExtOperatorValue> packetLength1 = new ArrayList<>();
+    private ExtOperatorValue opVal = new ExtOperatorValue((byte) 1, new byte[100]);
+    private ExtOperatorValue opVal1 = new ExtOperatorValue((byte) 1, new byte[200]);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.PACKET_LENGTH_LIST;
+
+    @Test
+    public void basics() {
+        packetLength.add(opVal);
+        packetLength1.add(opVal1);
+        DefaultExtPacketLength data = new DefaultExtPacketLength(packetLength, type);
+        DefaultExtPacketLength sameAsData = new DefaultExtPacketLength(packetLength, type);
+        DefaultExtPacketLength diffData = new DefaultExtPacketLength(packetLength1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPortTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPortTest.java
new file mode 100644
index 0000000..9e41e6c
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPortTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+        import com.google.common.testing.EqualsTester;
+        import org.junit.Test;
+
+        import java.util.ArrayList;
+        import java.util.List;
+
+/**
+ * Test for extended icmp type value attribute.
+ */
+public class DefaultExtPortTest {
+
+    private List<ExtOperatorValue> port = new ArrayList<>();
+    private List<ExtOperatorValue> port1 = new ArrayList<>();
+    private ExtOperatorValue opVal = new ExtOperatorValue((byte) 1, new byte[100]);
+    private ExtOperatorValue opVal1 = new ExtOperatorValue((byte) 1, new byte[200]);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.IN_PORT_LIST;
+
+    @Test
+    public void basics() {
+        port.add(opVal);
+        port1.add(opVal1);
+        DefaultExtPort data = new DefaultExtPort(port, type);
+        DefaultExtPort sameAsData = new DefaultExtPort(port, type);
+        DefaultExtPort diffData = new DefaultExtPort(port1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPrefixTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPrefixTest.java
new file mode 100644
index 0000000..71eb9e8
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtPrefixTest.java
@@ -0,0 +1,48 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+        import com.google.common.testing.EqualsTester;
+        import org.junit.Test;
+        import org.onlab.packet.IpAddress;
+        import org.onlab.packet.IpPrefix;
+
+        import java.util.ArrayList;
+        import java.util.List;
+
+/**
+ * Test for extended prefix value attribute.
+ */
+public class DefaultExtPrefixTest {
+
+    private List<IpPrefix> prefix = new ArrayList<>();
+    private List<IpPrefix> prefix1 = new ArrayList<>();
+    private IpAddress address = IpAddress.valueOf("192.168.1.1");
+    private IpPrefix opVal = IpPrefix.valueOf(address, 16);
+    private IpPrefix opVal1 = IpPrefix.valueOf(address, 20);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.IPV4_DST_PFX;
+
+    @Test
+    public void basics() {
+        prefix.add(opVal);
+        prefix1.add(opVal1);
+        DefaultExtPrefix data = new DefaultExtPrefix(prefix, type);
+        DefaultExtPrefix sameAsData = new DefaultExtPrefix(prefix, type);
+        DefaultExtPrefix diffData = new DefaultExtPrefix(prefix1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTargetTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTargetTest.java
new file mode 100644
index 0000000..2f8c37c
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTargetTest.java
@@ -0,0 +1,53 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+import org.onlab.packet.IpAddress;
+import org.onlab.packet.IpPrefix;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended t value target ttribute.
+ */
+public class DefaultExtTargetTest {
+    private List<IpPrefix> prefix = new ArrayList<>();
+    private List<IpPrefix> prefix1 = new ArrayList<>();
+    private IpAddress address = IpAddress.valueOf("192.168.1.1");
+    private IpPrefix opVal = IpPrefix.valueOf(address, 16);
+    private IpPrefix opVal1 = IpPrefix.valueOf(address, 20);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.IPV4_DST_PFX;
+    private ExtFlowTypes.ExtType typeThis = ExtFlowTypes.ExtType.WIDE_COMM_TARGET;
+
+    @Test
+    public void basics() {
+        prefix.add(opVal);
+        prefix1.add(opVal1);
+        DefaultExtPrefix localSpeaker = new DefaultExtPrefix(prefix, type);
+        DefaultExtPrefix remoteSpeaker = new DefaultExtPrefix(prefix, type);
+        DefaultExtPrefix localSpeaker1 = new DefaultExtPrefix(prefix1, type);
+        DefaultExtPrefix remoteSpeaker1 = new DefaultExtPrefix(prefix1, type);
+
+        DefaultExtTarget data = new DefaultExtTarget(localSpeaker, remoteSpeaker, typeThis);
+        DefaultExtTarget sameAsData = new DefaultExtTarget(localSpeaker, remoteSpeaker, typeThis);
+        DefaultExtTarget diffData = new DefaultExtTarget(localSpeaker1, remoteSpeaker1, typeThis);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTcpFlagTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTcpFlagTest.java
new file mode 100644
index 0000000..3ecedc1
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTcpFlagTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended tcp flag value attribute.
+ */
+public class DefaultExtTcpFlagTest {
+
+    private List<ExtOperatorValue> tcpFlag = new ArrayList<>();
+    private List<ExtOperatorValue> tcpFlag1 = new ArrayList<>();
+    private ExtOperatorValue opVal = new ExtOperatorValue((byte) 1, new byte[100]);
+    private ExtOperatorValue opVal1 = new ExtOperatorValue((byte) 1, new byte[200]);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.TCP_FLAG_LIST;
+
+    @Test
+    public void basics() {
+        tcpFlag.add(opVal);
+        tcpFlag1.add(opVal1);
+        DefaultExtTcpFlag data = new DefaultExtTcpFlag(tcpFlag, type);
+        DefaultExtTcpFlag sameAsData = new DefaultExtTcpFlag(tcpFlag, type);
+        DefaultExtTcpFlag diffData = new DefaultExtTcpFlag(tcpFlag1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficActionTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficActionTest.java
new file mode 100644
index 0000000..4f42a39
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficActionTest.java
@@ -0,0 +1,43 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+/**
+ * Test for extended traffic action value attribute.
+ */
+public class DefaultExtTrafficActionTest {
+
+    private boolean terminal = true;
+    private boolean sample = true;
+    private boolean rpd = true;
+    private boolean terminal1 = false;
+    private boolean sample1 = false;
+    private boolean rpd1 = false;
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.TRAFFIC_ACTION;
+
+    @Test
+    public void basics() {
+
+        DefaultExtTrafficAction data = new DefaultExtTrafficAction(terminal, sample, rpd, type);
+        DefaultExtTrafficAction sameAsData = new DefaultExtTrafficAction(terminal, sample, rpd, type);
+        DefaultExtTrafficAction diffData = new DefaultExtTrafficAction(terminal1, sample1, rpd1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficMarkingTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficMarkingTest.java
new file mode 100644
index 0000000..adee1ac
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficMarkingTest.java
@@ -0,0 +1,38 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+/**
+ * Test for extended traffic marking value attribute.
+ */
+public class DefaultExtTrafficMarkingTest {
+
+    private byte marking = 01;
+    private byte marking1 = 02;
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.TRAFFIC_MARKING;
+
+    @Test
+    public void basics() {
+        DefaultExtTrafficMarking data = new DefaultExtTrafficMarking(marking, type);
+        DefaultExtTrafficMarking sameAsData = new DefaultExtTrafficMarking(marking, type);
+        DefaultExtTrafficMarking diffData = new DefaultExtTrafficMarking(marking1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficRateTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficRateTest.java
new file mode 100644
index 0000000..f772e11
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficRateTest.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+/**
+ * Test for extended traffic rate value attribute.
+ */
+public class DefaultExtTrafficRateTest {
+
+    private Short asn = new Short((short) 1);
+    private Float rate = new Float(1.0);
+    private Short asn1 = new Short((short) 2);
+    private Float rate1 = new Float(1.0);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.TRAFFIC_RATE;
+
+    @Test
+    public void basics() {
+        DefaultExtTrafficRate data = new DefaultExtTrafficRate(asn, rate, type);
+        DefaultExtTrafficRate sameAsData = new DefaultExtTrafficRate(asn, rate, type);
+        DefaultExtTrafficRate diffData = new DefaultExtTrafficRate(asn1, rate1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficRedirectTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficRedirectTest.java
new file mode 100644
index 0000000..00ee162
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtTrafficRedirectTest.java
@@ -0,0 +1,39 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+/**
+ * Test for extended traffic redirect value attribute.
+ */
+public class DefaultExtTrafficRedirectTest {
+
+    String redirect = new String("vpnid1");
+    String redirect1 = new String("vpnid2");
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.TRAFFIC_REDIRECT;
+
+    @Test
+    public void basics() {
+
+        DefaultExtTrafficRedirect data = new DefaultExtTrafficRedirect(redirect, type);
+        DefaultExtTrafficRedirect sameAsData = new DefaultExtTrafficRedirect(redirect, type);
+        DefaultExtTrafficRedirect diffData = new DefaultExtTrafficRedirect(redirect1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtWideCommunityIntTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtWideCommunityIntTest.java
new file mode 100644
index 0000000..f209217
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/DefaultExtWideCommunityIntTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended wide community value attribute.
+ */
+public class DefaultExtWideCommunityIntTest {
+
+    private List<Integer> wCommInt = new ArrayList<>();
+    private List<Integer> wCommInt1 = new ArrayList<>();
+    private Integer opVal = new Integer(1);
+    private Integer opVal1 = new Integer(2);
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.WIDE_COMM_COMMUNITY;
+
+    @Test
+    public void basics() {
+        wCommInt.add(opVal);
+        wCommInt1.add(opVal1);
+        DefaultExtWideCommunityInt data = new DefaultExtWideCommunityInt(wCommInt, type);
+        DefaultExtWideCommunityInt sameAsData = new DefaultExtWideCommunityInt(wCommInt, type);
+        DefaultExtWideCommunityInt diffData = new DefaultExtWideCommunityInt(wCommInt1, type);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/ExtFlowContainerTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/ExtFlowContainerTest.java
new file mode 100644
index 0000000..e8113ce
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/ExtFlowContainerTest.java
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import com.google.common.testing.EqualsTester;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Test for extended flow container value attribute.
+ */
+public class ExtFlowContainerTest {
+
+    private List<ExtFlowTypes> container = new ArrayList<>();
+    private List<ExtFlowTypes> container1 = new ArrayList<>();
+    private ExtFlowTypes.ExtType type = ExtFlowTypes.ExtType.EXT_FLOW_RULE_KEY;
+    ExtFlowTypes val = new DefaultExtKeyName("Name", type);
+    ExtFlowTypes val1 = new DefaultExtKeyName("Name1", type);
+
+    @Test
+    public void basics() {
+        container.add(val);
+        container1.add(val1);
+        ExtFlowContainer data = new ExtFlowContainer(container);
+        ExtFlowContainer sameAsData = new ExtFlowContainer(container);
+        ExtFlowContainer diffData = new ExtFlowContainer(container1);
+        new EqualsTester().addEqualityGroup(data, sameAsData)
+                .addEqualityGroup(diffData).testEquals();
+    }
+}
\ No newline at end of file
diff --git a/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/ExtOperatorValueTest.java b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/ExtOperatorValueTest.java
new file mode 100644
index 0000000..8e9e3b7
--- /dev/null
+++ b/apps/bgpflowspec/flowapi/src/test/java/org/onosproject/flowapi/ExtOperatorValueTest.java
@@ -0,0 +1,37 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flowapi;
+
+import org.junit.Test;
+
+import com.google.common.testing.EqualsTester;
+
+/**
+ * Test for ExtOperatorValue flow specification component.
+ */
+public class ExtOperatorValueTest {
+    ExtOperatorValue tlv1 = new ExtOperatorValue((byte) 1, new byte[100]);
+    ExtOperatorValue sameAsTlv1 = new ExtOperatorValue((byte) 1, new byte[100]);
+    ExtOperatorValue tlv2 = new ExtOperatorValue((byte) 1, new byte[200]);
+
+    @Test
+    public void testEquality() {
+        new EqualsTester()
+                .addEqualityGroup(tlv1, sameAsTlv1)
+                .addEqualityGroup(tlv2)
+                .testEquals();
+    }
+}
diff --git a/apps/bgpflowspec/flowmgr/BUCK b/apps/bgpflowspec/flowmgr/BUCK
new file mode 100755
index 0000000..dd7ae7e
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/BUCK
@@ -0,0 +1,10 @@
+COMPILE_DEPS = [
+    '//lib:CORE_DEPS',
+    '//core/store/serializers:onos-core-serializers',
+    '//apps/bgpflowspec/flowapi:onos-apps-bgpflowspec-flowapi',
+]
+
+osgi_jar_with_tests (
+    name = 'onos-apps-bgpflowspec-flowmgr',
+    deps = COMPILE_DEPS,
+)
diff --git a/apps/bgpflowspec/flowmgr/pom.xml b/apps/bgpflowspec/flowmgr/pom.xml
new file mode 100755
index 0000000..5d9afbe
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/pom.xml
@@ -0,0 +1,51 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright 2015 Open Networking Laboratory
+  ~
+  ~ Licensed 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.
+  -->
+<project
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
+    xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.onosproject</groupId>
+        <artifactId>onos-app-bgpflow</artifactId>
+        <version>1.6.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>onos-app-bgp-flowmgr</artifactId>
+    <packaging>bundle</packaging>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onos-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>javax.ws.rs</groupId>
+            <artifactId>javax.ws.rs-api</artifactId>
+            <version>2.0.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.karaf.shell</groupId>
+            <artifactId>org.apache.karaf.shell.console</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onos-app-bgp-flowapi</artifactId>
+            <version>1.6.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
+</project>
diff --git a/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/BgpFlowForwarderService.java b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/BgpFlowForwarderService.java
new file mode 100755
index 0000000..e2527b9
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/BgpFlowForwarderService.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flow.forwarder;
+
+import org.onosproject.flowapi.ExtFlowContainer;
+
+/**
+ * Abstraction of an entity which provides Bgp Flow Service.
+ */
+public interface BgpFlowForwarderService {
+
+    /**
+     * Install forwarding rule.
+     *
+     * @param container BgpFlow container
+     * @return a true if success else false
+     */
+    boolean installForwardingRule(ExtFlowContainer container);
+
+    /**
+     * Uninstall forwarding rule.
+     *
+     * @param container BgpFlow container
+     * @return a true if success else false
+     */
+    boolean unInstallForwardingRule(ExtFlowContainer container);
+}
diff --git a/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/impl/BgpFlowForwarderImpl.java b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/impl/BgpFlowForwarderImpl.java
new file mode 100755
index 0000000..bc5170d
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/impl/BgpFlowForwarderImpl.java
@@ -0,0 +1,208 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flow.forwarder.impl;
+
+import org.onosproject.core.ApplicationId;
+import org.onosproject.flow.forwarder.BgpFlowForwarderService;
+
+import org.onosproject.flowapi.ExtFlowContainer;
+import org.onosproject.net.Annotations;
+import org.onosproject.net.Device;
+import org.onosproject.net.DeviceId;
+import org.onosproject.net.behaviour.ExtensionSelectorResolver;
+import org.onosproject.net.device.DeviceService;
+import org.onosproject.net.driver.DriverHandler;
+import org.onosproject.net.driver.DriverService;
+import org.onosproject.net.flow.DefaultTrafficSelector;
+import org.onosproject.net.flow.DefaultTrafficTreatment;
+import org.onosproject.net.flow.TrafficSelector;
+import org.onosproject.net.flow.TrafficTreatment;
+import org.onosproject.net.flow.criteria.ExtensionSelector;
+import org.onosproject.net.flowobjective.DefaultForwardingObjective;
+import org.onosproject.net.flowobjective.FlowObjectiveService;
+import org.onosproject.net.flowobjective.ForwardingObjective;
+import org.onosproject.net.flowobjective.ForwardingObjective.Flag;
+import org.onosproject.net.flowobjective.Objective;
+import org.slf4j.Logger;
+
+import java.util.Iterator;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+import static org.onosproject.net.flow.criteria.ExtensionSelectorType.ExtensionSelectorTypes.EXT_MATCH_FLOW_TYPE;
+import static org.slf4j.LoggerFactory.getLogger;
+
+/**
+ * Provides Bgp flow forwarder implementation.
+ */
+public class BgpFlowForwarderImpl implements BgpFlowForwarderService {
+
+    protected DriverService driverService;
+    protected DeviceService deviceService;
+    protected FlowObjectiveService flowObjectiveService;
+    private final Logger log = getLogger(getClass());
+    protected ApplicationId appId;
+
+    private static final String BGP_FLOW_CONTAINER_NOT_NULL = "Bgp flow container cannot be null";
+    private static final String APP_ID_NOT_NULL = "Application-Id cannot be null";
+    public static final String FLOW_PEER = "flowPeer";
+
+    /**
+     * Default constructor.
+     */
+    public BgpFlowForwarderImpl() {
+    }
+
+    /**
+     * Explicit constructor.
+     *
+     * @param appId Application id
+     * @param flowObjectiveService flow service
+     * @param deviceService device service
+     * @param driverService driver service
+     */
+    public BgpFlowForwarderImpl(ApplicationId appId, FlowObjectiveService flowObjectiveService,
+                                DeviceService deviceService, DriverService driverService) {
+        this.appId = checkNotNull(appId, APP_ID_NOT_NULL);
+        this.flowObjectiveService = flowObjectiveService;
+        this.deviceService = deviceService;
+        this.driverService = driverService;
+    }
+
+    @Override
+    public boolean installForwardingRule(ExtFlowContainer container) {
+        checkNotNull(container, BGP_FLOW_CONTAINER_NOT_NULL);
+        return pushBgpFlowRuleForwarder(container, Objective.Operation.ADD);
+    }
+
+    @Override
+    public boolean unInstallForwardingRule(ExtFlowContainer container) {
+        checkNotNull(container, BGP_FLOW_CONTAINER_NOT_NULL);
+        return pushBgpFlowRuleForwarder(container, Objective.Operation.REMOVE);
+    }
+
+    /**
+     * Find the bgp device and push the rule.
+     *
+     * @param container is a flow rule container
+     * @param type either add or remove the service rule
+     * @return a true if success else false
+     */
+    public boolean pushBgpFlowRuleForwarder(ExtFlowContainer container,
+                                             Objective.Operation type) {
+        DeviceId deviceId = null;
+
+        Iterable<Device> devices = deviceService.getAvailableDevices();
+        Iterator<Device> itr = devices.iterator();
+        while (itr.hasNext()) {
+            DeviceId tmp = itr.next().id();
+            if (tmp.toString().equals(container.deviceId())) {
+                if (validatePeer(tmp)) {
+                    deviceId = tmp;
+                    break;
+                }
+            }
+        }
+
+        if (deviceId != null) {
+            // pack traffic selector
+            TrafficSelector.Builder selector = packTrafficSelector(deviceId, container);
+
+            // pack traffic treatment
+            TrafficTreatment.Builder treatment = packTrafficTreatment(container);
+
+            sendBgpFlowRuleForwarder(selector, treatment, deviceId, type);
+        } else {
+            log.error("Bgp devices are not available..");
+            return false;
+        }
+
+        return true;
+    }
+
+    /**
+     * Validates the device id is a flow peer or not.
+     *
+     * @param deviceId device to which the flow needed to be pushed.
+     * @return true if success else false
+     */
+    boolean validatePeer(DeviceId deviceId) {
+        boolean ret = false;
+        Device d = deviceService.getDevice(deviceId);
+        Annotations a = d != null ? d.annotations() : null;
+        String ipAddress = a.value(FLOW_PEER);
+        if (ipAddress != null) {
+            ret = true;
+        }
+        return ret;
+    }
+
+    /**
+     * Traffic selector builder function.
+     *
+     * @param deviceId device id.
+     * @param container container need to be pushed.
+     * @return the traffic selector builder
+     */
+    public TrafficSelector.Builder packTrafficSelector(DeviceId deviceId, ExtFlowContainer container) {
+        TrafficSelector.Builder selector = DefaultTrafficSelector.builder();
+
+        DriverHandler handler = driverService.createHandler(deviceId);
+        ExtensionSelectorResolver resolver = handler.behaviour(ExtensionSelectorResolver.class);
+        ExtensionSelector bgpExtSelector = resolver.getExtensionSelector(EXT_MATCH_FLOW_TYPE.type());
+
+        try {
+            bgpExtSelector.setPropertyValue("container", container);
+        } catch (Exception e) {
+            log.error("Failed to get extension instruction for bgp flow {}", deviceId);
+        }
+
+        selector.extension(bgpExtSelector, deviceId);
+        return selector;
+    }
+
+    /**
+     * Traffic treatment builder function.
+     *
+     * @param container container need to be pushed.
+     * @return the traffic treatment builder
+     */
+    public TrafficTreatment.Builder packTrafficTreatment(ExtFlowContainer container) {
+        TrafficTreatment.Builder treatment = DefaultTrafficTreatment.builder();
+
+        return treatment;
+    }
+
+    /**
+     * Send bgp flow forwarder to bgp provider.
+     *
+     * @param selector traffic selector
+     * @param treatment traffic treatment
+     * @param deviceId device id
+     * @param type operation type
+     */
+    public void sendBgpFlowRuleForwarder(TrafficSelector.Builder selector, TrafficTreatment.Builder treatment,
+            DeviceId deviceId, Objective.Operation type) {
+        ForwardingObjective.Builder objective = DefaultForwardingObjective.builder().withTreatment(treatment.build())
+                .withSelector(selector.build()).fromApp(appId).makePermanent().withFlag(Flag.VERSATILE);
+        if (type.equals(Objective.Operation.ADD)) {
+            log.debug("ADD");
+            flowObjectiveService.forward(deviceId, objective.add());
+        } else {
+            log.debug("REMOVE");
+            flowObjectiveService.forward(deviceId, objective.remove());
+        }
+    }
+}
diff --git a/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/impl/package-info.java b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/impl/package-info.java
new file mode 100755
index 0000000..4ae602f
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/impl/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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.
+ */
+
+/**
+ * Bgp service manager for interacting with bgp provider.
+ */
+package org.onosproject.flow.forwarder.impl;
diff --git a/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/package-info.java b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/package-info.java
new file mode 100755
index 0000000..0000150
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/forwarder/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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.
+ */
+
+/**
+ * Service forwarder for bgp flow.
+ */
+package org.onosproject.flow.forwarder;
diff --git a/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/BgpFlowService.java b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/BgpFlowService.java
new file mode 100755
index 0000000..cf7aada
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/BgpFlowService.java
@@ -0,0 +1,40 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flow.manager;
+
+import org.onosproject.flowapi.ExtFlowContainer;
+
+/**
+ * Bgp flow service application.
+ */
+public interface BgpFlowService {
+
+    /**
+     * Bgp flow rule create interface.
+     *
+     * @param container flow container class
+     * @return true if success else false
+     */
+    boolean onBgpFlowCreated(ExtFlowContainer container);
+
+    /**
+     * Bgp flow rule delete interface.
+     *
+     * @param container flow container class
+     * @return true if success else false
+     */
+    boolean onBgpFlowDeleted(ExtFlowContainer container);
+}
diff --git a/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/impl/BgpFlowManager.java b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/impl/BgpFlowManager.java
new file mode 100755
index 0000000..deccf38
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/impl/BgpFlowManager.java
@@ -0,0 +1,83 @@
+/*
+ * Copyright 2016 Open Networking Laboratory
+ *
+ * Licensed 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 org.onosproject.flow.manager.impl;
+
+import org.apache.felix.scr.annotations.Activate;
+import org.apache.felix.scr.annotations.Component;
+import org.apache.felix.scr.annotations.Deactivate;
+import org.apache.felix.scr.annotations.Reference;
+import org.apache.felix.scr.annotations.ReferenceCardinality;
+import org.apache.felix.scr.annotations.Service;
+import org.onosproject.core.ApplicationId;
+import org.onosproject.core.CoreService;
+import org.onosproject.flow.forwarder.BgpFlowForwarderService;
+import org.onosproject.flow.forwarder.impl.BgpFlowForwarderImpl;
+import org.onosproject.flow.manager.BgpFlowService;
+import org.onosproject.flowapi.ExtFlowContainer;
+import org.onosproject.net.device.DeviceService;
+import org.onosproject.net.driver.DriverService;
+import org.onosproject.net.flowobjective.FlowObjectiveService;
+import org.slf4j.Logger;
+
+import static org.slf4j.LoggerFactory.getLogger;
+
+/**
+ * Provides implementation of Bgp flow Service.
+ */
+@Component(immediate = true)
+@Service
+public class BgpFlowManager implements BgpFlowService {
+
+    private final Logger log = getLogger(getClass());
+    private static final String APP_ID = "org.onosproject.app.bgpflow";
+
+    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+    protected CoreService coreService;
+
+    protected ApplicationId appId;
+    private BgpFlowForwarderService bgpFlowForwarderService;
+
+    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+    protected DriverService driverService;
+
+    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+    protected DeviceService deviceService;
+
+    @Reference(cardinality = ReferenceCardinality.MANDATORY_UNARY)
+    protected FlowObjectiveService flowObjectiveService;
+
+    @Activate
+    public void activate() {
+        appId = coreService.registerApplication(APP_ID);
+        bgpFlowForwarderService = new BgpFlowForwarderImpl(appId, flowObjectiveService, deviceService, driverService);
+        log.info("Started");
+    }
+
+    @Deactivate
+    public void deactivate() {
+        log.info("Stopped");
+    }
+
+    @Override
+    public boolean onBgpFlowCreated(ExtFlowContainer container) {
+        return bgpFlowForwarderService.installForwardingRule(container);
+    }
+
+    @Override
+    public boolean onBgpFlowDeleted(ExtFlowContainer container) {
+        return bgpFlowForwarderService.unInstallForwardingRule(container);
+    }
+}
diff --git a/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/impl/package-info.java b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/impl/package-info.java
new file mode 100755
index 0000000..e686bb8
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/impl/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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.
+ */
+
+/**
+ * Bgp service manager for interacting provider.
+ */
+package org.onosproject.flow.manager.impl;
diff --git a/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/package-info.java b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/package-info.java
new file mode 100755
index 0000000..b3ba1cb
--- /dev/null
+++ b/apps/bgpflowspec/flowmgr/src/main/java/org/onosproject/flow/manager/package-info.java
@@ -0,0 +1,20 @@
+/*
+ * Copyright 2016-present Open Networking Laboratory
+ *
+ * Licensed 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.
+ */
+
+/**
+ * Bgp flow manager.
+ */
+package org.onosproject.flow.manager;
diff --git a/apps/bgpflowspec/pom.xml b/apps/bgpflowspec/pom.xml
new file mode 100755
index 0000000..1ce57ca
--- /dev/null
+++ b/apps/bgpflowspec/pom.xml
@@ -0,0 +1,83 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~ Copyright 2016-present Open Networking Laboratory
+  ~
+  ~ Licensed 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.
+  -->
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>org.onosproject</groupId>
+        <artifactId>onos-apps</artifactId>
+        <version>1.6.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>onos-app-bgpflow</artifactId>
+    <packaging>pom</packaging>
+
+    <description>ONOS bgp flow spec applications</description>
+
+    <modules>
+        <module>app</module>
+        <module>flowapi</module>
+        <module>flowmgr</module>
+        <module>bgpweb</module>
+    </modules>
+    <dependencies>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onlab-junit</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava-testlib</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.easymock</groupId>
+            <artifactId>easymock</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onlab-osgi</artifactId>
+            <classifier>tests</classifier>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.onosproject</groupId>
+            <artifactId>onos-api</artifactId>
+            <scope>test</scope>
+            <classifier>tests</classifier>
+        </dependency>
+        <dependency>
+            <groupId>org.glassfish.jersey.containers</groupId>
+            <artifactId>jersey-container-servlet</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.glassfish.jersey.test-framework</groupId>
+            <artifactId>jersey-test-framework-core</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.glassfish.jersey.test-framework.providers</groupId>
+            <artifactId>jersey-test-framework-provider-jetty</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+</project>
diff --git a/apps/pom.xml b/apps/pom.xml
index 0479658..c6cc9c6 100644
--- a/apps/pom.xml
+++ b/apps/pom.xml
@@ -42,6 +42,7 @@
         <module>reactive-routing</module>
         <module>virtualbng</module>
         <module>bgprouter</module>
+        <module>bgpflowspec</module>
         <module>test</module>
         <module>segmentrouting</module>
         <module>xos-integration</module>