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) {
