.setEqualsBehavior( EqualityBehaviorOption.EQUALITY )

.setEventProcessingMode( EventProcessingOption.STREAM );