diff options
Diffstat (limited to 'qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java')
-rw-r--r-- | qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java index 282b933607..d68fc86a0e 100644 --- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java +++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ClientJmsDelegate.java @@ -360,6 +360,20 @@ public class ClientJmsDelegate } } + public int getAcknowledgeMode(final String sessionName) + { + try + { + final Session session = _testSessions.get(sessionName); + return session.getAcknowledgeMode(); + } + catch (final JMSException jmse) + { + throw new DistributedTestException("Unable to determine acknowledgement mode for session: " + + sessionName, jmse); + } + } + public Message sendNextMessage(final CreateProducerCommand command) { Message sentMessage = null; |