From 38cc8891e367ba8699b7f0ffc230a3454b674577 Mon Sep 17 00:00:00 2001
From: Anil Yilmaz <annilyilmaz@gmail.com>
Date: Sun, 31 Oct 2021 13:26:40 +0300
Subject: [PATCH] Add rabbitmq

---
 rabbitmq/connect_rabbitmq.php | 30 ++++++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)
 create mode 100644 rabbitmq/connect_rabbitmq.php

diff --git a/rabbitmq/connect_rabbitmq.php b/rabbitmq/connect_rabbitmq.php
new file mode 100644
index 0000000..9ab2b35
--- /dev/null
+++ b/rabbitmq/connect_rabbitmq.php
@@ -0,0 +1,30 @@
+<?php
+  use PhpAmqpLib\Connection\AMQPStreamConnection;
+  use PhpAmqpLib\Connection\AMQPSSLConnection;
+  use PhpAmqpLib\Message\AMQPMessage;
+
+  $url = parse_url(getenv('CLOUDAMQP_URL'));
+  $vhost = substr($url['path'], 1);
+
+  if($url['scheme'] === "amqps") {
+    $ssl_opts = array(
+      'capath' => '/etc/ssl/certs'
+    );
+    $conn= new AMQPSSLConnection($url['host'], 5671, $url['user'], $url['pass'], $vhost, $ssl_opts);
+  } else {
+    $conn = new AMQPStreamConnection($url['host'], 5672, $url['user'], $url['pass'], $vhost);
+  }
+  
+  $channel = $conn->channel();
+  $channel->exchange_declare('exchange', 'direct', false, false, false);
+  $channel->queue_declare('fisrt_queue', false, false, false, false);
+  $channel->queue_bind('fisrt_queue', 'exchange', 'test_key');
+
+  $msg = new AMQPMessage('first message');
+  $channel->basic_publish($msg, 'first_exchange', '');
+
+  echo " DENEME '\n";
+
+  $channel->close();
+  $conn->close();
+?>
\ No newline at end of file