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(*args, **kwargs)¶ Bases:
intelmq.bots.outputs.amqptopic.output.AMQPTopicOutputBot,intelmq.lib.bot.CollectorBotCollect 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
