Package org.drools.core.common

Examples of org.drools.core.common.PropagationContextImpl.evaluateActionQueue()

490
491
492
493
494
495
496
497
498
499
500
        ep.getEntryPointNode().assertObject( handle,
                                             propagationContext,
                                             typeConf,
                                             wm );

        propagationContext.evaluateActionQueue( wm );
        wm.executeQueuedActions();
    }

    private static void cleanReaderContexts(List<PropagationContextImpl> pctxs) {
        for ( PropagationContextImpl ctx : pctxs ) {
View Full Code Here
113
114
115
116
117
118
119
120
121
122
123
                                                                               PropagationContext.EXPIRATION,
                                                                               null,
                                                                               null,
                                                                               previous );
            ObjectTypeNode.doRetractObject( previous, expiresPctx, workingMemory);
            expiresPctx.evaluateActionQueue( workingMemory );
        }
        window.handles[window.pos] = (EventFactHandle) handle;
        return true;
    }
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
                                                                                       PropagationContext.EXPIRATION,
                                                                                       null,
                                                                                       null,
                                                                                       handle );
                    ObjectTypeNode.doRetractObject(handle, expiresPctx, workingMemory);
                    expiresPctx.evaluateActionQueue( workingMemory );
                }
                queue.expiringHandle = null;
                handle = queue.queue.peek();
            }
        }
View Full Code Here
187
188
189
190
191
192
193
194
195
196
197
                    WindowTupleList list = (WindowTupleList) memory.events.get( handle );
                    for( RightTuple tuple = list.getFirstWindowTuple(); tuple != null; tuple = list.getFirstWindowTuple() ) {
                        tuple.getRightTupleSink().retractRightTuple( tuple,
                                                                     propagationContext,
                                                                     workingMemory );
                        propagationContext.evaluateActionQueue( workingMemory );
                        tuple.unlinkFromRightParent();
                    }
                }
                queue.expiringHandle = null;
                handle = queue.queue.peek();
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
            WindowTupleList list = (WindowTupleList) memory.events.get( previous );
            for( RightTuple tuple = list.getFirstWindowTuple(); tuple != null; tuple = list.getFirstWindowTuple() ) {
                tuple.getRightTupleSink().retractRightTuple( tuple,
                                                             propagationContext,
                                                             workingMemory );
                propagationContext.evaluateActionQueue( workingMemory );
                tuple.unlinkFromRightParent();
            }
        }
        window.handles[window.pos] = (EventFactHandle) handle;
        return true;
View Full Code Here
469
470
471
472
473
474
475
476
477
478
479
        ep.getEntryPointNode().assertObject( handle,
                                             propagationContext,
                                             typeConf,
                                             wm );

        propagationContext.evaluateActionQueue( wm );
        wm.executeQueuedActions();
        propagationContext.cleanReaderContext();
    }

    public static InternalFactHandle readFactHandle(MarshallerReaderContext context,
View Full Code Here
487
488
489
490
491
492
493
494
495
496
497
        ep.getEntryPointNode().assertObject( handle,
                                             propagationContext,
                                             typeConf,
                                             wm );

        propagationContext.evaluateActionQueue( wm );
        wm.executeQueuedActions();
    }

    private static void cleanReaderContexts(List<PropagationContextImpl> pctxs) {
        for ( PropagationContextImpl ctx : pctxs ) {
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
                WindowTuple next = tuple.getWindowNext();
                tuple.setPropagationContext(pctx);
                tuple.getRightTupleSink().retractRightTuple(tuple,
                                                            pctx,
                                                            workingMemory);
                pctx.evaluateActionQueue(workingMemory);
                //tuple.unlinkFromRightParent();
                tuple = next;
            }
//            Commented out, for phreak development
//            for( WindowTuple tuple = list.getFirstWindowTuple(); tuple != null;  ) {
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
                        WindowTuple next = tuple.getWindowNext();
                        tuple.setPropagationContext( pctx );
                        tuple.getRightTupleSink().retractRightTuple( tuple,
                                                                     pctx,
                                                                     workingMemory );
                        pctx.evaluateActionQueue( workingMemory );
                        //tuple.unlinkFromRightParent();
                        tuple = next;
                    }
                }
                queue.expiringHandle = null;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.