Module: Temporalio::Worker::Interceptor

Defined in:

lib/temporalio/worker/interceptor.rb

Overview

Note:

Input classes herein may get new required fields added and therefore the constructors of the Input classes may change in backwards incompatible ways. Users should not try to construct Input classes themselves.

Mixin for intercepting worker work. Clases that ‘include` may implement their own #intercept_activity that returns their own instance of ActivityInbound.

Defined Under Namespace

Classes: ActivityInbound, ActivityOutbound, ExecuteActivityInput, HeartbeatActivityInput

Instance Method Summary

• #intercept_activity(next_interceptor) ⇒ ActivityInbound

  Method called when intercepting an activity.

Instance Method Details

#intercept_activity(next_interceptor) ⇒ ActivityInbound

Method called when intercepting an activity. This is called when starting an activity attempt.

Parameters:

• next_interceptor (ActivityInbound) —

  Next interceptor in the chain that should be called. This is usually passed to ActivityInbound constructor.

Returns:

• (ActivityInbound) —

  Interceptor to be called for activity calls.

# File 'lib/temporalio/worker/interceptor.rb', line 16

def intercept_activity(next_interceptor)
  next_interceptor
end