class GlassOctopus::Context
Message context. Wraps a Kafka message and adds some convenience methods.
@!attribute [rw] logger
A logger object. Defaults to the application logger.
@!attribute [r] message
A message read from Kafka. @return [Message]
Attributes
logger[RW]
message[R]
Public Class Methods
new(message, logger)
click to toggle source
@api private
# File lib/glass_octopus/context.rb, line 24 def initialize(message, logger) @data = {} @message = message @logger = logger end