doc/konsum.rest

   1 <!--
   2 SPDX-FileCopyrightText: 2022 Frank Doepper
   3
   4 SPDX-License-Identifier: FSFAP
   5 -->
   6
   7 # EXAMPLES
   8
   9 connect to localhost with default credentials and attach to a new temp
  10 queue on the default exchange:
  11
  12     konsum
  13
  14 Connect to a host with TLS on a custom port, authenticating with SSL
  15 client certificate. On every received message a callback is spawned.
  16 The message will be ACKed when the callback exits successfully. First
  17 500 bytes of the message body are printed to stderr. Header infos are
  18 always printed to stderr:
  19
  20     konsum -o amqp.example.com -p 5673 -T -k amqp-key.pem -c amqp-crt.pem -y vhost -x exchange -X./callback.sh -a -c -a callback.config.sh -f 2 -r binding.key.# -l 500
  21
  22 Authenticate with user and pass. Attach to an existing queue. Generate a file
  23 for every message:
  24
  25     konsum -o amqp.example.com -U user -P pass -q queue -t
  26
  27 Provide a custom CA cert for proving the server's identity via
  28 enviroment:
  29
  30     $ env SYSTEM_CERTIFICATE_PATH=/etc/amqp/cacert.crt konsum -T -y vhost -x exchange -r#
  31
  32 You can have no bindings, or you can bind the queue to one or multiple exchanges + binding keys:
  33
  34     konsum -x x1 -r b1 -r b2 -x x2 -r b3
  35
  36 would bind the queue to exchange x1 with binding keys b1 and b2 and to exchange x2 with binding key b3.
  37
  38 Stop with ^C
  39