activity

README

Apache Pulsar Activity

This activity publishes messages on a topic in a Apache Pulsar.

Flogo CLI

flogo install github.com/project-flogo/messaging-contrib/pulsar/activity

Configuration

Settings:

Name	Type	Description
connection	any	The connection object which is use to connect to pulsar - REQUIRED Connection
topic	string	The Pulsar topic on which to place the message - REQUIRED

Input:

Name	Type	Description
payload	string	The message to send

Documentation

Index

• func New(ctx activity.InitContext) (activity.Activity, error)
• type Activity
  • func (a *Activity) Eval(ctx activity.Context) (done bool, err error)
  • func (a *Activity) Metadata() *activity.Metadata
• type Input
  • func (r *Input) FromMap(values map[string]interface{}) error
  • func (r *Input) ToMap() map[string]interface{}
• type Settings

Functions

func New

func New(ctx activity.InitContext) (activity.Activity, error)

New optional factory method, should be used if one activity instance per configuration is desired

Types

type Activity

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

Activity is an sample Activity that can be used as a base to create a custom activity

func (*Activity) Eval

func (a *Activity) Eval(ctx activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - Logs the Message

func (*Activity) Metadata

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

Metadata returns the activity's metadata

type Input

type Input struct {
	Payload string `md:"payload,required"`
}

func (*Input) FromMap

func (r *Input) FromMap(values map[string]interface{}) error

func (*Input) ToMap

func (r *Input) ToMap() map[string]interface{}

type Settings

type Settings struct {
	Connection connection.Manager `md:"connection"`
	Topic      string             `md:"topic,required"`
}