[GitHub] [rocketmq-client-go] fananchong opened a new issue #507: rocketmq.Producer cannot be instantiated twice

[GitBox <gi...@apache.org>]

fananchong opened a new issue #507:
URL: https://github.com/apache/rocketmq-client-go/issues/507


   My code is :
   
   ```go
   package main
   
   import (
   	"context"
   	"fmt"
   	"log"
   	"os"
   	"strconv"
   
   	"github.com/apache/rocketmq-client-go/v2"
   	"github.com/apache/rocketmq-client-go/v2/primitive"
   	"github.com/apache/rocketmq-client-go/v2/producer"
   	"github.com/apache/rocketmq-client-go/v2/rlog"
   )
   
   func testNewAndClose() {
   
   	rlog.SetLogLevel("error")
   
   	p, _ := rocketmq.NewProducer(
   		producer.WithNsResovler(primitive.NewPassthroughResolver([]string{"127.0.0.1:9876"})),
   		producer.WithRetry(2),
   	)
   	err := p.Start()
   	if err != nil {
   		fmt.Printf("start producer error: %s", err.Error())
   		os.Exit(1)
   	}
   	topic := "test5"
   
   	for i := 0; i < 1; i++ {
   		msg := &primitive.Message{
   			Topic: topic,
   			Body:  []byte("Hello RocketMQ Go Client! " + strconv.Itoa(i)),
   		}
   		_, err := p.SendSync(context.Background(), msg)
   
   		if err != nil {
   			fmt.Printf("send message error: %s\n", err)
   		} else {
   			fmt.Printf("send message success\n")
   		}
   	}
   	err = p.Shutdown()
   	if err != nil {
   		fmt.Printf("shutdown producer error: %s", err.Error())
   	}
   }
   
   // Package main implements a simple producer to send message.
   func main() {
   	testNewAndClose()
   	log.Printf("try again ...")
   	testNewAndClose()
   }
   ```
   
   and output is:
   
   ```vim
   fananchong@localhost:~/rocketmq-client-go/examples/producer/simple$ ./simple 
   send message success
   2020/07/06 10:36:34 try again ...
   send message error: service close is not running, please check
   ```
   
   The second instantiated object does not work.
   
   
   
   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-client-go] fananchong closed issue #507: rocketmq.Producer cannot be instantiated twice

[GitBox <gi...@apache.org>]

fananchong closed issue #507:
URL: https://github.com/apache/rocketmq-client-go/issues/507


   


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org