Class: Karafka::Web::Pro::Ui::Controllers::ScheduledMessages::MessagesController

Inherits:
BaseController show all
Defined in:
lib/karafka/web/pro/ui/controllers/scheduled_messages/messages_controller.rb

Overview

Provides management of schedules related messages

Constant Summary

Constants inherited from Ui::Controllers::BaseController

Ui::Controllers::BaseController::Models

Instance Attribute Summary

Attributes inherited from Ui::Controllers::BaseController

#params, #session

Instance Method Summary collapse

Methods inherited from Ui::Controllers::BaseController

#cache, #initialize

Methods included from Ui::Controllers::Requests::Hookable

included, #run_after_hooks, #run_before_hooks

Constructor Details

This class inherits a constructor from Karafka::Web::Ui::Controllers::BaseController

Instance Method Details

#cancel(topic_id, partition_id, message_offset) ⇒ Object

Generates a cancel request for a given schedule message

Parameters:

  • topic_id (String)
  • partition_id (Integer)
  • message_offset (Integer) 


43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'lib/karafka/web/pro/ui/controllers/scheduled_messages/messages_controller.rb', line 43

def cancel(topic_id, partition_id, message_offset)
  # Fetches the message we want to cancel to get its key
  scheduled_message = Karafka::Admin.read_topic(
    topic_id,
    partition_id,
    1,
    message_offset
  ).first

  cancel_message = ::Karafka::Pro::ScheduledMessages.cancel(
    key: scheduled_message.key,
    envelope: {
      topic: topic_id,
      partition: partition_id
    }
  )

  Karafka::Web.producer.produce_sync(cancel_message)

  redirect(
    :back,
    success: format_flash(
      "A scheduled message with offset ? from ?#? had a ? successfully created",
      message_offset,
      topic_id,
      partition_id,
      "cancel request"
    )
  )
end