Hello,

after importing your contrib in the web UI, builds with your activity fail to run,

Failed to create engine: error unmarshalling flow: create task [mqtt_3] error: activity '#mqtt' not imported

using simple flow

{
  "name": "Edge",
  "type": "flogo:app",
  "version": "0.0.1",
  "appModel": "1.1.0",
  "description": "Edge MQTT",
  "imports": [
    "github.com/jvanderl/flogo-components/activity/mqtt",
    "github.com/project-flogo/contrib/trigger/timer",
    "github.com/project-flogo/flow"
  ],
  "triggers": [
    {
      "id": "timer",
      "ref": "#timer",
      "name": "Timer",
      "description": "Simple Timer trigger",
      "handlers": [
        {
          "settings": {
            "startDelay": "2s",
            "repeatInterval": "10s"
          },
          "action": {
            "ref": "#flow",
            "settings": {
              "flowURI": "res://flow:mqtt"
            }
          }
        }
      ]
    }
  ],
  "resources": [
    {
      "id": "flow:mqtt",
      "data": {
        "name": "MQTT",
        "metadata": {
          "output": [
            {
              "name": "output",
              "type": "any"
            }
          ]
        },
        "tasks": [
          {
            "id": "mqtt_3",
            "name": "Send MQTT Message",
            "description": "Pubishes message on MQTT topic",
            "activity": {
              "ref": "#mqtt",
              "input": {
                "broker": "tcp://localhost:1883",
                "id": "=flogo_publish",
                "topic": "=flogo",
                "qos": "0",
                "message": "Hello from Flogo!"
              }
            }
          }
        ]
      }
    }
  ]
}

please fix: o.Data, _ = coerce.ToAny(values["data"])

Hi @jvanderl,

Thank you so much for your contribution here. I am trying your sample to read from an SCD device.

I was wondering if you have tried your module on the latest flogo yet? I am getting some compilation errors.

warn: [18:58:32.295] Engine does not exist. Creating...
info: [18:58:32.296] Exec command: flogo create -f /flogo-web/local/engines/exported-app-build.json app-build in /flogo-web/local/engines
info: [18:58:32.299] run command: flogo create -f /flogo-web/local/engines/exported-app-build.json app-build
engine:create: 10648.679ms
info: [18:58:42.945] undefined {"durationMs":10657}
info: [18:58:42.946] [log] Build flogo: "flogo build -o,-e" compileOpts:
info: [18:58:42.950] run command: flogo build -o -e
warn: [18:58:43.156] command exited with code 1: flogo build -o -e
error: [18:58:43.156] Error building project: # github.com/jvanderl/go-gatt
/go/pkg/mod/github.com/jvanderl/[email protected]/central.go:118:11: undefined: central

Kind regards,

Hi Jan,

I am new to Tibco Flogo . Trying to learn and implement more interested towards Web UI side.

Currently , I am trying 2 things.

1.From MQTTLens I am trying to publish sample message and I want to receive the same message at
Tibco Flogo which I am using MQTTReciever and log. Please find attached screenshot 1 & and 2

2. I am trying to build sample flow in web UI.
   Publish message using MQTTSend activity
   and Receive the Message using MQTTReciever.

Can you please help me on both the scenarios since I am struggling with it from quit long time.

but no success.
![task1-1](https

://user-images.githubusercontent.com/29427328/28373596-64500e72-6cc0-11e7-81a6-e5c4d5366c81.png)

This is for second Task

Thanks in Advance!

Regards,
Ravikiran