diff --git a/lib/src/broker/event_system_connector.dart b/lib/src/broker/event_system_connector.dart
index e8db6b726a5731787da3c56ea715ce8f27ce1a5c..62f09fd40d1a821ce0b477ca8db6d43f9366f9a4 100644
--- a/lib/src/broker/event_system_connector.dart
+++ b/lib/src/broker/event_system_connector.dart
@@ -2,6 +2,7 @@ import 'dart:convert';
 
 import 'package:crypto/crypto.dart';
 import 'package:dart_amqp/dart_amqp.dart';
+import 'package:flutter/foundation.dart';
 
 //import 'package:s3i_flutter/src/broker/messages/event_system_messages.dart';
 import 'package:s3i_flutter/src/broker/messages/i40_message.dart';
@@ -99,6 +100,14 @@ class EventSystemConnector {
 
   /// Sets a queue binding to the given [eventTopic]
   Future<void> subscribeNamedEvent({required Map<String, List<Function(I40EventMessage event)>> events}) async {
+    if(kIsWeb){
+      _eventCallbacks = events;
+      for(var eventTopic in events.keys){
+        eventBrokerConnector.startConsuming(eventTopic);
+      }
+      return;
+    }
+
     final String thisThingId = s3iCore.authManager.clientIdentity.id;
     // create event queue with desired binding if not existing yet
     var _endpoint = await s3iCore.createEventQueueBinding(thisThingId, events.keys.toList());