From 6d0ff8dfc601132b3eaa2d0a24dbaf6b047c5e89 Mon Sep 17 00:00:00 2001
From: Henry Clifford <h.a.clifford@gmail.com>
Date: Wed, 7 Mar 2018 18:35:17 -0500
Subject: [PATCH] make jobFunc public

---
 job.go     | 2 +-
 manager.go | 4 ++--
 workers.go | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/job.go b/job.go
index de8fd75..ba68e17 100644
--- a/job.go
+++ b/job.go
@@ -1,3 +1,3 @@
 package workers
 
-type jobFunc func(message *Msg)
+type JobFunc func(message *Msg)
diff --git a/manager.go b/manager.go
index 0e4ee6f..380dca6 100644
--- a/manager.go
+++ b/manager.go
@@ -8,7 +8,7 @@ import (
 type manager struct {
 	queue       string
 	fetch       Fetcher
-	job         jobFunc
+	job         JobFunc
 	concurrency int
 	workers     []*worker
 	workersM    *sync.Mutex
@@ -93,7 +93,7 @@ func (m *manager) reset() {
 	m.fetch = Config.Fetch(m.queue)
 }
 
-func newManager(queue string, job jobFunc, concurrency int, mids ...Action) *manager {
+func newManager(queue string, job JobFunc, concurrency int, mids ...Action) *manager {
 	var customMids *Middlewares
 	if len(mids) == 0 {
 		customMids = Middleware
diff --git a/workers.go b/workers.go
index fc39be6..6fc6d72 100644
--- a/workers.go
+++ b/workers.go
@@ -28,7 +28,7 @@ var Middleware = NewMiddleware(
 	&MiddlewareStats{},
 )
 
-func Process(queue string, job jobFunc, concurrency int, mids ...Action) {
+func Process(queue string, job JobFunc, concurrency int, mids ...Action) {
 	access.Lock()
 	defer access.Unlock()