cvs: pecl /sam/tests sam_test1_wmq_p2p.php sam_test5_wmq_candr.php sam_test6_wpm_candr.php

From:	Dave Renshaw	Date:	Mon, 18 Dec 2006 12:25:52 +0000
Subject:	cvs: pecl /sam/tests sam_test1_wmq_p2p.php sam_test5_wmq_candr.php sam_test6_wpm_candr.php
Groups:	php.pecl.cvs
Request:	Send a blank email to pecl-cvs+get-6803@lists.php.net to get a copy of this message

dsr Mon Dec 18 12:25:52 2006 UTC Added files: /pecl/sam/tests sam_test5_wmq_candr.php sam_test6_wpm_candr.php Modified files: /pecl/sam/tests sam_test1_wmq_p2p.php Log:

http://cvs.php.net/viewvc.cgi/pecl/sam/tests/sam_test1_wmq_p2p.php?r1=1.2&r2=1.3&diff_format=u Index: pecl/sam/tests/sam_test1_wmq_p2p.php diff -u pecl/sam/tests/sam_test1_wmq_p2p.php:1.2 pecl/sam/tests/sam_test1_wmq_p2p.php:1.3 --- pecl/sam/tests/sam_test1_wmq_p2p.php:1.2 Fri Dec 8 17:02:32 2006 +++ pecl/sam/tests/sam_test1_wmq_p2p.php Mon Dec 18 12:25:52 2006 @@ -150,7 +150,7 @@ <?php if ($conn) { $msg = new SAMMessage('This is a 2nd test message'); - $correlid2 = $conn->send($queuename, $msg, array(SAM_SELECT => $correlid)); + $correlid2 = $conn->send($queuename, $msg, array(SAM_CORRELID => $correlid)); if (!$correlid) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { @@ -165,7 +165,7 @@ Attempting receive with correlation id - <?php if ($conn) { - $msg = $conn->receive($queuename, array(SAM_SELECT => $correlid, SAM_WAIT => 5000)); + $msg = $conn->receive($queuename, array(SAM_CORRELID => $correlid, SAM_WAIT => 5000)); if ($msg) { foreach ($msg->header as $key => $value) { http://cvs.php.net/viewvc.cgi/pecl/sam/tests/sam_test5_wmq_candr.php?view=markup&rev=1.1 Index: pecl/sam/tests/sam_test5_wmq_candr.php +++ pecl/sam/tests/sam_test5_wmq_candr.php <html> <head> <title>SAM - WMQ point to point transaction support testcase</title> <?php if ( ! extension_loaded('sam') ) { dl('php_sam.dll'); } // uncomment the following line to get additional debug info //sam_debug_on(); // test set up data... // $host = 'localhost'; $broker = 'bull'; $port = 1414; $queuename = 'queue://testqueue'; $protocol = SAM_WMQ; //$protocol = SAM_WMQ_CLIENT; //$protocol = SAM_WMQ_BINDINGS; ?> </head> <body> <h1>SAM - WMQ Point to Point transaction support testcase</h1> This testcase will exercise the SAM commit and rollback capabilities using the WMQ protocol to a WebSphere MQSeries Messaging server. The tests will use the following set up: Protocol: <?php echo $protocol ?> Host: <?php echo $host ?> Broker: <?php echo $broker ?> Port: <?php echo $port ?> Queue: <?php echo $queuename ?> <hr/> Attempting connection with manual transaction control - <?php $conn = new SAMConnection(); if ($conn->connect($protocol, array(SAM_HOST => $host, SAM_PORT => $port, SAM_BROKER => $broker, SAM_TRANSACTIONS => SAM_MANUAL))) { echo 'OK'; } else { echo 'FAILED'; } ?> <hr/> Sending test message - <?php if ($conn) { $msg = new SAMMessage('This is a test message'); $msg->header->SAM_TYPE = SAM_TEXT; $correlid = $conn->send($queuename, $msg); if (!$correlid) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK correlID='.$correlid; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Attempting 2nd send - <?php if ($conn) { $msg = new SAMMessage('This is a 2nd test message'); $correlid2 = $conn->send($queuename, $msg, array(SAM_SELECT => $correlid)); if (!$correlid) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK correlID='.$correlid; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Creating 2nd connection - <?php $conn2 = new SAMConnection(); if ($conn2->connect($protocol, array(SAM_HOST => $host, SAM_PORT => $port, SAM_BROKER => $broker))) { echo 'OK'; } else { echo 'FAILED'; } ?> <hr/> Attempting receive using 2nd connection - <?php if ($conn2) { $msg = $conn2->receive($queuename, array(SAM_WAIT => 5000)); if ($msg) { echo 'FAILED Oops, that message shouldn\'t have been accessible!'; } else { if ($conn2->errno == SAM_RECEIVE_TIMEDOUT) { echo 'OK'." ($conn2->errno) $conn2->error"; } else { echo 'FAILED XMS receive failure! '." ($conn2->errno) $conn2->error"; } } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Committing the messages - <?php if ($conn) { if (!$conn->commit()) { echo 'FAILED commit failed! '." ($conn->errno) $conn->error"; } else { echo 'OK'; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Attempting receive - <?php if ($conn2) { $msg = $conn2->receive($queuename); if ($msg) { foreach ($msg->header as $key => $value) { echo 'property '.$key.' set to '.$value.' '; } } if (!$msg) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK '."message=$msg->body"; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Attempting 2nd receive - <?php if ($conn2) { $msg = $conn2->receive($queuename); if ($msg) { foreach ($msg->header as $key => $value) { echo 'property '.$key.' set to '.$value.' '; } } if (!$msg) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK '."message=$msg->body"; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Sending test message - <?php if ($conn) { $msg = new SAMMessage('This is a 3rd test message'); $msg->header->SAM_TYPE = SAM_TEXT; $correlid = $conn->send($queuename, $msg); if (!$correlid) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK correlID='.$correlid; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Rolling back the message - <?php if ($conn) { if (!$conn->rollback()) { echo 'FAILED rollback failed! '." ($conn->errno) $conn->error"; } else { echo 'OK'; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Attempting receive using 2nd connection - <?php if ($conn2) { $msg = $conn2->receive($queuename, array(SAM_WAIT => 5000)); if ($msg) { echo 'FAILED Oops, that message shouldn\'t have been accessible!'; } else { echo 'OK'." ($conn2->errno) $conn2->error"; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Check connection still shows as connected - <?php if (!$conn->isConnected()) { echo 'FAILED'; } else { echo 'OK '; } ?> <hr/> Attempting disconnect with connected connection - <?php if (!$conn->disconnect()) { echo 'FAILED'; } else { echo 'OK '; } ?> <hr/> </body> </html> http://cvs.php.net/viewvc.cgi/pecl/sam/tests/sam_test6_wpm_candr.php?view=markup&rev=1.1 Index: pecl/sam/tests/sam_test6_wpm_candr.php +++ pecl/sam/tests/sam_test6_wpm_candr.php <html> <head> <title>SAM - WPM point to point transaction support testcase</title> <?php if ( ! extension_loaded('sam') ) { dl('php_sam.dll'); } //sam_debug_on(); // test set up data... // $endpoints = 'localhost:7278:BootstrapBasicMessaging'; $bus = 'Bus1'; $target = 'InboundBasicMessaging'; $queuename = 'queue://testqueue'; ?> </head> <body> <h1>SAM - WPM Point to Point transaction support testcase</h1> This testcase will exercise the SAM commit and rollback capabilities using the WPM protocol to a WebSphere Platform Messaging server. The tests will use the following set up: Endpoints: <?php echo $endpoints ?> Target chain: <?php echo $target ?> Bus: <?php echo $bus ?> Queue: <?php echo $queuename ?> <hr/> Attempting connection with manual transaction control - <?php $conn = new SAMConnection(); if ($conn->connect(SAM_WPM, array(SAM_ENDPOINTS => $endpoints, SAM_BUS => $bus, SAM_TARGETCHAIN => $target, SAM_TRANSACTIONS => SAM_MANUAL))) { echo 'OK'; } else { echo 'FAILED'; } ?> <hr/> Sending test message - <?php if ($conn) { $msg = new SAMMessage('This is a test message'); $msg->header->SAM_TYPE = SAM_TEXT; $correlid = $conn->send($queuename, $msg); if (!$correlid) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK correlID='.$correlid; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Attempting 2nd send - <?php if ($conn) { $msg = new SAMMessage('This is a 2nd test message'); $correlid2 = $conn->send($queuename, $msg, array(SAM_SELECT => $correlid)); if (!$correlid) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK correlID='.$correlid; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Creating 2nd connection - <?php $conn2 = new SAMConnection(); if ($conn2->connect(SAM_WPM, array(SAM_ENDPOINTS => $endpoints, SAM_BUS => $bus, SAM_TARGETCHAIN => $target))) { echo 'OK'; } else { echo 'FAILED'; } ?> <hr/> Attempting receive using 2nd connection - <?php if ($conn2) { $msg = $conn2->receive($queuename, array(SAM_WAIT => 5000)); if ($msg) { echo 'FAILED Oops, that message shouldn\'t have been accessible!'; } else { if ($conn2->errno == SAM_RECEIVE_TIMEDOUT) { echo 'OK'." ($conn2->errno) $conn2->error"; } else { echo 'FAILED XMS receive failure! '." ($conn2->errno) $conn2->error"; } } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Committing the messages - <?php if ($conn) { if (!$conn->commit()) { echo 'FAILED commit failed! '." ($conn->errno) $conn->error"; } else { echo 'OK'; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Attempting receive - <?php if ($conn2) { $msg = $conn2->receive($queuename); if ($msg) { foreach ($msg->header as $key => $value) { echo 'property '.$key.' set to '.$value.' '; } } if (!$msg) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK '."message=$msg->body"; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Attempting 2nd receive - <?php if ($conn2) { $msg = $conn2->receive($queuename); if ($msg) { foreach ($msg->header as $key => $value) { echo 'property '.$key.' set to '.$value.' '; } } if (!$msg) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK '."message=$msg->body"; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Sending test message - <?php if ($conn) { $msg = new SAMMessage('This is a 3rd test message'); $msg->header->SAM_TYPE = SAM_TEXT; $correlid = $conn->send($queuename, $msg); if (!$correlid) { echo 'FAILED'." ($conn->errno) $conn->error"; } else { echo 'OK correlID='.$correlid; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Rolling back the message - <?php if ($conn) { if (!$conn->rollback()) { echo 'FAILED rollback failed! '." ($conn->errno) $conn->error"; } else { echo 'OK'; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Attempting receive using 2nd connection - <?php if ($conn2) { $msg = $conn2->receive($queuename, array(SAM_WAIT => 5000)); if ($msg) { echo 'FAILED Oops, that message shouldn\'t have been accessible!'; } else { echo 'OK'." ($conn2->errno) $conn2->error"; } } else { echo 'FAILED previous connection create test failed!'; } ?> <hr/> Check connection still shows as connected - <?php if (!$conn->isConnected()) { echo 'FAILED'; } else { echo 'OK '; } ?> <hr/> Attempting disconnect with connected connection - <?php if (!$conn->disconnect()) { echo 'FAILED'; } else { echo 'OK '; } ?> <hr/> </body> </html>