diff --git a/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/ProtocolFactory.java b/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/ProtocolFactory.java
index 8240f182f5..783af311ad 100644
--- a/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/ProtocolFactory.java
+++ b/eventmesh-connectors/eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/protocol/ProtocolFactory.java
@@ -78,7 +78,7 @@ public Protocol getInstance(String name) {
         }
 
         if (classes.containsKey(name)) {
-            synchronized (ProtocolFactory.class) {
+            synchronized (this) {
                 // double check
                 if (instances.containsKey(name)) {
                     return instances.get(name);