package dbapi

import (
	"dbapi/deliver"
	"dbapi/protomsg"
	"encoding/json"
	"fmt"
)

type ReqrepApi struct {

}

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

func (api ReqrepApi)SendRequestAndGetReply(reqStr string) string {
	sender := deliver.NewConsumer(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("sendedMsg")

	//recvMsg, err := sender.Recv()
	//if err ==nil {
	//	fmt.Println(string(recvMsg))
	//}

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