Revision 9147e5f8 src/main/scala/gr/grnet/aquarium/service/ResourceEventProcessorService.scala

b/src/main/scala/gr/grnet/aquarium/service/ResourceEventProcessorService.scala
60 60 
    }
61 61 
  }
62 62 

  		





  63
  
  
    
  override def exists(event: ResourceEvent): Boolean =


  		





  
  63
  
    
  override def existsInStore(event: ResourceEvent): Boolean =


  		





  64
  64
  
    
    _configurator.resourceEventStore.findResourceEventById(event.id).isJust


  		





  65
  65
  
    

  		





  66
  
  
    
  override def persist(event: ResourceEvent, initialPayload: Array[Byte]): Unit = {


  		





  
  66
  
    
  override def storeParsedEvent(event: ResourceEvent, initialPayload: Array[Byte]): Unit = {


  		





  67
  67
  
    
    // 1. Store to local FS for debugging purposes.


  		





  68
  68
  
    
    //    BUT be resilient to errors, since this is not critical


  		





  69
  69
  
    
    if(_configurator.eventsStoreFolder.isJust) {


  		





  ......




  77
  77
  
    
  }


  		





  78
  78
  
    

  		





  79
  79
  
    

  		





  80
  
  
    
  protected def persistUnparsed(initialPayload: Array[Byte], exception: Throwable): Unit = {


  		





  
  80
  
    
  protected def storeUnparsedEvent(initialPayload: Array[Byte], exception: Throwable): Unit = {


  		





  81
  81
  
    
    // TODO: Also save to DB, just like we do for UserEvents


  		





  82
  82
  
    
    LocalFSEventStore.storeUnparsedResourceEvent(_configurator, initialPayload, exception)


  		





  83
  83
  
    
  }


  		












Also available in:
  Unified diff