Remove fmt.Println for debug
This commit is contained in:
parent
c06201b8eb
commit
972f79da01
|
@ -231,7 +231,6 @@ func (serve *Serve) Run() (err error) {
|
|||
}
|
||||
serve.callbackFuncs = make(map[string]func(err error, result []byte))
|
||||
serve.queueCallback = fmt.Sprintf("%s.%s.%x", serve.projectName, serve.moduleName, rnd)
|
||||
fmt.Println(serve.queueCallback)
|
||||
serve.chanQueueCallback = make(chan *nats.Msg)
|
||||
serve.subj, err = serve.nc.ChanQueueSubscribe(serve.queueCallback, serve.projectName+"."+serve.moduleName, serve.chanQueueCallback)
|
||||
//serve.subj, err = serve.nc.ChanSubscribe(serve.queueCallback, serve.chanQueueCallback)
|
||||
|
|
|
@ -37,7 +37,6 @@ func shutdown() {
|
|||
}
|
||||
|
||||
func TestMain(m *testing.M) {
|
||||
fmt.Println("Main")
|
||||
setup()
|
||||
code := m.Run()
|
||||
shutdown()
|
||||
|
@ -46,7 +45,6 @@ func TestMain(m *testing.M) {
|
|||
|
||||
func TestRegisterFunction(t *testing.T) {
|
||||
err := serve.RegisterFunction("testFunc", func(header *network.Header, paylod []byte) (result []byte, err error) {
|
||||
fmt.Println(`Hello world`)
|
||||
return []byte("Hello world"), nil
|
||||
})
|
||||
if err != nil {
|
||||
|
|
Loading…
Reference in New Issue
Block a user