doc.go

// Package events implements a messaging library
//
// About
//
// goevents allows to dispatch events between applications.
//
// An application produces events based on actions.
// Another application consume these events and maybe create new events.
//
// Supported Transport
//
// AMQP
//
// How to use
//
// The consumer
//
//    conn, err := NewConnection("amqp://guest:guest@127.0.0.1:5672/", "events-queue", "events-exchange")
//
//    if err != nil {
//        panic(err)
//    }
//
//    c, err := NewConsumer(conn, false)
//
//    if err != nil {
//        panic(err)
//    }
//
//    c.Subscribe("my_action", func(body []byte) bool {
//        fmt.Println(body)
//        return true
//    })
//
// The producer
//
//    conn, err := NewConnection("amqp://guest:guest@127.0.0.1:5672/", "events-queue", "events-exchange")
//
//    if err != nil {
//        panic(err)
//    }
//
//    p, err := NewProducer(conn)
//
//    if err != nil {
//        panic(err)
//    }
//
//    err = p.Publish("my_action", []byte("message"))
//
//    if err != nil {
//        panic(err)
//    }
//
package events