Skip to content

Commit

Permalink
Adapt README and cli for v0.2
Browse files Browse the repository at this point in the history
  • Loading branch information
lukasmartinelli committed Jan 5, 2016
1 parent 31e12ac commit d69b188
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 7 deletions.
5 changes: 3 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ You can download a single binary for Linux, OSX or Windows.
**OSX**

```bash
wget -O pipecat https://github.com/lukasmartinelli/pipecat/releases/download/v0.1/pipecat_darwin_amd64
wget -O pipecat https://github.com/lukasmartinelli/pipecat/releases/download/v0.2/pipecat_darwin_amd64
chmod +x pipecat

./pipecat --help
Expand All @@ -43,7 +43,7 @@ chmod +x pipecat
**Linux**

```bash
wget -O pipecat https://github.com/lukasmartinelli/pipecat/releases/download/v0.1/pipecat_linux_amd64
wget -O pipecat https://github.com/lukasmartinelli/pipecat/releases/download/v0.2/pipecat_linux_amd64
chmod +x pipecat

./pipecat --help
Expand Down Expand Up @@ -119,6 +119,7 @@ export AMQP_URI=amqp://guest:guest@localhost:5672/vhost
### Publish messages to Exchange

If you are using existing message queue infrastructure you can also publish messages to an exchange.
Thanks to @kennon for the implementation.

```bash
seq 1 1000 | pipecat publish --exchange "\" --no-create-queue numbers
Expand Down
10 changes: 5 additions & 5 deletions pipecat.go
Original file line number Diff line number Diff line change
Expand Up @@ -56,10 +56,10 @@ func publish(c *cli.Context) {
for scanner.Scan() {
line := scanner.Text()
err := channel.Publish(
c.String("exchange"), // exchange
queueName, // routing key
false, // mandatory
false, // immediate
c.String("exchange"), // exchange
queueName, // routing key
false, // mandatory
false, // immediate
amqp.Publishing{
ContentType: "text/plain",
Body: []byte(line),
Expand Down Expand Up @@ -157,7 +157,7 @@ func main() {
app := cli.NewApp()
app.Name = "pipecat"
app.Usage = "Connect unix pipes and message queues"
app.Version = "0.1"
app.Version = "0.2"

globalFlags := []cli.Flag{
cli.StringFlag{
Expand Down

0 comments on commit d69b188

Please sign in to comment.