fairymq / fairymq-go Goto Github PK

go get github.com/fairymq/fairymq-go

go mod download github.com/fairymq/fairymq-go

	client := &fairymqgo.Client{
		Host:      "", // i.e 0.0.0.0
		PublicKey: "", // i.e example.public.pem
	}
	
	err := client.Configure()
	if err != nil {
		log.Fatalf(err.Error())
	}

	err := client.Enqueue([]byte("Hello world"))
	if err != nil {
		log.Fatalf(err.Error())
	}

	err = client.Enqueue([]byte("Hello again"))
	if err != nil {
		log.Fatalf(err.Error())
	}

	first, err := client.FirstIn() // Get first up in queue
	if err != nil {
		log.Fatalf(err.Error()) 
	}
	
	//.. do something with last message bytes