Skip to content

Commit c470620

Browse files
scotttamdefunkt
authored andcommitted
Need to add before_fork to the helpers
1 parent f1042b1 commit c470620

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

lib/resque/helpers.rb

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,11 @@ def redis
66
Resque.redis
77
end
88

9+
#Direct access to the before_fork proc
10+
def before_fork
11+
Resque.before_fork
12+
end
13+
914
# Given a Ruby object, returns a string suitable for storage in a
1015
# queue.
1116
def encode(object)

lib/resque/worker.rb

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -207,7 +207,7 @@ def startup
207207
enable_gc_optimizations
208208
register_signal_handlers
209209
prune_dead_workers
210-
before_fork
210+
call_before_fork
211211
register_worker
212212
end
213213

@@ -313,8 +313,8 @@ def register_worker
313313
end
314314

315315
#Call any before_fork procs, if any
316-
def before_fork
317-
@@before_fork.call if Worker.class_variable_defined?(:@@before_fork)
316+
def call_before_fork
317+
before_fork.call if before_fork
318318
end
319319

320320
# Unregisters ourself as a worker. Useful when shutting down.

0 commit comments

Comments
 (0)