SQS driver.

Fix isssues in the AMQP driver.

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 31 insertions, 0 deletions

diff --git a/plugins/jobs/job/general.go b/plugins/jobs/job/general.go
new file mode 100644
index 00000000..2c7d04f0
--- /dev/null
+++ b/plugins/jobs/job/general.go
@@ -0,0 +1,31 @@
+package job
+
+// constant keys to pack/unpack messages from different drivers
+const (
+	RRID          string = "rr_id"
+	RRJob         string = "rr_job"
+	RRHeaders     string = "rr_headers"
+	RRPipeline    string = "rr_pipeline"
+	RRTimeout     string = "rr_timeout"
+	RRDelay       string = "rr_delay"
+	RRPriority    string = "rr_priority"
+	RRMaxAttempts string = "rr_max_attempts"
+)
+
+// Job carries information about single job.
+type Job struct {
+	// Job contains name of job broker (usually PHP class).
+	Job string `json:"job"`
+
+	// Ident is unique identifier of the job, should be provided from outside
+	Ident string `json:"id"`
+
+	// Payload is string data (usually JSON) passed to Job broker.
+	Payload string `json:"payload"`
+
+	// Headers with key-value pairs
+	Headers map[string][]string `json:"headers"`
+
+	// Options contains set of PipelineOptions specific to job execution. Can be empty.
+	Options *Options `json:"options,omitempty"`
+}