Add jobs protocol support for the AMQP driver

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

1 files changed, 28 insertions, 0 deletions

diff --git a/plugins/jobs/job/general.go b/plugins/jobs/job/general.go
index 2c7d04f0..d2a27373 100644
--- a/plugins/jobs/job/general.go
+++ b/plugins/jobs/job/general.go
@@ -29,3 +29,31 @@ type Job struct {
 	// Options contains set of PipelineOptions specific to job execution. Can be empty.
 	Options *Options `json:"options,omitempty"`
 }
+
+func (j Job) ID() string {
+	panic("implement me")
+}
+
+func (j Job) Priority() int64 {
+	panic("implement me")
+}
+
+func (j Job) Body() []byte {
+	panic("implement me")
+}
+
+func (j Job) Context() ([]byte, error) {
+	panic("implement me")
+}
+
+func (j Job) Ack() error {
+	panic("implement me")
+}
+
+func (j Job) Nack() error {
+	panic("implement me")
+}
+
+func (j Job) Requeue(delay uint32) error {
+	panic("implement me")
+}