fstn
10/15/2017, 11:22 AMferoz_baig
10/15/2017, 11:24 AMfstn
10/15/2017, 11:25 AMpackage fstn.vertxFlow.config.manager
import io.vertx.rxjava.core.Vertx
import io.vertx.rxjava.core.buffer.Buffer
import rx.Observable
/**
* Use to read or write bpmn flow file
* @author fstn
*/
class BpmnManager {
fun get(flowName:String): Observable<Buffer> {
return Vertx.vertx().fileSystem()
.rxReadFile(“$flowName.bpmn”)
.doOnError { throw UnableToReadConfigurationException(flowName) }
.toObservable()
}
fun set(flowName:String,flowContent:String): Observable<Void> {
return Vertx.vertx().fileSystem()
.rxWriteFile(“$flowName.bpmn”, Buffer.buffer(flowContent))
.doOnError { throw UnableToWriteConfigurationException(flowName) }
.toObservable()
}
class UnableToWriteConfigurationException(flowName: String) : RuntimeException(flowName)
class UnableToReadConfigurationException(flowName: String) : RuntimeException(flowName)
}
feroz_baig
10/15/2017, 11:27 AMfstn
10/15/2017, 11:28 AMstantronic
10/15/2017, 11:30 AMfstn
10/15/2017, 11:32 AMstantronic
10/15/2017, 11:33 AMfstn
10/15/2017, 11:33 AMstantronic
10/15/2017, 11:34 AMfstn
10/15/2017, 11:47 AM