regmicmahesh

package main

import (
	"flag"
	"log"
	"net/http"
	"os"
)

var folderToServe string

regmicmahesh

import pika
import logging

class Producer:

    def __init__(self,host='localhost', exchanges=[], queues=[], conn_params=None):
        self.queueNames = [ x.get('queue') for queue in queues ]
        self.exchangeNames = [ x.get('exchange') for exchange in exchanges ]
        if conn_params:
            self.connection = pika.BlockingConnection(conn_params)