diff --git a/.github/workflows/go-check.yml b/.github/workflows/go-check.yml
new file mode 100644
index 0000000..d54e5b8
--- /dev/null
+++ b/.github/workflows/go-check.yml
@@ -0,0 +1,19 @@
+name: Go Checks
+
+on:
+  pull_request:
+  push:
+    branches: ["main"]
+  workflow_dispatch:
+  merge_group:
+
+permissions:
+  contents: read
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.event_name }}-${{ github.event_name == 'push' && github.sha || github.ref }}
+  cancel-in-progress: true
+
+jobs:
+  go-check:
+    uses: ipdxco/unified-github-workflows/.github/workflows/go-check.yml@v1
diff --git a/.github/workflows/go-test.yml b/.github/workflows/go-test.yml
new file mode 100644
index 0000000..c5c4300
--- /dev/null
+++ b/.github/workflows/go-test.yml
@@ -0,0 +1,21 @@
+name: Go Test
+
+on:
+  pull_request:
+  push:
+    branches: ["main"]
+  workflow_dispatch:
+  merge_group:
+
+permissions:
+  contents: read
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.event_name }}-${{ github.event_name == 'push' && github.sha || github.ref }}
+  cancel-in-progress: true
+
+jobs:
+  go-test:
+    uses: ipdxco/unified-github-workflows/.github/workflows/go-test.yml@v1
+    secrets:
+      CODECOV_TOKEN: ${{ secrets.CODECOV_TOKEN }}
diff --git a/.github/workflows/release-check.yml b/.github/workflows/release-check.yml
new file mode 100644
index 0000000..cd176ae
--- /dev/null
+++ b/.github/workflows/release-check.yml
@@ -0,0 +1,21 @@
+name: Release Checker
+
+on:
+  pull_request_target:
+    paths: ["version.json"]
+    types: [ opened, synchronize, reopened, labeled, unlabeled ]
+  workflow_dispatch:
+
+permissions:
+  contents: write
+  pull-requests: write
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
+jobs:
+  release-check:
+    uses: ipdxco/unified-github-workflows/.github/workflows/release-check.yml@v1
+    with:
+      sources: '["version.json"]'
diff --git a/.github/workflows/releaser.yml b/.github/workflows/releaser.yml
new file mode 100644
index 0000000..60f76c3
--- /dev/null
+++ b/.github/workflows/releaser.yml
@@ -0,0 +1,21 @@
+name: Releaser
+
+on:
+  push:
+    paths: ["version.json"]
+  workflow_dispatch:
+
+permissions:
+  contents: write
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.sha }}
+  cancel-in-progress: true
+
+jobs:
+  releaser:
+    uses: ipdxco/unified-github-workflows/.github/workflows/releaser.yml@v1
+    with:
+      sources: '["version.json"]'
+    secrets:
+      UCI_GITHUB_TOKEN: ${{ secrets.UCI_GITHUB_TOKEN }}
diff --git a/.github/workflows/tagpush.yml b/.github/workflows/tagpush.yml
new file mode 100644
index 0000000..b1709a1
--- /dev/null
+++ b/.github/workflows/tagpush.yml
@@ -0,0 +1,18 @@
+name: Tag Push Checker
+
+on:
+  push:
+    tags:
+      - v*
+
+permissions:
+  contents: read
+  issues: write
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
+jobs:
+  releaser:
+    uses: ipdxco/unified-github-workflows/.github/workflows/tagpush.yml@v1
diff --git a/dsqueue.go b/dsqueue.go
index bb94716..a173a4d 100644
--- a/dsqueue.go
+++ b/dsqueue.go
@@ -133,10 +133,17 @@ func (q *DSQueue) GetN(n int) ([][]byte, error) {
 		return nil, nil
 	}
 	rsp := make(chan getResponse)
-	q.getn <- getRequest{
+	req := getRequest{
 		n:   n,
 		rsp: rsp,
 	}
+
+	select {
+	case q.getn <- req:
+	case <-q.closed:
+		return nil, fmt.Errorf("%s queue closed", q.name)
+	}
+
 	getRsp := <-rsp
 	return getRsp.items, getRsp.err
 }