amqpact

README

---

title: AMQP weight: 15709

amqp

This trigger provides your flogo application the ability to start a flow via AMQP

Installation

flogo install https://github.com/mtorre-iot/flogo-contrib/trigger/amqp

Schema

Settings, Outputs and Endpoint:

{
  "settings":[
    {
      "name": "requestHostName",
      "type": "string",
      "required": true
    },
    {
      "name": "requestPort",
      "type": "string",
      "required": true
    },
    {
      "name": "requestExchangeName",
      "type": "string",
      "required": true
    },
    {
      "name": "requestExchangeType",
      "type": "string",
      "required": true
    },
    {
      "name": "requestRoutingKey",
      "type": "string",
      "required": true
    },
    {
      "name": "requestUser",
      "type": "string",
      "required": true
    },    
    {
      "name": "requestPassword",
      "type": "string",
      "required": true
    },
    {
      "name": "requestDurable",
      "type": "string",
      "required": false
    },
    {
      "name": "requestAutoDelete",
      "type": "string",
      "required": false
    },
    {
      "name": "requestReliable",
      "type": "string",
      "required": false
    },
    {
      "name": "responseHostName",
      "type": "string",
      "required": false
    },
    {
      "name": "responsePort",
      "type": "string",
      "required": false
    },
    {
      "name": "responseExchangeName",
      "type": "string",
      "required": false
    },
    {
      "name": "responseExchangeType",
      "type": "string",
      "required": false
    },
    {
      "name": "responseRoutingKey",
      "type": "string",
      "required": false
    },
    {
      "name": "responseUser",
      "type": "string",
      "required": false
    },    
    {
      "name": "responsePassword",
      "type": "string",
      "required": false
    },
    {
      "name": "responseDurable",
      "type": "string",
      "required": false
    },
    {
      "name": "responseAutoDelete",
      "type": "string",
      "required": false
    },
    {
      "name": "responseReliable",
      "type": "string",
      "required": false
    }
  ],
  "output": [
    {
      "name": "message",
      "type": "string"
    }
  ],
  "reply": [
    {
      "name": "data",
      "type": "object"
    }
  ],
  "handler": {
    "settings": [
      {
        "name": "topic",
        "type": "string",
        "required": true
      }
    ]
  }
}

Example Configurations

Triggers are configured via the triggers.json of your application. The following are some example configuration of the AMQP Trigger.

Start a flow

Configure the Trigger to start "myflow". "settings" "topic" is the topic it uses to listen for incoming messages. So in this case the "endpoints" "settings" "topic" is "test_start" will start "myflow" flow. The incoming message payload has to define "replyTo" which is the the topic used to reply on.

{
  "triggers": [
    {
      "id": "receive_amqp_message",
      "ref": "github.com/mtorre-iot/flogo-contrib/trigger/amqp",
      "name": "Receive AMQP Message",
      "description": "Simple AMQP Trigger",
      "settings": {
        "requestHostName": "localhost",
        "requestPort": "5672",
        "requestExchangeName": "AMQPRequestExchange",
        "requestExchangeType": "topic",
        "requestRoutingKey": "#",
        "requestUser": "guest",
        "requestPassword": "guest",
        "responseHostName": "localhost",
        "responsePort": "5672",
        "responseExchangeName": "AMQPResponseExchange",
        "responseExchangeType": "topic",
        "responseRoutingKey": "#",
        "responseUser": "guest",
        "responsePassword": "guest"
      },
      "handlers": [
        {
          "action": {
            "ref": "github.com/TIBCOSoftware/flogo-contrib/action/flow",
            "data": {
              "flowURI": "res://flow:amqp_application_test"
            },
            "mappings": {
              "input": [
                {
                  "mapTo": "message",
                  "type": "assign",
                  "value": "$.message"
                }
              ]
            }
          },
          "settings": {
            "topic": "update"
          }
        }
      ]
    }
  ]
}

Documentation

Index

• func CheckParameter(context activity.Context, attribute string) (string, error)
• func NewActivity(md *activity.Metadata) activity.Activity
• type AmqpActivity
  • func (a *AmqpActivity) Eval(context activity.Context) (done bool, err error)
  • func (a *AmqpActivity) Metadata() *activity.Metadata
  • func (a *AmqpActivity) PublishMessage(message string) error

Functions

func CheckParameter

func CheckParameter(context activity.Context, attribute string) (string, error)

func NewActivity

func NewActivity(md *activity.Metadata) activity.Activity

NewActivity creates a new AppActivity

Types

type AmqpActivity

type AmqpActivity struct {
	// contains filtered or unexported fields
}

AmqpActivity is simple AMQP Activity

func (*AmqpActivity) Eval

func (a *AmqpActivity) Eval(context activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - Logs the Message

func (*AmqpActivity) Metadata

func (a *AmqpActivity) Metadata() *activity.Metadata

Metadata returns the activity's metadata

func (*AmqpActivity) PublishMessage

func (a *AmqpActivity) PublishMessage(message string) error