svn commit: r1566407 - /wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/SharedDataQueueConsumer.java

[sc...@apache.org]

Author: scottbw
Date: Sun Feb  9 20:47:24 2014
New Revision: 1566407

URL: http://svn.apache.org/r1566407
Log:
Replaced PersistanceManager and IWidgetInstance with AuthToken and SPI

Modified:
    wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/SharedDataQueueConsumer.java

Modified: wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/SharedDataQueueConsumer.java
URL: http://svn.apache.org/viewvc/wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/SharedDataQueueConsumer.java?rev=1566407&r1=1566406&r2=1566407&view=diff
==============================================================================
--- wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/SharedDataQueueConsumer.java (original)
+++ wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/SharedDataQueueConsumer.java Sun Feb  9 20:47:24 2014
@@ -16,9 +16,9 @@ package org.apache.wookie.queues.impl;
 import java.util.concurrent.BlockingQueue;
 
 import org.apache.log4j.Logger;
-import org.apache.wookie.beans.IWidgetInstance;
+import org.apache.wookie.auth.AuthToken;
+import org.apache.wookie.auth.AuthTokenUtils;
 import org.apache.wookie.beans.SharedContext;
-import org.apache.wookie.beans.util.IPersistenceManager;
 import org.apache.wookie.beans.util.PersistenceManagerFactory;
 import org.apache.wookie.queues.beans.IQueuedBean;
 /**
@@ -44,12 +44,9 @@ public class SharedDataQueueConsumer ext
     public void process(IQueuedBean bean) {    	
     	//logger.info("("+queueIdentifer+")CONSUME START SharedDataQueueConsumer" + bean.getKey()+ "' TO '" + bean.getValue()+"'");  
     	try {   
-    		IPersistenceManager persistenceManager = PersistenceManagerFactory.getPersistenceManager();
-    		persistenceManager.begin();
-    		IWidgetInstance widgetInstance = persistenceManager.findWidgetInstanceByIdKey(bean.getId_key());
-    		if (widgetInstance != null){
-    		  new SharedContext(widgetInstance).updateSharedData(bean.getKey(), bean.getValue(), bean.append());
-    			persistenceManager.commit();
+    		AuthToken authToken = AuthTokenUtils.decryptAuthToken(bean.getId_key());
+    		if (authToken != null){
+    		  new SharedContext(authToken).updateSharedData(bean.getKey(), bean.getValue(), bean.append());
     		}
     	} 
     	catch (Exception ex) {