On 22 October 2010 09:14, Ayush <firstname.lastname@example.org> wrote:
Thank you for your reply.
I think I was heading into the wrong direction. Now when I've synchronized
the function which is creating session, session is static and is only called
once, and firing the rules it's working fine. I'm planning to use JMS
wherein consumer will be syncronized. Is this the right way?
But I've following rule rule
$RA : AlertReceivedEvent( severity == 2, $entityA : entity ) over
window:time(60s) from entry-point NotificationStream
$RB : AlertReceivedEvent( this != $RA, severity == 1, $entityB : entity )
over window:time(60s) from entry-point NotificationStream
$alertB : X733Alert(this.entity == $entityB, correlationState !=
$alertA : X733Alert(this.entity == $entityA, correlationState !=
System.out.println("#### Running TwoAlertsFromSameSource... ####");
System.out.println("correlation state "+$alertB.getCorrelationState());
In above rules it's unable to modify $alertB