Skip to content

[pulsar-client-tools] Add support for websocket produce/consume command - #3835

Merged
merlimat merged 3 commits into
apache:masterfrom
rdhabalia:ws_cmd
Mar 19, 2019
Merged

merlimat merged 3 commits into
apache:masterfrom
rdhabalia:ws_cmd

Conversation

@rdhabalia

Copy link
Copy Markdown
Contributor

Motivation

Adding websocket client support into cli produce/consume command.

Modification

Add ws produce/consume in cli-tool.

Result

Now, user will be able to produce and consume messages to websocket proxy by just defining broker-service url as ws://<host>:<port>.
eg:

consume: 
./pulsar-client  --url ws://localhost:8080 consume  persistent://sample/standalone/ns1/t1 -s s1 -n 100

produce:
./pulsar-client  --url ws://localhost:8080/ produce -m "test" -n 100 persistent://sample/standalone/ns1/t1 

@rdhabalia rdhabalia added this to the 2.4.0 milestone Mar 16, 2019
@rdhabalia rdhabalia self-assigned this Mar 16, 2019
@rdhabalia

Copy link
Copy Markdown
Contributor Author

rerun java8 tests
rerun integration tests

@rdhabalia

Copy link
Copy Markdown
Contributor Author

rerun integration tests

topicName.getDomain(), topicName.getTenant(), topicName.getNamespacePortion(), topicName.getLocalName(),
subscriptionName, subscriptionType.toString());

/*String wsTopic = topicName.getDomain() + "/" + topicName.getTenant()

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

remove this?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

yes..fixed it.

@sijie

sijie commented Mar 19, 2019

Copy link
Copy Markdown
Member

run java8 tests

@merlimat
merlimat merged commit 9bc0d26 into apache:master Mar 19, 2019
sijie pushed a commit that referenced this pull request Jan 13, 2020
### Motivation
Support for websocket produce/consume command is added in #3835. The info is not updated in doc content.

### Modifications
Sync doc content with code update.
huangdx0726 pushed a commit to huangdx0726/pulsar that referenced this pull request Aug 24, 2020
### Motivation
Support for websocket produce/consume command is added in apache#3835. The info is not updated in doc content.

### Modifications
Sync doc content with code update.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants