| Index: trunk/extensions/DonationInterface/activemq_stomp/activemq_stomp.php |
| — | — | @@ -68,8 +68,9 @@ |
| 69 | 69 | */ |
| 70 | 70 | function sendSTOMP($transaction) { |
| 71 | 71 | global $wgOut; |
| 72 | | - global $wgStompServer; |
| | 72 | + global $wgStompServer, $wgStompQueueName; |
| 73 | 73 | |
| | 74 | + $queueName = isset ( $wgStompQueueName ) ? $wgStompQueueName : 'test'; |
| 74 | 75 | // include a library |
| 75 | 76 | require_once("Stomp.php"); |
| 76 | 77 | |
| — | — | @@ -82,7 +83,7 @@ |
| 83 | 84 | $con->connect(); |
| 84 | 85 | |
| 85 | 86 | // send a message to the queue |
| 86 | | - $result = $con->send("/queue/test", $message, array('persistent' => 'true')); |
| | 87 | + $result = $con->send("/queue/$queueName", $message, array('persistent' => 'true')); |
| 87 | 88 | |
| 88 | 89 | if (!$result) { |
| 89 | 90 | wfDebugLog('activemq_stomp', 'Send to Q failed for this message: ' . $message); |