forked from iron-io/iron_mq_php
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathtestMessages.php
87 lines (70 loc) · 2.42 KB
/
testMessages.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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
<?php
#require("phar://iron_mq.phar");
require("../iron_core_php/IronCore.class.php");
require("IronMQ.class.php");
$ironmq = new IronMQ();
#$ironmq->debug_enabled = true;
$ironmq->ssl_verifypeer = false;
for ($i = 0; $i < 10; $i++) {
echo "Post message:\n";
$res = $ironmq->postMessage("test_queue", "Test Message $i");
var_dump($res);
echo "Post messages:\n";
$res = $ironmq->postMessages("test-queue-multi", array("Test Message $i", "Test Message $i-2"));
var_dump($res);
echo "Get message..\n";
$message = $ironmq->getMessage("test_queue");
print_r($message);
echo "Touch message..\n";
$res = $ironmq->touchMessage("test_queue", $message->id);
print_r($res);
echo "Release message..\n";
$res = $ironmq->releaseMessage("test_queue", $message->id);
print_r($res);
echo "Peek message..\n";
$res = $ironmq->peekMessage("test_queue");
print_r($res);
echo "Delete message..\n";
$message = $ironmq->deleteMessage("test_queue", $message->id);
print_r($message);
$message = $ironmq->getMessage("test_queue");
print_r($message);
echo "Getting multiple messages..\n";
$messageIds = array();
$messages = $ironmq->getMessages("test-queue-multi", 2);
foreach($messages as $message){
array_push($messageIds, $message->id);
}
echo "Deleting messages with ids..\n";
print_r($messageIds);
$res = $ironmq->deleteMessages("test-queue-multi", $messageIds);
print_r($res);
echo "Adding alerts..\n";
$res = $ironmq->postMessage("test_alert_queue", "Test Message 1");
$first_alert = array(
'type' => 'fixed',
'direction' => 'desc',
'trigger' => 1001,
'snooze' => 10,
'queue' => 'test_alert_queue');
$second_alert = array(
'type' => 'fixed',
'direction' => 'asc',
'trigger' => 1000,
'snooze' => 5,
'queue' => 'test_alert_queue',);
$res = $ironmq->addAlerts("test_alert_queue", array($first_alert, $second_alert));
print_r($res);
echo "Deleting alerts with ids..\n";
$message = $ironmq->getQueue("test_alert_queue");
$alert_ids = array();
$alerts = $message-> alerts;
foreach($alerts as $alert) {
array_push($alert_ids, array('id'=>$alert->id));
}
print_r($alert_ids);
$res = $ironmq->deleteAlerts("test_alert_queue", $alert_ids);
print_r($res);
echo "\n------$i-------\n";
}
echo "\n done";