<commit_before>package main

import (
	"fmt"
	"github.com/streadway/amqp"
	"koding/tools/amqputil"
	"koding/migrators/mongo"
	"log"
)

var (
	EXCHANGE_NAME     = "a-relationshipExchange"
	WORKER_QUEUE_NAME = "relationshipEventWorker"
)

type Consumer struct {
	conn    *amqp.Connection
	channel *amqp.Channel
}

func main() {
	log.Println("Neo4J Feeder worker started")
	startConsuming()
	//looooop forever
	select {}
}

func startConsuming() {

	c := &Consumer{
		conn:    nil,
		channel: nil,<commit_msg>[go][koding][workers] created a message structure for incoming messages from mq<commit_after>package main

import (
	"fmt"
	"github.com/streadway/amqp"
	"koding/tools/amqputil"
	"koding/migrators/mongo"
	"log"
)

var (
	EXCHANGE_NAME     = "a-relationshipExchange"
	WORKER_QUEUE_NAME = "relationshipEventWorker"
)

type Consumer struct {
	conn    *amqp.Connection
	channel *amqp.Channel
}

type Message struct {
	Event string `json:"event"`
	Data []EventData
}

type EventData struct {
	SourceName string
	SourceId   string
	TargetName string
	TargetId   string
	As         string
}

func main() {
	log.Println("Neo4J Feeder worker started")
	startConsuming()
	//looooop forever
	select {}
}

func startConsuming() {

	c := &Consumer{
		conn:    nil,
		channel: nil,
{'fraction_non_alphanumeric': 0.11242138364779874, 'fraction_numerical': 0.0015723270440251573, 'mean_word_length': 4.092, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '5269221', 'n_tokens_mistral': 479, 'n_tokens_neox': 467, 'n_words': 105}