listen

Documentation

Index

• Variables

Variables

var Cmd = &cobra.Command{
	Use:   "listen",
	Short: "listen",

	Run: func(cmd *cobra.Command, args []string) {
		log.Info("listen")

	},
}

var CmdEclair = &cobra.Command{
	Use:   "eclair",
	Short: "Listens on the specified eclair source",
	Run: func(cmd *cobra.Command, args []string) {
		logrus.Info("Listening on source: ", source)
		subscriber, err := autoload.NewSubscriber("eclair")
		if err != nil {
			logrus.Error("Failed to create subscriber: ", err)
			return
		}
		subscriber.Start()

		for msg := range subscriber.Listen() {
			logrus.Info("Received message: ", msg)
		}
	},
}

var CmdZmq = &cobra.Command{
	Use:   "zmq",
	Short: "Listens on the specified zmq source",
	Run: func(cmd *cobra.Command, args []string) {
		logrus.Info("Listening on source: ", source)
		subscriber, err := autoload.NewSubscriber("zmq")
		if err != nil {
			logrus.Error("Failed to create subscriber: ", err)
			return
		}

		subscriber.Start()

		for msg := range subscriber.Listen() {
			logrus.Info("Received message: ", msg)
			logrus.Info("Publishing message to destination: ", destination)
		}
	},
}