1 files changed, 34 insertions, 0 deletions
diff --git a/plugins/jobs/pq_plugin/plugin.go b/plugins/jobs/pq_plugin/plugin.go
new file mode 100644
index 00000000..7df846ac
--- /dev/null
+++ b/plugins/jobs/pq_plugin/plugin.go
@@ -0,0 +1,34 @@
+package pq_plugin //nolint:stylecheck
+
+import (
+	priorityqueue "github.com/spiral/roadrunner/v2/pkg/priority_queue"
+	"github.com/spiral/roadrunner/v2/plugins/logger"
+)
+
+const (
+	PluginName string = "internal_pq"
+)
+
+type Plugin struct {
+	log logger.Logger
+	pq  priorityqueue.Queue
+}
+
+func (p *Plugin) Init(log logger.Logger) error {
+	p.log = log
+	p.pq = priorityqueue.NewPriorityQueue()
+	return nil
+}
+
+func (p *Plugin) Push(item interface{}) {
+	p.pq.Push(item)
+	// no-op
+}
+
+func (p *Plugin) Pop() interface{} {
+	return p.pq.Pop()
+}
+
+func (p *Plugin) Name() string {
+	return PluginName
+}