Browse Source

remove WIP

adding-message-queue-integration-tests
chrislu 7 months ago
parent
commit
49e1e56aa1
  1. 2
      weed/command/mq_agent.go
  2. 2
      weed/command/mq_broker.go

2
weed/command/mq_agent.go

@ -32,7 +32,7 @@ func init() {
var cmdMqAgent = &Command{
UsageLine: "mq.agent [-port=16777] [-broker=<ip:port>]",
Short: "<WIP> start a message queue agent",
Short: "start a message queue agent",
Long: `start a message queue agent
The agent runs on local server to accept gRPC calls to write or read messages.

2
weed/command/mq_broker.go

@ -43,7 +43,7 @@ func init() {
var cmdMqBroker = &Command{
UsageLine: "mq.broker [-port=17777] [-master=<ip:port>]",
Short: "<WIP> start a message queue broker",
Short: "start a message queue broker",
Long: `start a message queue broker
The broker can accept gRPC calls to write or read messages. The messages are stored via filer.

Loading…
Cancel
Save