File tree Expand file tree Collapse file tree 1 file changed +24
-0
lines changed
test/src/com/rabbitmq/client/test/functional Expand file tree Collapse file tree 1 file changed +24
-0
lines changed Original file line number Diff line number Diff line change 3131
3232package com .rabbitmq .client .test .functional ;
3333
34+ import com .rabbitmq .client .AMQP ;
3435import com .rabbitmq .client .test .BrokerTestCase ;
3536import java .io .IOException ;
3637
@@ -319,4 +320,27 @@ public void testAckAll()
319320 closeChannel ();
320321 }
321322
323+ public void testNonTransactedCommit ()
324+ throws IOException
325+ {
326+ openChannel ();
327+ try {
328+ txCommit ();
329+ fail ("Expected channel error" );
330+ } catch (IOException e ) {
331+ checkShutdownSignal (AMQP .PRECONDITION_FAILED , e );
332+ }
333+ }
334+
335+ public void testNonTransactedRollback ()
336+ throws IOException
337+ {
338+ openChannel ();
339+ try {
340+ txRollback ();
341+ fail ("Expected channel error" );
342+ } catch (IOException e ) {
343+ checkShutdownSignal (AMQP .PRECONDITION_FAILED , e );
344+ }
345+ }
322346}
You can’t perform that action at this time.
0 commit comments