-
Notifications
You must be signed in to change notification settings - Fork 0
/
MongoServer.php~
57 lines (56 loc) · 1.38 KB
/
MongoServer.php~
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
#!/usr/bin/php
<?php
require_once('path.inc');
require_once('get_host_info.inc');
require_once('rabbitMQLib.inc');
function getData()
{
try
{
$connection = new Mongo("mongodb://test:test@ds039504.mongolab.com:39504/thetop");
$database = $connection->selectDB('thetop');
$collection = $database->selectCollection('NJ');
var_dump($connection);
var_dump($collection);
}
catch(MongoConnectionException $e)
{
die("Failed to connect to database ".$e->getMessage());
}
$cursor = $collection->find();
echo "find results:\n";
$returnArray = array();
foreach ($cursor as $doc)
{
var_dump($doc);
array_push($returnArray, $doc);
}
return $returnArray;
}
function requestProcessor($request)
{
echo "received request".PHP_EOL;
var_dump($request);
$logger = implode(" | ",$request);
$logFile = "log.txt";
$lf = fopen($logFile, 'a') or die("Can't open file.");
fwrite($lf, "received request\n");
fwrite($lf, $logger);
fwrite($lf, "\n\n");
fclose($lf);
if(!isset($request['type']))
{
return "ERROR: unsupported message type";
}
switch ($request['type'])
{
case "getData":
$information = getData();
return $information;
}
//return array("returnCode" => '0', 'message'=>"Server received request and processed");
}
$server = new rabbitMQServer("RabbitMQ.ini","testServer");
$server->process_requests('requestProcessor');
exit();
?>