diff --git a/pkg/middle/worker.go b/pkg/middle/worker.go
new file mode 100644
index 0000000..7d78b2d
--- /dev/null
+++ b/pkg/middle/worker.go
@@ -0,0 +1,17 @@
+package middle
+
+import (
+	"context"
+)
+
+func (m *MiddleWare) middleWorker() {
+	ctx := context.Background()
+	workEvent := m.eventConsumer.Receive(ctx)
+	m.loadPlugins()
+	for _, singles := range m.plugins {
+		for _, single := range singles {
+			single.Exec(workEvent)
+		}
+	}
+
+}
diff --git a/pkg/middle/worker_test.go b/pkg/middle/worker_test.go
new file mode 100644
index 0000000..4bdbcf5
--- /dev/null
+++ b/pkg/middle/worker_test.go
@@ -0,0 +1,16 @@
+package middle
+
+import (
+	"testing"
+
+	"gitee.com/timedb/wheatCache/pkg/event"
+)
+
+func TestWorker(t *testing.T) {
+	event := event.NewEvent("LogContext")
+	m := NewMiddleWare()
+	m.eventDriver.Put(event)
+
+	m.middleWorker()
+
+}