Skip to content

Commit 0b9710e

Browse files
Nikolajlszymap
authored andcommitted
Update subscription get message by id typo lederId to ledgerId (#1699)
* Update subscription get message by id typo lederId to edgerId * Adjust after merge, use ledgerID for get message by id (cherry picked from commit b9416b7)
1 parent 4db78e6 commit 0b9710e

File tree

1 file changed

+11
-11
lines changed

1 file changed

+11
-11
lines changed

pkg/ctl/subscription/get_message_by_id.go

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -31,41 +31,41 @@ import (
3131

3232
func GetMessageByIDCmd(vc *cmdutils.VerbCmd) {
3333
var desc cmdutils.LongDescription
34-
desc.CommandUsedFor = "This command is used for getting messages by the given legerID and entryID" +
34+
desc.CommandUsedFor = "This command is used for getting messages by the given ledgerID and entryID" +
3535
" for a subscription."
3636
desc.CommandPermission = "This command requires tenant admin and namespace produce or consume permissions."
3737

3838
var examples []cmdutils.Example
3939
examples = append(examples, cmdutils.Example{
40-
Desc: "Get message by the given legerID an entryID",
41-
Command: "pulsarctl subscription get-message-by-id --leger-id (leger-id) --entry-id (entry-id) (topic-name)",
40+
Desc: "Get message by the given ledgerID an entryID",
41+
Command: "pulsarctl subscription get-message-by-id --ledger-id (ledger-id) --entry-id (entry-id) (topic-name)",
4242
})
4343
desc.CommandExamples = examples
4444

4545
vc.SetDescription(
4646
"get-message-by-id",
47-
"Getting messages by the given legerID and entryID",
47+
"Getting messages by the given ledgerID and entryID",
4848
desc.ToString(),
4949
desc.ExampleToString(),
5050
)
5151

52-
var legerID int64
52+
var ledgerID int64
5353
var entryID int64
5454

5555
vc.SetRunFuncWithNameArg(func() error {
56-
return doGetMessageByID(vc, legerID, entryID)
56+
return doGetMessageByID(vc, ledgerID, entryID)
5757
}, "the topic name is not specified or the topic name is specified more than one")
5858

5959
vc.FlagSetGroup.InFlagSet("GetMessageByID", func(set *pflag.FlagSet) {
60-
set.Int64VarP(&legerID, "leger-id", "l", 0, "ledger id pointing to the desired ledger")
61-
cobra.MarkFlagRequired(set, "leger-id")
60+
set.Int64VarP(&ledgerID, "ledger-id", "l", 0, "ledger id pointing to the desired ledger")
61+
cobra.MarkFlagRequired(set, "ledger-id")
6262
set.Int64VarP(&entryID, "entry-id", "e", 0, "entry id pointing to the desired entry")
6363
cobra.MarkFlagRequired(set, "entry-id")
6464
})
6565
vc.EnableOutputFlagSet()
6666
}
6767

68-
func doGetMessageByID(vc *cmdutils.VerbCmd, legerID int64, entryID int64) error {
68+
func doGetMessageByID(vc *cmdutils.VerbCmd, ledgerID int64, entryID int64) error {
6969
// for testing
7070
if vc.NameError != nil {
7171
return vc.NameError
@@ -77,12 +77,12 @@ func doGetMessageByID(vc *cmdutils.VerbCmd, legerID int64, entryID int64) error
7777
}
7878

7979
client := cmdutils.NewPulsarClient()
80-
messages, err := client.Subscriptions().GetMessagesByID(*topic, legerID, entryID)
80+
messages, err := client.Subscriptions().GetMessagesByID(*topic, ledgerID, entryID)
8181
if err != nil {
8282
return err
8383
}
8484
if len(messages) == 0 {
85-
return fmt.Errorf("no message found with the given legerID and entryID")
85+
return fmt.Errorf("no message found with the given ledgerID and entryID")
8686
}
8787
message := messages[0]
8888
propertiesJSON, err := json.Marshal(message.GetProperties())

0 commit comments

Comments
 (0)