Examples of PickResponseChannel

org.apache.ode.bpel.rtrep.v1.channels.PickResponseChannel
Response channel for pick requests. @jacob.kind @jacob.parent TimerResponseChannel
org.apache.ode.bpel.rtrep.v2.channels.PickResponseChannel
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.PickResponseChannel
An auto-generated channel interface for the channel type {@link org.apache.ode.bpel.runtime.channels.PickResponse}. @see org.apache.ode.bpel.runtime.channels.PickResponse @see org.apache.ode.bpel.runtime.channels.PickResponseChannelListener

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

        final String mexId = mex.getMessageExchangeId();
        _vpu.inject(new JacobRunnable() {
            private static final long serialVersionUID = 3168964409165899533L;


            public void run() {
                PickResponseChannel responseChannel = importChannel(responsechannel, PickResponseChannel.class);
                responseChannel.onRequestRcvd(idx, mexId);
            }
        });
    }

View Full Code Here

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

         * @see org.apache.ode.jacob.JacobRunnable#run()
         */
        public void run() {
            Selector selector;
            try {
                PickResponseChannel pickResponseChannel = newChannel(PickResponseChannel.class);
                CorrelationKey key;
                PartnerLinkInstance pLinkInstance = _scopeFrame.resolve(_oevent.partnerLink);
                if (_oevent.matchCorrelation == null) {
                    // Adding a route for opaque correlation. In this case correlation is done on "out-of-band" session id.
                    String sessionId = getBpelRuntimeContext().fetchMySessionId(pLinkInstance);

View Full Code Here

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

    public void updateExtensionContext(BpelRuntimeContext context) {
        ((ExtensionContextImpl)_extensionContext).setBpelRuntimeContext(context);
    }


    public void run() {
        PickResponseChannel pickResponseChannel = (PickResponseChannel)JacobVPU.activeJacobThread().newChannel(PickResponseChannel.class, getClass().getSimpleName(), null);
      runAsync(_extensionContext, _cid, _element);
        JacobVPU.activeJacobThread().instance(new WAITING(pickResponseChannel, _extensionContext.getCorrelationValues()));
    }

View Full Code Here

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


    /**
     * @see org.apache.ode.jacob.JacobRunnable#run()
     */
    public void run() {
        PickResponseChannel pickResponseChannel = newChannel(PickResponseChannel.class);
        Date timeout;
        Selector[] selectors;


        try {
            selectors = new Selector[_opick.onMessages.size()];

View Full Code Here

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

        final String mexId = mex.getMessageExchangeId();
        _vpu.inject(new JacobRunnable() {
            private static final long serialVersionUID = 3168964409165899533L;


            public void run() {
                PickResponseChannel responseChannel = importChannel(responsechannel, PickResponseChannel.class);
                responseChannel.onRequestRcvd(idx, mexId);
            }
        });
    }

View Full Code Here

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

         * @see org.apache.ode.jacob.JacobRunnable#run()
         */
        public void run() {
            Selector selector;
            try {
                PickResponseChannel pickResponseChannel = newChannel(PickResponseChannel.class);
                CorrelationKeySet keySet = new CorrelationKeySet();
                PartnerLinkInstance pLinkInstance = _scopeFrame.resolve(_oevent.partnerLink);
                for( OScope.CorrelationSet cset : _oevent.joinCorrelations ) {
                    if(getBpelRuntimeContext().isCorrelationInitialized(_scopeFrame.resolve(cset))) {
                        keySet.add(getBpelRuntimeContext().readCorrelation(_scopeFrame.resolve(cset)));

View Full Code Here

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


    /**
     * @see org.apache.ode.jacob.JacobRunnable#run()
     */
    public void run() {
        PickResponseChannel pickResponseChannel = newChannel(PickResponseChannel.class);
        Date timeout;
        Selector[] selectors;


        try {
            selectors = new Selector[_opick.onMessages.size()];

View Full Code Here

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

        final String mexId = mex.getMessageExchangeId();
        vpu.inject(new JacobRunnable() {
            private static final long serialVersionUID = 3168964409165899533L;


            public void run() {
                PickResponseChannel responseChannel = importChannel(responsechannel, PickResponseChannel.class);
                responseChannel.onRequestRcvd(idx, mexId);
            }
        });
    }

View Full Code Here

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

         * @see org.apache.ode.jacob.JacobRunnable#run()
         */
        public void run() {
            Selector selector;
            try {
                PickResponseChannel pickResponseChannel = newChannel(PickResponseChannel.class);
                CorrelationKey key;
                PartnerLinkInstance pLinkInstance = _scopeFrame.resolve(_oevent.partnerLink);
                if (_oevent.matchCorrelation == null) {
                    // Adding a route for opaque correlation. In this case correlation is done on "out-of-band" session id.
                    String sessionId = getBpelRuntimeContext().fetchMySessionId(pLinkInstance);

View Full Code Here

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

        final String mexId = mex.getMessageExchangeId();
        _vpu.inject(new JacobRunnable() {
            private static final long serialVersionUID = 3168964409165899533L;


            public void run() {
                PickResponseChannel responseChannel = importChannel(responsechannel, PickResponseChannel.class);
                responseChannel.onRequestRcvd(idx, mexId);
            }
        });
    }

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.