conf := amqp.Config{
    Connection: amqp.ConnectionConfig{
        AmqpURI:   "amqp://user:password@127.0.0.1:5672/"
    },
    Marshaler: amqp.DefaultMarshaler{},
    Exchange: amqp.ExchangeConfig{
        GenerateName: func(topic string) string {
            return "test_exchange"
        },
        Type:    "fanout",
        Durable: false,
    },
    Queue: amqp.QueueConfig{
        GenerateName: func(topic string) string {
            hostname, err := os.Hostname()
            if err != nil {
                hostname = "unknown"
            }

            return "mysvc_" + hostname + "_" + strconv.Itoa(rand.Int())
        },
        Exclusive:  true,
    },
    QueueBind: amqp.QueueBindConfig{
        GenerateRoutingKey: func(topic string) string {
            return ""
        },
    },
    Publish: amqp.PublishConfig{
        GenerateRoutingKey: func(topic string) string {
            return topic
        },
    },
    Consume: amqp.ConsumeConfig{
        Qos: amqp.QosConfig{
            PrefetchCount: 5,
        },
    },
    TopologyBuilder: &amqp.DefaultTopologyBuilder{},
}