Publishing a message that exceeds the maximum gnatsd payload size

gistfile1.txt

package main

import (
	"log"

	gs "github.com/apcera/gnatsd/server"
	"github.com/apcera/nats"
)

func msg(n int) []byte {
	ret := []byte{}
	for i := 0; i < n; i++ {
		ret = append(ret, byte(i))
	}
	log.Printf("Created a message of length: %d", len(ret))
	return ret
}

func main() {
	nc, err := nats.Connect(nats.DefaultURL)
	if err != nil {
		log.Printf("Unable to connect: %v", err)
		return
	}

	subj := "Request"
	reply := "Reply"

	badMsg := nats.Msg{Subject: subj, Reply: reply, Data: msg(gs.MAX_PAYLOAD_SIZE * 2)}
	err = nc.PublishMsg(&badMsg)
	log.Printf("err = %v", err)
	log.Printf("closed = %v", nc.IsClosed())
	log.Printf("LastError = %v", nc.LastError())
	
	goodMsg := nats.Msg{Subject: subj, Reply: reply, Data: msg(100)}
	err = nc.PublishMsg(&goodMsg)
	log.Printf("err = %v", err)
}