Sha256: e9a792ae7e730702b8d2115ec19c20e84a2ceb05010dfe4255635e4f555d48e5

Contents?: true

Size: 305 Bytes

Versions: 28

Compression:

Stored size: 305 Bytes

Contents

module Messaging
  module Routing
    # Internal: Used for enqueing background jobs instead of calling the handler directly
    class EnqueuedRoute < Route
      def initialize(pattern, handler)
        super
        @handler = EnqueueMessageHandler.new(handler).method(:call)
      end
    end
  end
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version Path
messaging-4.0.12 lib/messaging/routing/enqueued_route.rb
messaging-4.0.11 lib/messaging/routing/enqueued_route.rb
messaging-4.0.10 lib/messaging/routing/enqueued_route.rb
messaging-4.0.10.pre lib/messaging/routing/enqueued_route.rb
messaging-4.0.9 lib/messaging/routing/enqueued_route.rb
messaging-4.0.8 lib/messaging/routing/enqueued_route.rb
messaging-4.0.7 lib/messaging/routing/enqueued_route.rb
messaging-4.0.6 lib/messaging/routing/enqueued_route.rb
messaging-4.0.5 lib/messaging/routing/enqueued_route.rb
messaging-4.0.4.pre lib/messaging/routing/enqueued_route.rb
messaging-4.0.3.pre lib/messaging/routing/enqueued_route.rb
messaging-4.0.2.pre lib/messaging/routing/enqueued_route.rb
messaging-4.0.1.pre lib/messaging/routing/enqueued_route.rb
messaging-4.0.0.pre lib/messaging/routing/enqueued_route.rb
messaging-3.8.2 lib/messaging/routing/enqueued_route.rb
messaging-3.8.1 lib/messaging/routing/enqueued_route.rb
messaging-3.8.0 lib/messaging/routing/enqueued_route.rb
messaging-3.7.3 lib/messaging/routing/enqueued_route.rb
messaging-3.7.2 lib/messaging/routing/enqueued_route.rb
messaging-3.7.1 lib/messaging/routing/enqueued_route.rb