| | |
| | | break OUTER |
| | | } |
| | | handler.ResponseReceived(r) |
| | | fmt.Println("enter respch: r.payload", r.Payload) |
| | | fmt.Println("enter respch: r.payload", len(r.Payload)) |
| | | |
| | | case <-c.ShutdownCh: |
| | | return 1 |
| | |
| | | } |
| | | |
| | | /** my self example*/ |
| | | fmt.Println("x length is: ", payload) |
| | | fmt.Println("x length is: ", len(payload)) |
| | | |
| | | // // byte to file. |
| | | sdb.Dbconn.Close() |
| | |
| | | return errors.New("get current path error") |
| | | } |
| | | |
| | | filepath := fmt.Sprintf("%stest.db", path) |
| | | filepath := fmt.Sprintf("self: %stest.db", path) |
| | | fmt.Println(filepath) |
| | | db, err := New(filepath, "", false) |
| | | if err != nil { |