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: AMQPTopicOutputBot, 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: int = 3

connection_heartbeat: int = 3600

connection_host: str = '127.0.0.1'

connection_port: int = 5672

connection_vhost: str = None

expect_intelmq_message: bool = False

init()

password: str = None

process()

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

queue_name: str = None

use_ssl: bool = False

username: str = None

intelmq.bots.collectors.amqp.collector_amqp.BOT

alias of AMQPCollectorBot

Module contents