diff --git a/TestON/drivers/common/api/controller/trexclientdriver.py b/TestON/drivers/common/api/controller/trexclientdriver.py
index 030e42b..a3923c9 100644
--- a/TestON/drivers/common/api/controller/trexclientdriver.py
+++ b/TestON/drivers/common/api/controller/trexclientdriver.py
@@ -149,7 +149,7 @@
                                               trex_args=trex_args)
         success = self.__set_up_trex_server(
             self.trex_daemon_client, self.trex_address,
-            pathToTrexConfig + self.trex_config,
+            os.path.join(pathToTrexConfig, self.trex_config),
             self.force_restart
         )
         if not success:
diff --git a/TestON/tests/USECASE/SegmentRouting/INT/INT.params b/TestON/tests/USECASE/SegmentRouting/INT/INT.params
index b4be343..63ff5c7 100644
--- a/TestON/tests/USECASE/SegmentRouting/INT/INT.params
+++ b/TestON/tests/USECASE/SegmentRouting/INT/INT.params
@@ -3,4 +3,45 @@
 <PARAMS>
     <testcases>1,2,3</testcases>
     <routerMac>00:00:0A:4C:1C:46</routerMac>
+    <TREX>
+        <flows>
+            <RESET_QUEUE_REPORT_FILTER>
+                <!-- A low-throughput flow to reset the queue report filter -->
+                <name>Low throughput flow</name>
+                <l1_bps>10000</l1_bps>
+                <trex_port>0</trex_port>
+                <packet>
+                    <pktlen>1400</pktlen>
+                    <ip_src>10.32.11.123</ip_src>
+                    <ip_dst>10.32.11.125</ip_dst>
+                    <eth_src>40:A6:B7:22:AB:40</eth_src>
+                    <eth_dst>40:A6:B7:22:AB:21</eth_dst>
+                </packet>
+            </RESET_QUEUE_REPORT_FILTER>
+            <FLOW1>
+                <name>Flow 1</name>
+                <l1_bps>25000000000</l1_bps> <!-- 25G -->
+                <trex_port>0</trex_port>
+                <packet>
+                    <pktlen>1400</pktlen>
+                    <ip_src>10.32.11.123</ip_src>
+                    <ip_dst>10.32.11.125</ip_dst>
+                    <eth_src>40:A6:B7:22:AB:40</eth_src>
+                    <eth_dst>40:A6:B7:22:AB:21</eth_dst>
+                </packet>
+            </FLOW1>
+            <FLOW2>
+                <name>Flow 2</name>
+                <l1_bps>25000000000</l1_bps> <!-- 25G -->
+                <trex_port>2</trex_port>
+                <packet>
+                    <pktlen>1400</pktlen>
+                    <ip_src>10.32.11.124</ip_src>
+                    <ip_dst>10.32.11.125</ip_dst>
+                    <eth_src>40:A6:B7:22:AB:20</eth_src>
+                    <eth_dst>40:A6:B7:22:AB:21</eth_dst>
+                </packet>
+            </FLOW2>
+        </flows>
+    </TREX>
 </PARAMS>
diff --git a/TestON/tests/USECASE/SegmentRouting/INT/INT.py b/TestON/tests/USECASE/SegmentRouting/INT/INT.py
index c902af3..9295a29 100644
--- a/TestON/tests/USECASE/SegmentRouting/INT/INT.py
+++ b/TestON/tests/USECASE/SegmentRouting/INT/INT.py
@@ -221,3 +221,63 @@
 
         main.step("Clean up the test")
         intTest.cleanUp(main)
+
+    def CASE4(self, main):
+        """
+        Generate traffic at high rate and expect queue congestion reports in DeepInsight.
+        """
+        from core import utilities
+        import time
+        from tests.USECASE.SegmentRouting.INT.dependencies.IntTest import IntTest
+        from tests.USECASE.SegmentRouting.dependencies.trex import Trex
+        main.cfgName = 'CASE4'
+
+        main.step("Setting up the test")
+        intTest = IntTest(scapy=False)
+        intTest.setUpTest(main)
+        dstIp = main.params["TREX"]["flows"]["FLOW1"]["packet"]["ip_dst"]
+
+        main.step("Set up TRex client")
+        trex = Trex()
+        trex.setup(main.TRexClient)
+
+        # See SRpairedLeaves.param for the detail of each flow.
+        main.step("Reset queue report filter")
+        # Here we are using a low-latency(no congestion) traffic to reset the queue.
+        # report filter.
+        trex.createFlow("RESET_QUEUE_REPORT_FILTER")
+        trex.sendAndReceiveTraffic(5)
+        trex.resetFlows()
+        main.step("Generating traffic")
+        startTimeMs = (time.time() - 5) * 1000
+        trex.createFlow("FLOW1")
+        trex.createFlow("FLOW2")
+        trex.sendAndReceiveTraffic(10)
+        endTimeMs = (time.time() + 5) * 1000
+
+        main.step("Checking queue report from DeepInsight")
+        def getQueueAnomaly(*args, **kwargs):
+            return main.DeepInsight.getAnomalyRecords(
+                startTime=startTimeMs,
+                endTime=endTimeMs,
+                dstIp=dstIp,
+                anomalyType="congested_flow",
+            )
+
+        # Need to wait few seconds until DeepInsight database updated.
+        queueAnomalies = utilities.retry(
+            f=getQueueAnomaly,
+            retValue=[[]],
+            attempts=60,
+        )
+
+        # We should get at least two congestion records
+        utilities.assert_lesser(
+            expect=2, actual=len(queueAnomalies),
+            onpass="Got %d anomalies with 'congested_flow' type as expcted." % (len(queueAnomalies)),
+            onfail="Did not get any anomaly with 'congested_flow' type."
+        )
+
+        main.step("Clean up the test")
+        trex.teardown()
+        intTest.cleanUp(main)
diff --git a/TestON/tests/USECASE/SegmentRouting/INT/INT.topo b/TestON/tests/USECASE/SegmentRouting/INT/INT.topo
index 559d041..e54c546 100644
--- a/TestON/tests/USECASE/SegmentRouting/INT/INT.topo
+++ b/TestON/tests/USECASE/SegmentRouting/INT/INT.topo
@@ -100,6 +100,19 @@
             </COMPONENTS>
         </DeepInsight>
 
+        <TRexClient>
+            <host>localhost</host>
+            <type>TrexClientDriver</type>
+            <connect_order>5</connect_order>
+            <COMPONENTS>
+                <trex_address>10.76.28.72</trex_address> <!-- Compute2 -->
+                <trex_config>trex_config.yaml</trex_config> <!-- relative path starting from ./dependencies-->
+                <force_restart>True</force_restart>
+                <software_mode>True</software_mode>
+                <trex_library_python_path>/home/jenkins/trex_python</trex_library_python_path>
+            </COMPONENTS>
+        </TRexClient>
+
         <!-- A NetworkDriver to provide functions such as "createHostComponent" -->
         <INTNetwork>
             <host>localhost</host>
diff --git a/TestON/tests/USECASE/SegmentRouting/INT/dependencies/IntTest.py b/TestON/tests/USECASE/SegmentRouting/INT/dependencies/IntTest.py
index 2c6a99e..e10248f 100644
--- a/TestON/tests/USECASE/SegmentRouting/INT/dependencies/IntTest.py
+++ b/TestON/tests/USECASE/SegmentRouting/INT/dependencies/IntTest.py
@@ -1,6 +1,7 @@
 # SPDX-FileCopyrightText: Copyright 2021-present Open Networking Foundation.
 # SPDX-License-Identifier: GPL-2.0-or-later
 
+import os
 from tests.dependencies.Network import Network
 
 class IntTest:
@@ -12,6 +13,7 @@
     def setUpTest(self, main):
         main.Network = Network()
         main.Network.connectToNet()
+        main.configPath = os.path.join(os.path.dirname(main.testFile), "dependencies")
 
         for host in self.hosts:
             main.Network.createHostComponent(host)
diff --git a/TestON/tests/USECASE/SegmentRouting/INT/dependencies/trex_config.yaml b/TestON/tests/USECASE/SegmentRouting/INT/dependencies/trex_config.yaml
new file mode 100644
index 0000000..00a1f85
--- /dev/null
+++ b/TestON/tests/USECASE/SegmentRouting/INT/dependencies/trex_config.yaml
@@ -0,0 +1,19 @@
+# TRex Port ID=0 --> PCI BUS: d8:00.0, Linux Intf: enp216s0f0 connected to leaf1/0 (PDN)
+# TRex Port ID=1 --> PCI BUS: d8:00.1, Linux Intf: enp216s0f1 not connected, but required by TRex to have an even number of interfaces
+# TRex Port ID=2 --> PCI BUS: 5e:00.0, Linux Intf: enp94s0f0 connected to leaf2/0 (eNodeB)
+# TRex Port ID=3 --> PCI BUS: 5e:00.1, Linux Intf: enp94s0f1 connected to leaf2/4
+
+- version: 2
+  port_limit: 4
+  interfaces: [ 'd8:00.0', 'd8:00.1', '5e:00.0', '5e:00.1']
+  port_bandwidth_gb: 40
+  c: 16
+  port_info:
+    - src_mac: 40:A6:B7:22:AB:40
+      dest_mac: 00:00:0A:4C:1C:46
+    - src_mac: 40:A6:B7:22:AB:41
+      dest_mac: 00:00:0A:4C:1C:46
+    - src_mac: 40:A6:B7:22:AB:20
+      dest_mac: 00:00:0A:4C:1C:46
+    - src_mac: 40:A6:B7:22:AB:21
+      dest_mac: 00:00:0A:4C:1C:46
diff --git a/TestON/tests/USECASE/SegmentRouting/dependencies/trex.py b/TestON/tests/USECASE/SegmentRouting/dependencies/trex.py
index 9245f16..9b15811 100644
--- a/TestON/tests/USECASE/SegmentRouting/dependencies/trex.py
+++ b/TestON/tests/USECASE/SegmentRouting/dependencies/trex.py
@@ -67,6 +67,9 @@
             self.packets[flow_name] = scapy_helper.simple_udp_packet(
                 **self.traffic_flows[flow_name]["packet"])
 
+    def resetFlows(self):
+        self.packets = {}
+
     def sendAndReceiveTraffic(self, duration):
         """
         Connect the client, create the flows in trex (with packets created with