[jboss-user] [JBoss Cache] New message: "Jboss cache TransactionCompletedEvent in Jboss AS 5.1"

[Frank Cheng]

User development,

A new message was posted in the thread "Jboss cache TransactionCompletedEvent in Jboss AS 5.1":

http://community.jboss.org/message/523069#523069

Author  : Frank Cheng
Profile : http://community.jboss.org/people/chengsuntx

Message:
--------------------------------------------------------------
I am trying to add transaction support to Jboss Cache. The TransactionComplted listener got hit when the transaction was commited or whenever a read happened to the cache. The cache root in TransactionCompletedEvent is always null.

Here is the code I am using:

@CacheListener
public class JbossCacheListener {
    private static Log logger = LogFactory.getLog(JbossCacheListener.class);
    public static String DEFAULT_CONFIC_CACHE_NAME = "config-default-name";
    
    private InitialContext context;
    private Cache cache;
    private TransactionManager transMgr;
    
    public boolean init(){
        try {
            this.context = new InitialContext();
            CacheManager cacheManager = (CacheManager)context.lookup("java:CacheManager");
            cache = cacheManager.getCache(DEFAULT_CONFIC_CACHE_NAME, true);
            if (cache == null) {
                logger.error("Unable to find cache " + DEFAULT_CONFIC_CACHE_NAME + ", jboss cache isn't configured properly.");
                return false;
            }
            cache.start();
            cache.addCacheListener(this);

            GenericTransactionManagerLookup tranLookup = new GenericTransactionManagerLookup();
            transMgr = tranLookup.getTransactionManager();
        } catch (NamingException e1) {
            logger.error("unable to find initial context by naming service; " + e1);
            return false;
        } catch (Exception e) {
            logger.error("unable to find initial context by naming service; " + e);
            return false;
        }


        try {
            transMgr.begin();
            loadConfig();  // load data to the cache through bunch of puts
            transMgr.commit();
        } catch (Exception e) {
            try { transMgr.rollback(); } catch(Throwable t) {}
            logger.error("Unable to load cluster configuration; " + e);
            return false;
        }


        return true;
    }
    
    @TransactionCompleted
    public void perform(TransactionCompletedEvent te)
    {
        logger.info("An trans complete event " + te.getType() + " isOriginLocal " + te.isOriginLocal() + " isSuccessful " + te.isSuccessful() + " has occured");
        if (te.getCache().getRoot() == null) {
            logger.info("cache root is null from TransactionCompletedEvent after complete.");
            return;
        }
        logger.info("transEvent: " + te.getTransaction().toString());
    }
    
    private void loadConfig() {
        Node rootNode = cache.getRoot();
        Node personRecordsNode = rootNode.addChild(Fqn.fromString("/org/mycompany/personRecords"));     
        personRecordsNode.put("name", "Peter");
        personRecordsNode.put("address", "1 main st");
    }}

And here is some of the configuration properties.

         <property name="transactionManagerLookupClass">org.jboss.cache.transaction.GenericTransactionManagerLookup</property>
         <property name="nodeLockingScheme">OPTIMISTIC</property>
         <property name="useLockStriping">false</property>
         <property name="cacheMode">REPL_ASYNC</property> 


Perform function gots called and te.getCache().getRoot() is null. And also, perform gots call whenerver a read happened on any of the nodes in the cache and te.getCache().getRoot() is null.

Any idea on this? Thanks in advance.


--------------------------------------------------------------

To reply to this message visit the message page: http://community.jboss.org/message/523069#523069