Skip to content

Instantly share code, notes, and snippets.

@akash-gautam
Created September 12, 2018 06:29
Show Gist options
  • Save akash-gautam/d4aaeb77473cde7496b47c2695b66390 to your computer and use it in GitHub Desktop.
Save akash-gautam/d4aaeb77473cde7496b47c2695b66390 to your computer and use it in GitHub Desktop.
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