package dbapi

import (
	"basic.com/valib/deliver.git"
	"basic.com/pubsub/protomsg.git"
	"encoding/json"
	"fmt"
)

type ReqrepApi struct {

}

const (
	ReqRep_URL = "tcp://192.168.1.11:8002"
)

func (api ReqrepApi)SendRequestAndGetReply(reqStr string) string {
	sender := deliver.NewClient(deliver.Mode(deliver.ReqRep), ReqRep_URL)
	var sendMsg = protomsg.SdkMessage{}
	sendMsg.Cid = "kkkk"
	byteArr, _ := json.Marshal(sendMsg)
	err := sender.Send(byteArr)
	if err !=nil {
		fmt.Println(err)
	}

	fmt.Println("SendRequest")
	return ""
}