echo_provider.go

package echo
 
type Connection interface {
  Subscribe(string, func(string))
  Publish(string, string)
}
 
// echo back any message sent to the "/echo" topic
func StartEchoProvider(connection Connection) {
  connection.Subscribe("/echo", func(message string) {
    connection.Publish("/echo", message)
  })
}