amazonsqssend

README

Send SQS Message

Send a message using Amazon Simple Queue Service (SQS)

Installation

flogo install github.com/retgits/flogo-components/activity/amazonsqssend

Link for flogo web:

https://github.com/retgits/flogo-components/activity/amazonsqssend

Schema

Inputs and Outputs:

{
    "inputs": [
        {
            "name": "awsAccessKeyID",
            "type": "string",
            "required": false
        },
        {
            "name": "awsSecretAccessKey",
            "type": "string",
            "required": false
        },
        {
            "name": "awsRegion",
            "type": "string",
            "required": true
        },
        {
            "name": "queueUrl",
            "type": "string",
            "required": true
        },
        {
            "name": "messageBody",
            "type": "string",
            "required": true
        }
    ],
    "outputs": [
        {
            "name": "result",
            "type": "string"
        }
    ]
}

Inputs

Input	Description
awsAccessKeyID	Your AWS Access Key (only needed if you don't give your Lambda function rights to interact with Amazon SQS)
awsSecretAccessKey	Your AWS Secret Key (only needed if you don't give your Lambda function rights to interact with Amazon SQS)
awsRegion	The region your queue is in
queueUrl	The URL of your SQS queue
messageBody	The body of the message you want to send

Ouputs

Output	Description
result	The ID of the message sent to SQS

Documentation

Overview

Package amazonsqssend sends a message using Amazon SQS

Index

• func NewActivity(metadata *activity.Metadata) activity.Activity
• type ExpressionAttribute
• type MyActivity
  • func (a *MyActivity) Eval(context activity.Context) (done bool, err error)
  • func (a *MyActivity) Metadata() *activity.Metadata

Functions

func NewActivity

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

NewActivity creates a new activity

Types

type ExpressionAttribute

type ExpressionAttribute struct {
	Name  string
	Value string
}

ExpressionAttribute is a structure representing the JSON payload for the expression syntax

type MyActivity

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

MyActivity is a stub for your Activity implementation

func (*MyActivity) Eval

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

Eval implements activity.Activity.Eval

func (*MyActivity) Metadata

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

Metadata implements activity.Activity.Metadata