2 files changed, 8 insertions, 24 deletions
diff --git a/src/stateless/messaging/trex_stateless_messaging.cpp b/src/stateless/messaging/trex_stateless_messaging.cpp
index 4cd5b416..4ef508fc 100644
--- a/src/stateless/messaging/trex_stateless_messaging.cpp
+++ b/src/stateless/messaging/trex_stateless_messaging.cpp
@@ -20,32 +20,25 @@ limitations under the License.
 */
 #include <trex_stateless_messaging.h>
 #include <trex_stateless_dp_core.h>
+#include <trex_stream.h>
 #include <string.h>
 
 /*************************
   start traffic message
  ************************/ 
-TrexStatelessDpStart::TrexStatelessDpStart(const uint8_t *pkt, uint16_t pkt_len, double pps) {
-    assert(pkt);
-    assert(pkt_len > 0);
-
-    m_pkt = new uint8_t[pkt_len];
-    memcpy(m_pkt, pkt, pkt_len);
-    m_pkt_len = pkt_len;
-
-    m_pps = pps;
+TrexStatelessDpStart::TrexStatelessDpStart(TrexStreamsCompiledObj *obj) : m_obj(obj) {
 }
 
 TrexStatelessDpStart::~TrexStatelessDpStart() {
-    if (m_pkt) {
-        delete m_pkt;
+    if (m_obj) {
+        delete m_obj;
     }
 }
 
 bool
 TrexStatelessDpStart::handle(TrexStatelessDpCore *dp_core) {
 
-    dp_core->start_const_traffic(m_pkt, m_pkt_len, m_pps);
+    dp_core->start_traffic(m_obj);
     return true;
 }
 
diff --git a/src/stateless/messaging/trex_stateless_messaging.h b/src/stateless/messaging/trex_stateless_messaging.h
index af05aa4c..13f6c05a 100644
--- a/src/stateless/messaging/trex_stateless_messaging.h
+++ b/src/stateless/messaging/trex_stateless_messaging.h
@@ -24,6 +24,7 @@ limitations under the License.
 #include <msg_manager.h>
 
 class TrexStatelessDpCore;
+class TrexStreamsCompiledObj;
 
 /**
  * defines the base class for CP to DP messages
@@ -54,24 +55,14 @@ public:
 class TrexStatelessDpStart : public TrexStatelessCpToDpMsgBase {
 public:
 
-    TrexStatelessDpStart(const uint8_t *pkt, uint16_t pkt_len, double pps);
+    TrexStatelessDpStart(TrexStreamsCompiledObj *obj);
 
     ~TrexStatelessDpStart();
 
-    const uint8_t * get_pkt() {
-        return m_pkt;
-    }
-
-    uint16_t get_pkt_len() {
-        return m_pkt_len;
-    }
-
     virtual bool handle(TrexStatelessDpCore *dp_core);
 
 private:
-    uint8_t *m_pkt;
-    uint16_t m_pkt_len;
-    double   m_pps;
+    TrexStreamsCompiledObj *m_obj;
 };
 
 /**