Examples of ParentScopeChannelListener

org.apache.ode.bpel.rtrep.v1.channels.ParentScopeChannelListener
Response channel for pick requests. @jacob.kind @jacob.parent TimerResponseChannel
org.apache.ode.bpel.rtrep.v2.channels.ParentScopeChannelListener
Alarm event handler. This process template manages a single alarm event handler. It acts like an activity in that it can be terminated, but also adds a channel for "soft" termination (aka stopping) to deal with the case when the scope that owns the event handler completes naturally.
org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener
An auto-generated channel listener abstract class for the {@link org.apache.ode.bpel.runtime.channels.ParentScope} channel type. @see org.apache.ode.bpel.runtime.channels.ParentScope @see org.apache.ode.bpel.runtime.channels.ParentScopeChannel

Examples of org.apache.ode.bpel.rtrep.v2.channels.ParentScopeChannelListener

            _oprocess.processScope,
            newChannel(TerminationChannel.class), newChannel(ParentScopeChannel.class));
        ScopeFrame processFrame = new ScopeFrame(_oprocess.processScope, scopeInstanceId, null, null,_globals);
        instance(new SCOPE(child, processFrame, new LinkFrame(null)));


        object(new ParentScopeChannelListener(child.parent) {
            private static final long serialVersionUID = -8564969578471906493L;


            public void compensate(OScope scope, SynchChannel ret) {
                assert false;
            }

View Full Code Here

Examples of org.apache.ode.bpel.rtrep.v2.channels.ParentScopeChannelListener

                public void terminate() {
                    _terminated = true;
                    replication(_child.self).terminate();
                    instance(WAITER.this);
                }
            }.or(new ParentScopeChannelListener(_child.parent) {
                private static final long serialVersionUID = 3907167240907524405L;


                public void compensate(OScope scope, SynchChannel ret) {
                    _self.parent.compensate(scope,ret);
                    instance(WAITER.this);

View Full Code Here

Examples of org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener

                    deadPathRemaining();


                    _terminateRequested = true;
                    instance(ACTIVE.this);
                }
            }.or(new ParentScopeChannelListener(_child.parent) {
                private static final long serialVersionUID = 7195562310281985971L;


                public void compensate(OScope scope, SynchChannel ret) {
                    _self.parent.compensate(scope,ret);
                    instance(ACTIVE.this);

View Full Code Here

Examples of org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener

        ACTIVE(ActivityInfo activity) {
            _activity = activity;
        }


        public void run() {
            object(false,new ParentScopeChannelListener(_activity.parent){
                private static final long serialVersionUID = -3357030137175178040L;


                public void compensate(OScope scope, SynchChannel ret) {
                    _psc.compensate(scope,ret);
                    instance(ACTIVE.this);

View Full Code Here

Examples of org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener

                    }
                });
                for (;active.hasNext();) {
                    // Checking out our children
                    final ChildInfo child = active.next();
                    mlSet.add(new ParentScopeChannelListener(child.activity.parent) {
                        private static final long serialVersionUID = -8027205709961438172L;


                        public void compensate(OScope scope, SynchChannel ret) {
                            // Forward compensation to parent
                            _self.parent.compensate(scope, ret);

View Full Code Here

Examples of org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener

        public TCONDINTERCEPT(ParentScopeChannel in) {
            _in = in;
        }


        public void run() {
            object(new ParentScopeChannelListener(_in) {
                private static final long serialVersionUID = 2667359535900385952L;


                public void compensate(OScope scope, SynchChannel ret) {
                    _self.parent.compensate(scope,ret);
                    instance(TCONDINTERCEPT.this);

View Full Code Here

Examples of org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener

                    });


                }


                for (final ActivityInfo ai : _active) {
                    mlset.add(new ParentScopeChannelListener(ai.parent) {
                        private static final long serialVersionUID = 5341207762415360982L;


                        public void compensate(OScope scope, SynchChannel ret) {
                            _psc.compensate(scope, ret);
                            instance(WAITING.this);

View Full Code Here

Examples of org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener

                    }
                });
                for (;active.hasNext();) {
                    // Checking out our children
                    final ChildInfo child = active.next();
                    mlSet.add(new ParentScopeChannelListener(child.activity.parent) {
                        private static final long serialVersionUID = -8027205709961438172L;


                        public void compensate(OScope scope, SynchChannel ret) {
                            // Forward compensation to parent
                            _self.parent.compensate(scope, ret);

View Full Code Here

Examples of org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener

        public TCONDINTERCEPT(ParentScopeChannel in) {
            _in = in;
        }


        public void run() {
            object(new ParentScopeChannelListener(_in) {
                private static final long serialVersionUID = 2667359535900385952L;


                public void compensate(OScope scope, SynchChannel ret) {
                    _self.parent.compensate(scope,ret);
                    instance(TCONDINTERCEPT.this);

View Full Code Here

Examples of org.apache.ode.bpel.runtime.channels.ParentScopeChannelListener

        ACTIVE(ActivityInfo activity) {
            _activity = activity;
        }


        public void run() {
            object(false,new ParentScopeChannelListener(_activity.parent){
                private static final long serialVersionUID = -3357030137175178040L;


                public void compensate(OScope scope, SynchChannel ret) {
                    _psc.compensate(scope,ret);
                    instance(ACTIVE.this);

View Full Code Here

0 1 2 3 4 5

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.