Effect CommunityEC
Effect Community•9mo ago
Vinnie

Spans not appearing in telemetry for MQTT message handling with NodeRuntime.runMain

I'm using NodeRuntime.runMain, with a program that listens to MQTT for messages. The only span's I'm seeing are the startup code from when the server starts up, but not any of the other effects.

This function is called on startup, and the messages are actually correctly handled, but the spans just don't show up in the telemetry data

    const addMessageHandler = (client, handler) => {
      return Effect.sync(() => {

        client.on("message", (topic, payload, packet) => {
          const effect = Effect.gen(function* () {
            // ... 
            yield* handler(topic, payload, packet);
          }).pipe(Effect.withSpan("MqttConnService:onMessage"));

          Effect.runFork(effect);
        });
      });
    };


yield* mqttService.addMessageHandler(client, messageHandler);
Was this page helpful?