@@ -12,28 +12,32 @@ def self.included(cls)
12
12
end
13
13
end
14
14
15
- def starting
16
- ## unless batch_size.nil?
17
- ## logger.info(tag: :*) { "Batch Size: #{batch_size.inspect}" }
18
- ## end
19
- logger . debug ( tag : :* ) { "Batch Size: #{ batch_size . inspect } " }
15
+ def print_startup_info
16
+ STDOUT . puts " Batch Size: #{ get . batch_size . inspect } "
20
17
21
- ## unless correlation.nil?
22
- ## logger.info(tag: :*) { "Correlation: #{correlation.inspect}" }
23
- ## end
24
- logger . debug ( tag : :* ) { "Correlation: #{ correlation . inspect } " }
18
+ unless correlation . nil?
19
+ STDOUT . puts " Correlation: #{ correlation || '(none)' } "
20
+ end
21
+
22
+ unless group_member . nil? && group_size . nil?
23
+ STDOUT . puts " Group Member: #{ group_member . inspect } "
24
+ STDOUT . puts " Group Size: #{ group_size . inspect } "
25
+ end
26
+
27
+ unless condition . nil?
28
+ STDOUT . puts " Condition: #{ condition . inspect } "
29
+ end
30
+ end
25
31
26
- ## unless group_member.nil? && group_size.nil?
27
- ## logger.info (tag: :*) { "Group Member: #{group_member.inspect}, Group Size: #{group_size .inspect}" }
28
- ## end
32
+ def log_startup_info
33
+ logger . debug ( tag : :* ) { "Batch Size: #{ get . batch_size . inspect } " }
34
+ logger . debug ( tag : :* ) { "Correlation: #{ correlation . inspect } " }
29
35
logger . debug ( tag : :* ) { "Group Member: #{ group_member . inspect } " }
30
36
logger . debug ( tag : :* ) { "Group Size: #{ group_size . inspect } " }
31
-
32
- ## unless condition.nil?
33
- ## logger.info(tag: :*) { "Condition: #{condition.inspect}" }
34
- ## end
35
37
logger . debug ( tag : :* ) { "Condition: #{ condition . inspect } " }
38
+ end
36
39
40
+ def starting
37
41
if identifier . nil? && !group_member . nil? && !group_size . nil?
38
42
raise Identifier ::Error , 'Identifier must not be omitted when the consumer is a member of a group'
39
43
end
0 commit comments