|
php.net | support | documentation | report a bug | advanced search | search howto | statistics | random bug | login |
[2009-11-12 03:24 UTC] pop3 at flachtaucher dot de
Description:
------------
Using ActiveMQ 5 as broker.
Do something that produces a STOMP error frame (e.g. unsubscribe for a queue I havent subscribed to).
Next readFrame will return false (same value as used for timeout). However it will not notify me that an error has occured. This makes it impossible for me to distinguish between "readFrame returned timeout" and "readFrame got an Error-Frame".
Proposed solution: Throw an Exception.
Possible other solution: Document this behaviour.
Reproduce code:
---------------
<?php
try {
$stomp = new Stomp('tcp://1.2.3.4:61613', 'user', 'password');
} catch(StompException $e) {
die('Connection failed: ' . $e->getMessage()."\n");
exit;
}
$stomp->unsubscribe('/queue/temp.foo');
$stomp->readFrame();
?>
here is my patch to make the module throw an exception:
--- stomp-0.3.1.orig/php_stomp.c 1970-01-01 10:14:21.000000000 +0100
+++ stomp-0.3.1/php_stomp.c 2009-11-12 09:08:42.000000000 +0100
@@ -845,6 +845,11 @@
frame_destroy(res);
} else {
+ if (stomp->error) {
+ STOMP_ERROR(stomp->errnum, stomp->error);
+ } else {
+ STOMP_ERROR(0, PHP_STOMP_ERR_UNKNOWN);
+ }
RETURN_FALSE;
}
}
Expected result:
----------------
readFrame throws an exception or does something else that allows me to find out that I got an error-frame.
Actual result:
--------------
readFrame returns false.
PatchesPull RequestsHistoryAllCommentsChangesGit/SVN commits
|
|||||||||||||||||||||||||||
Copyright © 2001-2025 The PHP GroupAll rights reserved. |
Last updated: Wed Nov 05 12:00:01 2025 UTC |
Sorry my patch did not work. Here is a new one that works for me. --- stomp-0.3.1.orig/stomp.c 1970-01-01 10:13:08.000000000 +0100 +++ stomp-0.3.1/stomp.c 2009-11-12 09:53:45.000000000 +0100 @@ -462,15 +462,6 @@ f->body_length = stomp_read_buffer(stomp, &f->body); } - if (0 == strncmp("ERROR", f->command, sizeof("ERROR") - 1)) { - char *error_msg = NULL; - if (zend_hash_find(f->headers, "message", sizeof("message"), (void **)&error_msg) == SUCCESS) { - stomp_set_error(stomp, error_msg, 0); - } - frame_destroy(f); - return NULL; - } - return f; } /* }}} */ --- stomp-0.3.1.orig/php_stomp.c 1970-01-01 10:14:21.000000000 +0100 +++ stomp-0.3.1/php_stomp.c 2009-11-12 09:57:56.000000000 +0100 @@ -817,6 +817,15 @@ ulong pos; zend_hash_internal_pointer_reset(res->headers); + if (0 == strncmp("ERROR", res->command, sizeof("ERROR") - 1)) { + char *error_msg = NULL; + if (zend_hash_find(res->headers, "message", sizeof("message"), (void **)&error_msg) == SUCCESS) { + STOMP_ERROR(0, error_msg); + frame_destroy(res); + RETURN_FALSE; + } + } + while (zend_hash_get_current_key(res->headers, &key, &pos, 0) == HASH_KEY_IS_STRING) { char *value = NULL; if (zend_hash_get_current_data(res->headers, (void **)&value) == SUCCESS) {