|
@@ -117,7 +117,7 @@ func (c *Controller) AttachDB() (int, string) {
|
|
// func (c *Controller) KafkaAnswer(body string) {
|
|
// func (c *Controller) KafkaAnswer(body string) {
|
|
|
|
|
|
// // c.Ctx.Answer.Body = []byte(body) // 쓸데없는 것 같은데 나중에 지
|
|
// // c.Ctx.Answer.Body = []byte(body) // 쓸데없는 것 같은데 나중에 지
|
|
-// // e.Tp("ReturnTopic=" + c.Ctx.ReturnTopic)
|
|
|
|
|
|
+// // fmt.Println("ReturnTopic=" + c.Ctx.ReturnTopic)
|
|
// if _, _, err := KafkaProducer(body,
|
|
// if _, _, err := KafkaProducer(body,
|
|
// c.Ctx.ReturnTopic, c.ConnString, XConfig["api_method"]); err != nil {
|
|
// c.Ctx.ReturnTopic, c.ConnString, XConfig["api_method"]); err != nil {
|
|
// e.MyErr("WERRWEEWQRFDFHQW", err, false)
|
|
// e.MyErr("WERRWEEWQRFDFHQW", err, false)
|
|
@@ -137,7 +137,7 @@ func (c *Controller) AnswerJson() {
|
|
// } else {
|
|
// } else {
|
|
// ret, _ = json.Marshal(c.Data["json"])
|
|
// ret, _ = json.Marshal(c.Data["json"])
|
|
// }
|
|
// }
|
|
- // // e.Tp(string(ret))
|
|
|
|
|
|
+ // // fmt.Println(string(ret))
|
|
// if c.Ctx.Ask.ApiType == "Kafka" {
|
|
// if c.Ctx.Ask.ApiType == "Kafka" {
|
|
// c.KafkaAnswer(string(ret))
|
|
// c.KafkaAnswer(string(ret))
|
|
// } else if c.Ctx.Ask.ApiType == "gRpc" {
|
|
// } else if c.Ctx.Ask.ApiType == "gRpc" {
|