diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-10 01:18:56 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-10 01:18:56 +0300 |
| commit | 4fcb5979fad87f6e268f5b9df91ee2ee91e9ef16 (patch) | |
| tree | 30ed85120f8a39fd07756af9f5ce3422cf318971 /plugins/jobs/brokers/amqp/plugin.go | |
| parent | 4566f88004e81d3229222d82614c15346ac2e47d (diff) | |
AMQP job driver...
Update main driver's interface, add Consume(*pipeline) method. Implement
it on the amqp and ephemeral drivers.
Fix error with incorrect order of Register <-> Consume method calls.
Implement rabbitMQ driver, add timeouts, dead-letter-exchange,
packing-unpacking of the amqp messages.
Implement AMQP redialer in case of network error as well as channels
re-creation.
Update drawio diagram.
Update .rr.yaml jobs configuration, add all amqp options. Implement
Ack/Nack.
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'plugins/jobs/brokers/amqp/plugin.go')
| -rw-r--r-- | plugins/jobs/brokers/amqp/plugin.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/plugins/jobs/brokers/amqp/plugin.go b/plugins/jobs/brokers/amqp/plugin.go index 174cb006..74f9a174 100644 --- a/plugins/jobs/brokers/amqp/plugin.go +++ b/plugins/jobs/brokers/amqp/plugin.go @@ -8,7 +8,7 @@ import ( ) const ( - name string = "amqp" + pluginName string = "amqp" ) type Plugin struct { @@ -23,7 +23,7 @@ func (p *Plugin) Init(log logger.Logger, cfg config.Configurer) error { } func (p *Plugin) Name() string { - return name + return pluginName } func (p *Plugin) JobsConstruct(configKey string, pq priorityqueue.Queue) (jobs.Consumer, error) { |