AMQP pipeline: arguments are ignored

[ghost]

intelmq/intelmq/lib/pipeline.py

Lines 436 to 457 in e54b470

	self.host = getattr(self,
	"{}_pipeline_host".format(queues_type),
	"127.0.0.1")
	self.port = getattr(self,
	"{}_pipeline_port".format(queues_type), 5672)
	self.username = getattr(self,
	"{}_pipeline_username".format(queues_type),
	None)
	self.password = getattr(self,
	"{}_pipeline_password".format(queues_type),
	None)
	# socket_timeout is None by default, which means no timeout
	self.socket_timeout = getattr(self,
	"{}_pipeline_socket_timeout".format(
	queues_type),
	None)
	self.load_balance = getattr(self, "load_balance", False)
	self.virtual_host = getattr(self,
	"{}_pipeline_amqp_virtual_host".format(queues_type),
	'/')
	self.ssl = getattr(self, "{}_pipeline_ssl".format(queues_type), False)
	self.exchange = getattr(self, "{}_pipeline_amqp_exchange".format(queues_type), "")

The amqp class accesses self to get the parameters, while the redis class uses self.pipeline_args. The amqp pipeline does not receive any parameters because of that bug.