import (
 "log"
 "runtime"

 "github.com/nats-io/nats.go"
)

func main() {

 // Create server connection
 natsConnection, _ := nats.Connect("nats://yourusername:yoursecret@localhost:4222")
 log.Println("Connected")

 // Subscribe to subject
 log.Printf("Subscribing to subject 'bucketevents'\n")
 natsConnection.Subscribe("bucketevents", func(msg *nats.Msg) {

  // Handle the message

ess singleton_$less$colon$less; public static void <clinit>(); public final collection.immutable.Set$ Set(); public static void assert(boolean); public static void require(boolean); public static Object any2ArrowAssoc(Object); public static void println(Object); public static collection.mutable.ArrayOps genericArrayOps(Object); public static collection.mutable.ArrayOps refArrayOps(Object[]); public static String augmentString(String); public static Object any2stringadd(Object); public final Predef$$less$colon$less...