chrislu 17 hours ago
parent
commit
bf0d82a915
  1. 2
      other/mq_client_example/agent_pub_record/agent_pub_record.go
  2. 2
      other/mq_client_example/agent_sub_record/agent_sub_record.go
  3. 0
      other/mq_client_example/example/my_record.go

2
weed/mq/client/cmd/agent_pub_record/agent_pub_record.go → other/mq_client_example/agent_pub_record/agent_pub_record.go

@ -3,8 +3,8 @@ package main
import ( import (
"flag" "flag"
"fmt" "fmt"
"github.com/seaweedfs/seaweedfs/other/mq_client_example/example"
"github.com/seaweedfs/seaweedfs/weed/mq/client/agent_client" "github.com/seaweedfs/seaweedfs/weed/mq/client/agent_client"
"github.com/seaweedfs/seaweedfs/weed/mq/client/cmd/example"
"github.com/seaweedfs/seaweedfs/weed/mq/schema" "github.com/seaweedfs/seaweedfs/weed/mq/schema"
"log" "log"
"sync" "sync"

2
weed/mq/client/cmd/agent_sub_record/agent_sub_record.go → other/mq_client_example/agent_sub_record/agent_sub_record.go

@ -3,8 +3,8 @@ package main
import ( import (
"flag" "flag"
"fmt" "fmt"
"github.com/seaweedfs/seaweedfs/other/mq_client_example/example"
"github.com/seaweedfs/seaweedfs/weed/mq/client/agent_client" "github.com/seaweedfs/seaweedfs/weed/mq/client/agent_client"
"github.com/seaweedfs/seaweedfs/weed/mq/client/cmd/example"
"github.com/seaweedfs/seaweedfs/weed/mq/topic" "github.com/seaweedfs/seaweedfs/weed/mq/topic"
"github.com/seaweedfs/seaweedfs/weed/pb/schema_pb" "github.com/seaweedfs/seaweedfs/weed/pb/schema_pb"
"github.com/seaweedfs/seaweedfs/weed/util" "github.com/seaweedfs/seaweedfs/weed/util"

0
weed/mq/client/cmd/example/my_record.go → other/mq_client_example/example/my_record.go

Loading…
Cancel
Save