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

[scottbw]

Author: scottbw
Date: Sun Feb  9 19:37:15 2014
New Revision: 1566372

URL: http://svn.apache.org/r1566372
Log:
Replaced use of persistence manager with AuthToken and SPIs

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

Modified: 
wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/PreferenceQueueConsumer.java
URL: 
http://svn.apache.org/viewvc/wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/PreferenceQueueConsumer.java?rev=1566372&r1=1566371&r2=1566372&view=diff
==============================================================================
--- 
wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/PreferenceQueueConsumer.java
 (original)
+++ 
wookie/trunk/wookie-server/src/main/java/org/apache/wookie/queues/impl/PreferenceQueueConsumer.java
 Sun Feb  9 19:37:15 2014
@@ -16,8 +16,8 @@ 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.beans.util.IPersistenceManager;
+import org.apache.wookie.auth.AuthToken;
+import org.apache.wookie.auth.AuthTokenUtils;
 import org.apache.wookie.beans.util.PersistenceManagerFactory;
 import org.apache.wookie.controller.PropertiesController;
 import org.apache.wookie.queues.beans.IQueuedBean;
@@ -44,13 +44,8 @@ public class PreferenceQueueConsumer ext
    public void process(IQueuedBean bean) {
        //logger.info("("+queueIdentifer+")CONSUME START 
PreferenceQueueConsumer" + bean.getKey()+ "' TO '" + bean.getValue()+"'");  
        try {   
-               IPersistenceManager persistenceManager = 
PersistenceManagerFactory.getPersistenceManager();
-               persistenceManager.begin();
-               IWidgetInstance widgetInstance = 
persistenceManager.findWidgetInstanceByIdKey(bean.getId_key());
-               if (widgetInstance != null){
-                       PropertiesController.updatePreference(widgetInstance, 
bean.getKey(), bean.getValue());
-                       persistenceManager.commit();
-               }
+               AuthToken authToken = 
AuthTokenUtils.decryptAuthToken(bean.getId_key());
+               PropertiesController.updatePreference(authToken, bean.getKey(), 
bean.getValue());
        } 
        catch (Exception ex) {                  
                logger.error("("+queueIdentifer+ " to " +bean.getValue() + 
")(Error setting preference: "+ ex, ex);