| | |
| | | handler.AckReceived(a) |
| | | |
| | | case r := <-respCh: |
| | | fmt.Println("enter respch: r.payload", len(r.Payload)) |
| | | if r.From == "" { |
| | | break OUTER |
| | | } |
| | | handler.ResponseReceived(r) |
| | | fmt.Println("enter respch: r.payload", len(r.Payload)) |
| | | |
| | | case <-c.ShutdownCh: |
| | | return 1 |
| | |
| | | return errors.New("get current path error") |
| | | } |
| | | |
| | | filepath := fmt.Sprintf("self: %stest.db", path) |
| | | fmt.Println(filepath) |
| | | filepath := fmt.Sprintf("%stest.db", path) |
| | | fmt.Println("self: ========>", filepath) |
| | | db, err := New(filepath, "", false) |
| | | if err != nil { |
| | | fmt.Println("new db database: ", err) |