diff --git a/src/plugin/plugin_manager.cpp b/src/plugin/plugin_manager.cpp
index 85728b0..c14aab0 100644
--- a/src/plugin/plugin_manager.cpp
+++ b/src/plugin/plugin_manager.cpp
@@ -1037,7 +1037,7 @@ void plugin_manager_on_session_ingress(struct session *sess, struct packet *pkt)
         {
         case SESSION_TYPE_TCP:
 			session_mq_publish_message_with_priority(sess, plug_mgr_rt->plug_mgr->tcp_topic_id ,(void *)pkt, STELLAR_MQ_PRIORITY_HIGH);
-			while ((seg = session_get_tcp_segment(sess)) != NULL)
+			if ((seg = session_get_tcp_segment(sess)) != NULL)
 			{
 				session_mq_publish_message_with_priority(sess, plug_mgr_rt->plug_mgr->tcp_stream_topic_id, (void *)seg, STELLAR_MQ_PRIORITY_HIGH);
 			}
@@ -1053,11 +1053,15 @@ void plugin_manager_on_session_ingress(struct session *sess, struct packet *pkt)
     //TODO: check TCP topic active subscirber num, if 0, return disable assembler state, to reduce tcp reassemble overhead
 	int tid=stellar_get_current_thread_index();
 	stellar_mq_dispatch(plug_mgr_rt->plug_mgr->per_thread_data[tid].priority_mq, &plug_mgr_rt->plug_mgr->per_thread_data[tid].dealth_letter_queue, sess, pkt);
+
+	while ((seg = session_get_tcp_segment(sess)) != NULL)
+	{
+		session_mq_publish_message_with_priority(sess, plug_mgr_rt->plug_mgr->tcp_stream_topic_id, (void *)seg, STELLAR_MQ_PRIORITY_HIGH);
+		stellar_mq_dispatch(plug_mgr_rt->plug_mgr->per_thread_data[tid].priority_mq, &plug_mgr_rt->plug_mgr->per_thread_data[tid].dealth_letter_queue, sess, pkt);
+	}
 	plugin_manager_scratch_session_set(NULL);
 
-
-
-    return;
+	return;
 }
 
 void plugin_manager_on_session_egress(struct session *sess, struct packet *pkt)