intelmq.bots.collectors.amqp package

Submodules

intelmq.bots.collectors.amqp.collector_amqp module

Collecting from a (remote) AMQP Server and fetching either intelmq or any other messages.

class intelmq.bots.collectors.amqp.collector_amqp.AMQPCollectorBot(bot_id: str, start: bool = False, sighup_event=None, disable_multithreading: bool = None)

Bases: intelmq.bots.outputs.amqptopic.output.AMQPTopicOutputBot, intelmq.lib.bot.CollectorBot

Collect data from an AMQP Server and fetch either intelmq or any other messages. Requires the pika python library. Inheriting from AMQPTopicOutputBot for connect_server method

connection_attempts = 3
connection_heartbeat = 3600
connection_host = '127.0.0.1'
connection_port = 5672
connection_vhost = None
expect_intelmq_message = False
init()
password = None
process()

Stop the Bot if cannot connect to AMQP Server after the defined connection attempts

queue_name = None
use_ssl = False
username = None
intelmq.bots.collectors.amqp.collector_amqp.BOT

alias of intelmq.bots.collectors.amqp.collector_amqp.AMQPCollectorBot

Module contents