You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by js...@apache.org on 2006/07/04 13:54:24 UTC
svn commit: r418987 -
/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Subscription.java
Author: jstrachan
Date: Tue Jul 4 04:54:24 2006
New Revision: 418987
URL: http://svn.apache.org/viewvc?rev=418987&view=rev
Log:
spring cleaning; catch bad ackMode configurations and throw an exception
Modified:
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Subscription.java
Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Subscription.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Subscription.java?rev=418987&r1=418986&r2=418987&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Subscription.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/stomp/Subscription.java Tue Jul 4 04:54:24 2006
@@ -70,6 +70,9 @@
MessageAck ack = new MessageAck(md, MessageAck.STANDARD_ACK_TYPE, 1);
format.enqueueCommand(ack);
}
+ else {
+ throw new JMSException("Unknown ackMode: " + ackMode);
+ }
FrameBuilder builder = new FrameBuilder(Stomp.Responses.MESSAGE);