atomic-factory/src/main/java/org/infinispan/atomic/container/Container.java
/**
    * Internal use of the listener API.
    *
    * @param event of class CacheEntryModifiedEvent
    */
Internal use of the listener API.
@param event of class CacheEntryModifiedEvent
Internal use of the listener API . @param event of class CacheEntryModifiedEvent
@SuppressWarnings({ "rawtypes", "unchecked" })
   @CacheEntryModified
   @CacheEntryCreated
   @Deprecated
   public void onCacheModification(CacheEntryEvent event){
      if( !event.getKey().equals(key) )
         return;
      if(event.isPre())
         return;
      try {
         GenericJBossMarshaller marshaller = new GenericJBossMarshaller();
         byte[] bb = (byte[]) event.getValue();
         Call call = (Call) marshaller.objectFromByteBuffer(bb);
         if (log.isDebugEnabled()) log.debugf("Receive %s (isOriginLocal=%s) ", call, event.isOriginLocal());
         callExecutor.execute(new AtomicObjectContainerTask(call));
      } catch (Exception e) {
         e.printStackTrace();
      }
   }
@ SuppressWarnings ( { "rawtypes" , "unchecked" } ) @ CacheEntryModified @ CacheEntryCreated @ Deprecated public void onCacheModification ( CacheEntryEvent event ) { if ( ! event . getKey ( ) . equals ( key ) ) return ; if ( event . isPre ( ) ) return ; try { GenericJBossMarshaller marshaller = new GenericJBossMarshaller ( ) ; byte [ ] bb = ( byte [ ] ) event . getValue ( ) ; Call call = ( Call ) marshaller . objectFromByteBuffer ( bb ) ; if ( log . isDebugEnabled ( ) ) log . debugf ( "Receive %s (isOriginLocal=%s) " , call , event . isOriginLocal ( ) ) ; callExecutor . execute ( new AtomicObjectContainerTask ( call ) ) ; } catch ( Exception e ) { e . printStackTrace ( ) ; } }
Internal use of the listener API.
Internal use of the listener API .