granule_ingester/granule_ingester/main.py [169:178]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        consumer = MessageConsumer(rabbitmq_host=args.rabbitmq_host,
                                   rabbitmq_username=args.rabbitmq_username,
                                   rabbitmq_password=args.rabbitmq_password,
                                   rabbitmq_queue=args.rabbitmq_queue,
                                   data_store_factory=partial(cassandra_factory,
                                                              cassandra_contact_points,
                                                              cassandra_port,
                                                              cassandra_keyspace,
                                                              cassandra_username,
                                                              cassandra_password),
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



granule_ingester/granule_ingester/main.py [203:212]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        consumer = MessageConsumer(rabbitmq_host=args.rabbitmq_host,
                                   rabbitmq_username=args.rabbitmq_username,
                                   rabbitmq_password=args.rabbitmq_password,
                                   rabbitmq_queue=args.rabbitmq_queue,
                                   data_store_factory=partial(cassandra_factory,
                                                              cassandra_contact_points,
                                                              cassandra_port,
                                                              cassandra_keyspace,
                                                              cassandra_username,
                                                              cassandra_password),
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -