diff --git a/configurations/beelzebub.yaml b/configurations/beelzebub.yaml index 5d2cd09..8c18987 100644 --- a/configurations/beelzebub.yaml +++ b/configurations/beelzebub.yaml @@ -5,5 +5,5 @@ core: logDisableTimestamp: true logsPath: ./logs tracing: - rabbitMQEnabled: false + rabbitMQEnabled: true rabbitMQURI: "amqp://guest:guest@localhost:5672/" diff --git a/main.go b/main.go index 514a3bc..6fa013a 100644 --- a/main.go +++ b/main.go @@ -14,8 +14,7 @@ import ( var quit = make(chan struct{}) -var queue amqp.Queue -var channel amqp.Channel +var channel *amqp.Channel func main() { parser := parser.Init("./configurations/beelzebub.yaml", "./configurations/services/") @@ -37,16 +36,6 @@ func main() { channel, err := conn.Channel() failOnError(err, "Failed to open a channel") defer channel.Close() - - queue, err = channel.QueueDeclare( - "event", // name - false, // durable - false, // delete when unused - false, // exclusive - false, // no-wait - nil, // arguments - ) - failOnError(err, "Failed to declare a queue") } // Init Protocol strategies @@ -88,9 +77,19 @@ func traceStrategyStdout(event tracer.Event) { }).Info("New Event") //TODO check amqp.Channe - if queue != (amqp.Queue{}) { + if channel != nil { eventJSON, err := json.Marshal(event) - failOnError(err, "Failed to publish a message") + failOnError(err, "Failed to Marshal Event") + + queue, err := channel.QueueDeclare( + "event", + false, + false, + false, + false, + nil, + ) + failOnError(err, "Failed to declare a queue") err = channel.Publish( "",