Merge pull request #284 from batchcorp/blinktag/fix_examples

Fix relay examples

Dockerfile

@@ -24,6 +24,7 @@ RUN apk --update add bash curl ca-certificates && update-ca-certificates
 # Install binary
 COPY --from=builder /build/plumber-linux /plumber-linux
 COPY --from=builder /docker-entrypoint.sh /docker-entrypoint.sh
+RUN ln -s /plumber-linux /usr/bin/plumber
 
 ENTRYPOINT ["/docker-entrypoint.sh"]
 

docs/examples.md

@@ -403,7 +403,7 @@ $ docker run --name plumber-rabbit -p 8080:8080 \
     -e PLUMBER_RELAY_RABBIT_ROUTING_KEY=some.routing.key \
     -e PLUMBER_RELAY_RABBIT_QUEUE_EXCLUSIVE=false \
     -e PLUMBER_RELAY_RABBIT_QUEUE_DURABLE=true \
-    batchcorp/plumber rabbit
+    batchcorp/plumber plumber relay rabbit
 ```
 
 ##### Continuously relay messages from an SQS queue to a Batch.sh collection
@@ -414,7 +414,7 @@ docker run -d --name plumber-sqs -p 8080:8080 \
     -e AWS_SECRET_ACCESS_KEY=$AWS_SECRET_ACCESS_KEY \
     -e PLUMBER_RELAY_SQS_QUEUE_NAME=TestQueue \
     -e PLUMBER_RELAY_TOKEN=$YOUR-BATCHSH-TOKEN-HERE \
-    batchcorp/plumber aws-sqs
+    batchcorp/plumber plumber relay aws-sqs
 ```
 
 ##### Continuously relay messages from an Azure queue to a Batch.sh collection
@@ -424,7 +424,7 @@ docker run -d --name plumber-azure -p 8080:8080 \
     -e SERVICEBUS_CONNECTION_STRING="Endpoint=sb://mybus.servicebus.windows.net/;SharedAccessKeyName..."
     -e PLUMBER_RELAY_AZURE_QUEUE_NAME=neworders \
     -e PLUMBER_RELAY_TOKEN=$YOUR-BATCHSH-TOKEN-HERE \
-    batchcorp/plumber azure-service-bus
+    batchcorp/plumber plumber relay azure-service-bus
 ```
 
 ##### Continuously relay messages from an Azure topic to a Batch.sh collection
@@ -435,7 +435,7 @@ docker run -d --name plumber-azure -p 8080:8080 \
     -e PLUMBER_RELAY_AZURE_TOPIC_NAME=neworders \
     -e PLUMBER_RELAY_AZURE_SUBSCRIPTION=some-sub \
     -e PLUMBER_RELAY_TOKEN=$YOUR-BATCHSH-TOKEN-HERE \
-    batchcorp/plumber azure-service-bus
+    batchcorp/plumber plumber relay azure-service-bus
 ```
 
 ##### Continuously relay messages from multiple Redis channels to a Batch.sh collection
@@ -445,7 +445,7 @@ docker run -d --name plumber-redis-pubsub -p 8080:8080 \
     -e PLUMBER_RELAY_REDIS_PUBSUB_ADDRESS=localhost:6379 \
     -e PLUMBER_RELAY_REDIS_PUBSUB_CHANNELS=channel1,channel2 \
     -e PLUMBER_RELAY_TOKEN=$YOUR-BATCHSH-TOKEN-HERE \
-    batchcorp/plumber redis-pubsub
+    batchcorp/plumber plumber relay redis-pubsub
 ```
 
 ##### Continuously relay messages from multiple Redis streams to a Batch.sh collection
@@ -455,21 +455,21 @@ docker run -d --name plumber-redis-streams -p 8080:8080 \
     -e PLUMBER_RELAY_REDIS_STREAMS_ADDRESS=localhost:6379 \
     -e PLUMBER_RELAY_REDIS_STREAMS_STREAMS=stream1,stream2 \
     -e PLUMBER_RELAY_TOKEN=$YOUR-BATCHSH-TOKEN-HERE \
-    batchcorp/plumber redis-streams
+    batchcorp/plumber plumber relay redis-streams
 ```
 
 ##### Continuously relay messages from a Kafka topic (on Confluent) to a Batch.sh collection (via CLI)
 
 ```
-export PLUMBER_RELAY_TOKEN="$YOUR-BATCHSH-TOKEN-HERE"
-export PLUMBER_RELAY_KAFKA_ADDRESS="pkc-4kgmg.us-west-2.aws.confluent.cloud:9092,pkc-5kgmg.us-west-2.aws.confluent.cloud:9092"
-export PLUMBER_RELAY_KAFKA_TOPIC="$YOUR_TOPIC"
-export PLUMBER_RELAY_KAFKA_INSECURE_TLS="true"
-export PLUMBER_RELAY_KAFKA_USERNAME="$YOUR_CONFLUENT_API_KEY"
-export PLUMBER_RELAY_KAFKA_PASSWORD="$YOUR_CONFLUENT_API_SECRET"
-export PLUMBER_RELAY_KAFKA_SASL_TYPE="plain"
-
-$ plumber relay kafka
+docker run -d --name plumber-kafka -p 8080:8080 \
+    -e PLUMBER_RELAY_TOKEN="$YOUR-BATCHSH-TOKEN-HERE"
+    -e PLUMBER_RELAY_KAFKA_ADDRESS="pkc-4kgmg.us-west-2.aws.confluent.cloud:9092,pkc-5kgmg.us-west-2.aws.confluent.cloud:9092"
+    -e PLUMBER_RELAY_KAFKA_TOPIC="$YOUR_TOPIC"
+    -e PLUMBER_RELAY_KAFKA_INSECURE_TLS="true"
+    -e PLUMBER_RELAY_KAFKA_USERNAME="$YOUR_CONFLUENT_API_KEY"
+    -e PLUMBER_RELAY_KAFKA_PASSWORD="$YOUR_CONFLUENT_API_SECRET"
+    -e PLUMBER_RELAY_KAFKA_SASL_TYPE="plain"
+    batchcorp/plumber plumber relay kafka
 ```
 
 ##### Continuously relay messages from a MQTT topic to a Batch.sh collection
@@ -480,7 +480,7 @@ docker run -d --name plumber-mqtt -p 8080:8080 \
     -e PLUMBER_RELAY_MQTT_TOPIC=iotdata \
     -e PLUMBER_RELAY_MQTT_QOS=1 \
     -e PLUMBER_RELAY_TOKEN=$YOUR-BATCHSH-TOKEN-HERE \
-    batchcorp/plumber:local mqtt
+    batchcorp/plumber plumber relay mqtt
 ```
 
 ##### Continuously relay messages from a NATS JetStream stream to a Batch.sh collection
@@ -491,7 +491,7 @@ docker run -d --name plumber-natsjs -p 8080:8080 \
     -e PLUMBER_RELAY_NATS_JETSTREAM_CLIENT_ID=plumber \
     -e PLUMBER_RELAY_NATS_JETSTREAM_STREAM=orders \
     -e PLUMBER_RELAY_TOKEN=$YOUR-BATCHSH-TOKEN-HERE \
-    batchcorp/plumber:local mqtt
+    batchcorp/plumber plumber relay mqtt
 ```
 
 
@@ -510,7 +510,7 @@ docker run -d --name plumber-cdc-mongo -p 8080:8080 \
     -e PLUMBER_RELAY_CDCMONGO_DATABASE=mydb \
     -e PLUMBER_RELAY_CDCMONGO_COLLECTION=customers \
     -e PLUMBER_RELAY_TOKEN=YOUR_BATCHSH_TOKEN_HERE \
-    batchcorp/plumber cdc-mongo
+    batchcorp/plumber plumber relay cdc-mongo
 
 ```