FilesExpand file tree

 master

/

enqueue.php

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

31 lines (22 loc) · 698 Bytes

 master

/

enqueue.php

Copy path

Top

File metadata and controls

• Code
• Blame

31 lines (22 loc) · 698 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

<?php

require_once __DIR__ . '/../vendor/autoload.php';

use PhpAmqpLib\Connection\AMQPStreamConnection;

use PhpAmqpLib\Message\AMQPMessage;

function mylog($log_txt)

{

if ($log_txt !== "")

{

$log = fopen("../log/access.txt","a");

fwrite($log, $log_txt."\r\n");

fclose($log);

}

}

$connection = new AMQPStreamConnection('localhost', 5672, 'rabbitmq', 'password','taxqueue');

$channel = $connection->channel();

$msg = new AMQPMessage(json_encode($_POST));

$channel->basic_publish($msg, '', 'taxqueue');

$result_str = "{$_POST['taskname']}\tqueued";

mylog(shell_exec("echo \"{$result_str}\" >> ../data/queued.txt"));

$channel->close();

$connection->close();

?>