text: /* vim:set ft=c ts=2 sw=2 sts=2 et cindent: */
  /*
   * ***** BEGIN LICENSE BLOCK *****
   * Version: MIT
   *
   * Portions created by Alan Antonuk are Copyright (c) 2012-2013
   * Alan Antonuk. All Rights Reserved.
   *
   * Portions created by Mike Steinert are Copyright (c) 2012-2013
   * Mike Steinert. All Rights Reserved.
   *
   * Portions created by VMware are Copyright (c) 2007-2012 VMware, Inc.
   * All Rights Reserved.
   *
   * Portions created by Tony Garnock-Jones are Copyright (c) 2009-2010
   * VMware, Inc. and Tony Garnock-Jones. All Rights Reserved.
   *
   * Permission is hereby granted, free of charge, to any person
   * obtaining a copy of this software and associated documentation
   * files (the "Software"), to deal in the Software without
   * restriction, including without limitation the rights to use, copy,
   * modify, merge, publish, distribute, sublicense, and/or sell copies
   * of the Software, and to permit persons to whom the Software is
   * furnished to do so, subject to the following conditions:
   *
   * The above copyright notice and this permission notice shall be
   * included in all copies or substantial portions of the Software.
   *
   * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
   * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
   * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
   * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
   * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
   * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
   * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
   * SOFTWARE.
   * ***** END LICENSE BLOCK *****
   */
  
  #include <stdlib.h>
  #include <stdio.h>
  #include <string.h>
  
  #include <stdint.h>
  #include <amqp_ssl_socket.h>
  #include <amqp_framing.h>
  
  #include "utils.h"
  
  int main(int argc, char const *const *argv)
  {
    char const *hostname;
    int port, status;
    char const *exchange;
    char const *bindingkey;
    char const *queue;
    amqp_socket_t *socket;
    amqp_connection_state_t conn;
  
    if (argc < 6) {
      fprintf(stderr, "Usage: amqps_bind host port exchange bindingkey queue "
              "[cacert.pem [key.pem cert.pem]]\n");
      return 1;
    }
  
    hostname = argv[1];
    port = atoi(argv[2]);
    exchange = argv[3];
    bindingkey = argv[4];
    queue = argv[5];
  
    conn = amqp_new_connection();
  
    socket = amqp_ssl_socket_new(conn);
    if (!socket) {
      die("creating SSL/TLS socket");
    }
  
    if (argc > 6) {
      status = amqp_ssl_socket_set_cacert(socket, argv[6]);
      if (status) {
        die("setting CA certificate");
      }
    }
  
    if (argc > 8) {
      status = amqp_ssl_socket_set_key(socket, argv[8], argv[7]);
      if (status) {
        die("setting client cert");
      }
    }
  
    status = amqp_socket_open(socket, hostname, port);
    if (status) {
      die("opening SSL/TLS connection");
    }
  
    die_on_amqp_error(amqp_login(conn, "/", 0, 131072, 0, AMQP_SASL_METHOD_PLAIN, "guest", "guest"),
                      "Logging in");
    amqp_channel_open(conn, 1);
    die_on_amqp_error(amqp_get_rpc_reply(conn), "Opening channel");
  
    amqp_queue_bind(conn, 1,
                    amqp_cstring_bytes(queue),
                    amqp_cstring_bytes(exchange),
                    amqp_cstring_bytes(bindingkey),
                    amqp_empty_table);
    die_on_amqp_error(amqp_get_rpc_reply(conn), "Unbinding");
  
    die_on_amqp_error(amqp_channel_close(conn, 1, AMQP_REPLY_SUCCESS), "Closing channel");
    die_on_amqp_error(amqp_connection_close(conn, AMQP_REPLY_SUCCESS), "Closing connection");
    die_on_error(amqp_destroy_connection(conn), "Ending connection");
    return 0;
  }
  