package main

import (
    "log"

    "github.com/micro/go-micro/server"
    "github.com/micro/go-plugins/broker/rabbitmq"

    micro "github.com/micro/go-micro"
)


func main() {
    // Create a new service. Optionally include some options here.
    service := micro.NewService(
        micro.Name("go-micro-rabbit"),
        micro.Broker(rabbitmq.NewBroker()),
    )

    // Init will parse the command line flags.
    service.Init()

    // Register handler
    proto.RegisterGreeterHandler(service.Server(), new(Greeter))

    micro.RegisterSubscriber("micro-exchange", service.Server(), myFunc, server.SubscriberQueue("my-queue"))

    // Run the server
    if err := service.Run(); err != nil {
        log.Fatal(err)
    }
}