diff --git a/job.go b/job.go index b3c0bba..03c20d8 100644 --- a/job.go +++ b/job.go @@ -694,12 +694,6 @@ func jobMsgRefresh(j Job) { err = setJobDone(j.ID64) logOnError(err, "joMsgClient : setJobDone") return - } else { - /* logOnError(err, "jobMsgRefresh : getObjMsg") - err = setJobDone(j.ID64) - logOnError(err, "joMsgClient : setJobDone") - return - */ } err = delObj(p.ObjID64) diff --git a/obj.go b/obj.go index 48740d0..421cf7f 100644 --- a/obj.go +++ b/obj.go @@ -447,7 +447,6 @@ func delObj(objId int64) error { return errors.New("Can only delete cacheObjSubType[`msg_auction_announce`].") } - log.Printf("delObj(%d)\n", objId) cacheObjMsg.Delete(objId) // better delete from cache before, worst case we reload after stmt, err := db.Prepare(`DELETE FROM obj WHERE id = ?`) diff --git a/workers.go b/workers.go index 81dd39e..14e1894 100644 --- a/workers.go +++ b/workers.go @@ -263,7 +263,7 @@ func MQTGCmdWorker(id int, cmds <-chan TGCommand) { if clt, ok := getLockedClient(c.FromUserID64, false); ok { j, err := json.Marshal(c) logOnError(err, "MQTGCmdWorker["+strconv.Itoa(id)+"] : Marshal(c)") - log.Printf("MQTGCmdWorker["+strconv.Itoa(id)+"] : new command.\n%s\n", string(j)) + //log.Printf("MQTGCmdWorker["+strconv.Itoa(id)+"] : new command.\n%s\n", string(j)) for clt.MQ.Connection == nil || clt.MQ.Connection.IsClosed() { clt.Active = false log.Printf("MQTGCmdWorker : Resetting MQ connection for #%d.\n", c.FromUserID64)