Skip to content
Snippets Groups Projects
Commit 7b5c2050 authored by Jacob Peters's avatar Jacob Peters
Browse files

changed eventSubscribing for web

parent 1a689237
Branches web
No related tags found
No related merge requests found
......@@ -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());
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment