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