List of beginFlow() Examples

Examples of beginFlow()

com.asakusafw.yaess.core.ExecutionLock.beginFlow()
Begin to process a flow using this lock. @param flowId target flow ID @param executionId target execution ID @throws IOException if failed to operate @throws IllegalArgumentException if some parameters were {@code null}

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

        try {
            lock.beginFlow("flow1", "exec1");
            ExecutionLock other = instance2.newInstance("batch1");
            try {
                // can acquire other flow lock
                other.beginFlow("flow2", "exec1");
                other.endFlow("flow2", "exec1");
                other.beginFlow("flow2", "exec2");
                other.endFlow("flow2", "exec2");


                try {

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

            ExecutionLock other = instance2.newInstance("batch1");
            try {
                // can acquire other flow lock
                other.beginFlow("flow2", "exec1");
                other.endFlow("flow2", "exec1");
                other.beginFlow("flow2", "exec2");
                other.endFlow("flow2", "exec2");


                try {
                    other.beginFlow("flow1", "exec2");
                    fail("cannot run same flow");

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

                other.endFlow("flow2", "exec1");
                other.beginFlow("flow2", "exec2");
                other.endFlow("flow2", "exec2");


                try {
                    other.beginFlow("flow1", "exec2");
                    fail("cannot run same flow");
                } catch (IOException e) {
                    // ok.
                }
            } finally {

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

            }


            other = instance2.newInstance("batch2");
            try {
                // can acquire any flow lock if batch is different
                other.beginFlow("flow1", "exec1");
            } finally {
                other.close();
            }
        } finally {
            lock.close();

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

        ExecutionLockProvider instance1 = profile.newInstance();
        ExecutionLockProvider instance2 = profile.newInstance();


        ExecutionLock lock = instance1.newInstance("batch1");
        try {
            lock.beginFlow("flow1", "exec1");
            ExecutionLock other = instance2.newInstance("batch1");
            try {
                // can acquire other flow lock
                other.beginFlow("flow2", "exec1");
                other.endFlow("flow2", "exec1");

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

        try {
            lock.beginFlow("flow1", "exec1");
            ExecutionLock other = instance2.newInstance("batch1");
            try {
                // can acquire other flow lock
                other.beginFlow("flow2", "exec1");
                other.endFlow("flow2", "exec1");
                other.beginFlow("flow2", "exec2");
                other.endFlow("flow2", "exec2");


                // can acquire other execution lock

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

            ExecutionLock other = instance2.newInstance("batch1");
            try {
                // can acquire other flow lock
                other.beginFlow("flow2", "exec1");
                other.endFlow("flow2", "exec1");
                other.beginFlow("flow2", "exec2");
                other.endFlow("flow2", "exec2");


                // can acquire other execution lock
                other.beginFlow("flow1", "exec2");
                other.endFlow("flow1", "exec2");

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

                other.endFlow("flow2", "exec1");
                other.beginFlow("flow2", "exec2");
                other.endFlow("flow2", "exec2");


                // can acquire other execution lock
                other.beginFlow("flow1", "exec2");
                other.endFlow("flow1", "exec2");


                try {
                    other.beginFlow("flow1", "exec1");
                    fail("cannot run same execution");

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

                // can acquire other execution lock
                other.beginFlow("flow1", "exec2");
                other.endFlow("flow1", "exec2");


                try {
                    other.beginFlow("flow1", "exec1");
                    fail("cannot run same execution");
                } catch (IOException e) {
                    // ok.
                }
            } finally {

View Full Code Here

Examples of com.asakusafw.yaess.core.ExecutionLock.beginFlow()

            }


            other = instance2.newInstance("batch2");
            try {
                // can acquire any flow lock if batch is different
                other.beginFlow("flow1", "exec1");
            } finally {
                other.close();
            }
        } finally {
            lock.close();

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.