|
|
@ -2,12 +2,21 @@ package sylvilagus
|
|
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
"log"
|
|
|
|
"log"
|
|
|
|
|
|
|
|
"os"
|
|
|
|
)
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
"github.com/streadway/amqp"
|
|
|
|
"github.com/streadway/amqp"
|
|
|
|
)
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
var AMQP_URI = os.Getenv("SYLVILAGUS_AMQP_URI")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func init() {
|
|
|
|
|
|
|
|
if len(AMQP_URI) < 1 {
|
|
|
|
|
|
|
|
log.Fatal("SYLVILAGUS_AMQP_URI is not defined!")
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func CreateHelloTopology(connection *amqp.Connection) (*amqp.Channel, error) {
|
|
|
|
func CreateHelloTopology(connection *amqp.Connection) (*amqp.Channel, error) {
|
|
|
|
channel, err := connection.Channel()
|
|
|
|
channel, err := connection.Channel()
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|