-
Notifications
You must be signed in to change notification settings - Fork 78
/
activity.go
executable file
·42 lines (32 loc) · 1.03 KB
/
activity.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
package error
import (
"github.com/TIBCOSoftware/flogo-lib/core/activity"
"github.com/TIBCOSoftware/flogo-lib/logger"
)
// log is the default package logger
var log = logger.GetLogger("activity-tibco-error")
const (
ivMessage = "message"
ivData = "data"
)
// ErrorActivity is an Activity that used to cause an explicit error in the flow
// inputs : {message,data}
// outputs: node
type ErrorActivity struct {
metadata *activity.Metadata
}
// NewActivity creates a new AppActivity
func NewActivity(metadata *activity.Metadata) activity.Activity {
return &ErrorActivity{metadata: metadata}
}
// Metadata returns the activity's metadata
func (a *ErrorActivity) Metadata() *activity.Metadata {
return a.metadata
}
// Eval implements api.Activity.Eval - Invokes a REST Operation
func (a *ErrorActivity) Eval(context activity.Context) (done bool, err error) {
mesg := context.GetInput(ivMessage).(string)
data := context.GetInput(ivData)
log.Debugf("Message :'%s', Data: '%+v'", mesg, data)
return false, activity.NewError(mesg, "", data)
}