[WELD-865]; check conversation lock

weld · Mar 8, 2011 · b11cc2a · b11cc2a
1 parent d724daf
commit b11cc2a
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/impl/src/main/java/org/jboss/weld/context/AbstractConversationContext.java b/impl/src/main/java/org/jboss/weld/context/AbstractConversationContext.java
@@ -292,10 +292,16 @@ public void activate(String cid)
          else
          {
             setRequestAttribute(getRequest(), CURRENT_CONVERSATION_ATTRIBUTE_NAME, getConversation(cid));
-            getCurrentConversation().lock(getConcurrentAccessTimeout());
-            NamingScheme namingScheme = new ConversationNamingScheme(ConversationContext.class.getName(), cid);
-            setBeanStore(createRequestBeanStore(namingScheme, getRequest()));
-            getBeanStore().attach();
+            if (getCurrentConversation().lock(getConcurrentAccessTimeout()))
+            {
+               NamingScheme namingScheme = new ConversationNamingScheme(ConversationContext.class.getName(), cid);
+               setBeanStore(createRequestBeanStore(namingScheme, getRequest()));
+               getBeanStore().attach();
+            }
+            else
+            {
+               throw new IllegalStateException("Conversation lock timed out: " + cid);
+            }
          }
 
       }