diff options
Diffstat (limited to 'weed/mq/cmd/qsend/qsend.go')
| -rw-r--r-- | weed/mq/cmd/qsend/qsend.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/weed/mq/cmd/qsend/qsend.go b/weed/mq/cmd/qsend/qsend.go index 34f7e6dc5..c80b220b8 100644 --- a/weed/mq/cmd/qsend/qsend.go +++ b/weed/mq/cmd/qsend/qsend.go @@ -5,6 +5,7 @@ import ( "flag" "fmt" "github.com/seaweedfs/seaweedfs/weed/mq/client" + "github.com/seaweedfs/seaweedfs/weed/mq/messages" "os" "time" ) @@ -24,7 +25,7 @@ func main() { err := eachLineStdin(func(line string) error { if len(line) > 0 { - if err := publisher.Publish(&client.Message{ + if err := publisher.Publish(&messages.Message{ Key: nil, Content: []byte(line), Properties: nil, |