@@ -67,14 +67,35 @@ public static List<PersistentSubscriptionInfo> GetNewSubscriptions(List<Persiste
6767 return result ;
6868 }
6969
70- public static SubscriptionWorker IgnoreSubscriptions ( this SubscriptionWorker subscriptionWorker , String ignoreSubscriptions )
70+ public static SubscriptionWorker SetIgnoreGroups ( this SubscriptionWorker subscriptionWorker , String ignoreGroups )
7171 {
72- subscriptionWorker . IgnoreSubscriptions = ignoreSubscriptions ;
72+ subscriptionWorker . IgnoreGroups = ignoreGroups ;
7373
7474 return subscriptionWorker ;
7575 }
76-
77- internal static Boolean IncludeSubscriptionGroup ( PersistentSubscriptionInfo subscription , String include )
76+
77+ public static SubscriptionWorker SetIncludeGroups ( this SubscriptionWorker subscriptionWorker , String includeGroups )
78+ {
79+ subscriptionWorker . IncludeGroups = includeGroups ;
80+
81+ return subscriptionWorker ;
82+ }
83+
84+ public static SubscriptionWorker SetIgnoreStreams ( this SubscriptionWorker subscriptionWorker , String ignoreStreams )
85+ {
86+ subscriptionWorker . IgnoreStreams = ignoreStreams ;
87+
88+ return subscriptionWorker ;
89+ }
90+
91+ public static SubscriptionWorker SetIncludeStreams ( this SubscriptionWorker subscriptionWorker , String includeStreams )
92+ {
93+ subscriptionWorker . IncludeStreams = includeStreams ;
94+
95+ return subscriptionWorker ;
96+ }
97+
98+ private static Boolean IncludeSubscriptionGroup ( PersistentSubscriptionInfo subscription , String include )
7899 {
79100 if ( ! String . IsNullOrEmpty ( include ) )
80101 {
@@ -90,8 +111,8 @@ internal static Boolean IncludeSubscriptionGroup(PersistentSubscriptionInfo subs
90111 return true ;
91112 }
92113
93- internal static Boolean IgnoreSubscriptionGroup ( PersistentSubscriptionInfo subscription ,
94- String ignore ) {
114+ private static Boolean IgnoreSubscriptionGroup ( PersistentSubscriptionInfo subscription ,
115+ String ignore ) {
95116 if ( ! String . IsNullOrEmpty ( ignore ) ) {
96117
97118 List < String > checkList = ignore . Split ( ',' ) . Select ( s => s . Trim ( ) ) . ToList ( ) ;
@@ -105,7 +126,7 @@ internal static Boolean IgnoreSubscriptionGroup(PersistentSubscriptionInfo subsc
105126 return true ;
106127 }
107128
108- internal static Boolean IncludeSubscriptionStream ( PersistentSubscriptionInfo subscription , String include )
129+ private static Boolean IncludeSubscriptionStream ( PersistentSubscriptionInfo subscription , String include )
109130 {
110131 if ( ! String . IsNullOrEmpty ( include ) )
111132 {
@@ -123,8 +144,8 @@ internal static Boolean IncludeSubscriptionStream(PersistentSubscriptionInfo sub
123144 return true ;
124145 }
125146
126- internal static Boolean IgnoreSubscriptionStream ( PersistentSubscriptionInfo subscription ,
127- String ignore ) {
147+ private static Boolean IgnoreSubscriptionStream ( PersistentSubscriptionInfo subscription ,
148+ String ignore ) {
128149 if ( ! String . IsNullOrEmpty ( ignore ) ) {
129150 List < String > checkList = ignore . Split ( ',' ) . Select ( s => s . Trim ( ) ) . ToList ( ) ;
130151
0 commit comments