Package org.drools.common

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

829
830
831
832
833
834
835
836
837
838
839
                                                                                      tuple,
                                                                                      null );
                            ((LeftTupleSink) sink).retractLeftTuple( tuple,
                                                                     pContext,
                                                                     wm );
                            pContext.evaluateActionQueue( wm );
                        }

                    }
                } catch ( Exception e ) {
                    throw new IllegalArgumentException( "line " + step.getLine() + ": unable to execute command " + Arrays.toString( cmd ),
View Full Code Here
895
896
897
898
899
900
901
902
903
904
905
                                                              modifyPreviousTuples,
                                                              pContext,
                                                              wm );
                            modifyPreviousTuples.retractTuples( pContext,
                                                                wm );
                            pContext.evaluateActionQueue( wm );
                        } else {
                            List<InternalFactHandle> tlist = (List<InternalFactHandle>) element;
                            String id = getTupleId( tlist );
                            LeftTuple tuple = (LeftTuple) context.get( id );
                            if ( tuple == null ) {
View Full Code Here
911
912
913
914
915
916
917
918
919
920
921
                                                                                      tuple,
                                                                                      new DefaultFactHandle(1, "") );
                            ((LeftTupleSink) sink).modifyLeftTuple( tuple,
                                                                    pContext,
                                                                    wm );
                            pContext.evaluateActionQueue( wm );
                        }
                    }
                } catch ( Exception e ) {
                    throw new IllegalArgumentException( "line " + step.getLine() + ": unable to execute command " + cmd,
                                                        e );
View Full Code Here
183
184
185
186
187
188
189
190
191
192
193
                                                                                              null,
                                                                                              handle );
                    tuple.getRightTupleSink().retractRightTuple( tuple,
                                                                 propagationContext,
                                                                 workingMemory );
                    propagationContext.evaluateActionQueue( workingMemory );
                }
                tuple.unlinkFromRightParent();
            }
            queue.expiringTuple = null;
            tuple = queue.queue.peek();
View Full Code Here
483
484
485
486
487
488
489
490
491
492
493
        ep.getEntryPointNode().assertObject( handle,
                                             propagationContext,
                                             typeConf,
                                             wm );

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

    public static InternalFactHandle readFactHandle(MarshallerReaderContext context,
                                                    WorkingMemoryEntryPoint entryPoint,
View Full Code Here
481
482
483
484
485
486
487
488
489
490
491
        ep.getEntryPointNode().assertObject( handle,
                                             propagationContext,
                                             typeConf,
                                             wm );

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

    public static InternalFactHandle readFactHandle(MarshallerReaderContext context,
                                                    WorkingMemoryEntryPoint entryPoint,
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
                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;
View Full Code Here
204
205
206
207
208
209
210
211
212
213
214
                    WindowTupleList list = (WindowTupleList) memory.events.remove( handle );
                    for( RightTuple tuple = list.getFirstWindowTuple(); tuple != null; tuple = list.getFirstWindowTuple() ) {
                        tuple.getRightTupleSink().retractRightTuple( tuple,
                                                                     propagationContext,
                                                                     workingMemory );
                        propagationContext.evaluateActionQueue( workingMemory );
                        tuple.unlinkFromRightParent();
                    }
                } else {
                    memory.events.remove( handle );
                }
View Full Code Here
477
478
479
480
481
482
483
484
485
486
487
        ep.getEntryPointNode().assertObject( handle,
                                             propagationContext,
                                             typeConf,
                                             wm );

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

    public static InternalFactHandle readFactHandle(MarshallerReaderContext context,
View Full Code Here
192
193
194
195
196
197
198
199
200
201
202
            for ( BaseNode node : context.getNodes() ) {
                node.updateSinkOnAttach( context, propagationContext, workingMemory );
            }

            propagationContext.evaluateActionQueue( workingMemory );
        }
    }

    /**
     * Adds a query pattern to the given subrule
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.