Skip to content

Instantly share code, notes, and snippets.

@velotiotech

velotiotech/main.go

Created Jun 11, 2020
Embed
What would you like to do?
package main
import (
"time"
"velotio.com/consumer"
"velotio.com/producer"
"velotio.com/publisher"
)
func main() {
go producer.StartKinesisProducer()
go publisher.StartMQTTPublisher()
time.Sleep(5 * time.Second)
consumer.StartKinesisConsumer()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.