{"_id":"@anabranch/queue","_rev":"16-0798830116c80ec960c5d91636ba5215","name":"@anabranch/queue","dist-tags":{"latest":"0.3.7"},"versions":{"0.1.0":{"name":"@anabranch/queue","version":"0.1.0","license":"MIT","_id":"@anabranch/queue@0.1.0","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"3888c1f19fe439077175fe194ed394756f99a28b","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.1.0.tgz","fileCount":37,"integrity":"sha512-RdZmtrkB+bGUJQ8dPdXYi6R7TYbLkD2mgscCqKV4Fo981sHnzcf4qyuCF7jivWj1d/Y02T0mIkLwp1N2q+fWZw==","signatures":[{"sig":"MEYCIQCVTA8rwZZ3K+qlQylvUxQtGAp5Av3FtVYJcxl0bBqoOQIhAMFYqp9nV+xA9AgBbxG6N/4FR/jj67I4I/E/eyXShtpO","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":138363},"module":"./esm/queue/index.js","exports":{".":{"import":"./esm/queue/index.js"}},"gitHead":"a2e83b2587b94bc649d7ec2a876d1dec66f476d8","scripts":{},"_npmUser":{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.9.0","description":"Message queue with dead letter queue and visibility timeout support","directories":{},"_nodeVersion":"25.6.1","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"_npmOperationalInternal":{"tmp":"tmp/queue_0.1.0_1772852752659_0.30078686466176197","host":"s3://npm-registry-packages-npm-production"}},"0.1.1":{"name":"@anabranch/queue","version":"0.1.1","license":"MIT","_id":"@anabranch/queue@0.1.1","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"62e5f30e81cc2a86f4366a74d4b4c0dff622ba77","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.1.1.tgz","fileCount":37,"integrity":"sha512-E0wb1GuAU8KzRDTVJh2B1nCcE4JFYop9HmKwdeXKRH/L9pjRgx9w6dpDAY9ER8AO/cAqYPGozSpJVy/fOqja8g==","signatures":[{"sig":"MEUCIFMlXqrsszbPFsh735zK156jIypHIrrNrGZoK2BKpCdyAiEA2C6vbGxwScqPoHowUtmTySYZShJGY5J+Ze7V11L0N84=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.1.1","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":138363},"module":"./esm/queue/index.js","exports":{".":{"import":"./esm/queue/index.js"}},"gitHead":"8ce04366e7975304635d0d40dec385efce556d6a","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Message queue with dead letter queue and visibility timeout support","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"_npmOperationalInternal":{"tmp":"tmp/queue_0.1.1_1772853136687_0.46217151950025004","host":"s3://npm-registry-packages-npm-production"}},"0.1.2":{"name":"@anabranch/queue","version":"0.1.2","license":"MIT","_id":"@anabranch/queue@0.1.2","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"580f9182ffe8a7898c177a627601e63bfc9aae3a","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.1.2.tgz","fileCount":37,"integrity":"sha512-DOurQhZYyAnTL1/TO8/g8iVbw6MFPvu9K8ju5EfZzhjSUGMxpEtXLbCii14kJTmfRmhJnQ7Z39EYQcAy2BLiuw==","signatures":[{"sig":"MEUCIQCij5npIR15w0qIpoWnz2XF/Of9zZougLGyfkLP3MOBgQIgCc4YwtQJ2bfrtlEgq7+HzozFn6q7ZZSnG69++ijprLs=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.1.2","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":138679},"module":"./esm/queue/index.js","exports":{".":{"import":"./esm/queue/index.js"}},"gitHead":"31762283bdc489eaca65a1b37d183cfd8f62e11d","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Message queue with dead letter queue and visibility timeout support","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"_npmOperationalInternal":{"tmp":"tmp/queue_0.1.2_1772853741904_0.7739552200677293","host":"s3://npm-registry-packages-npm-production"}},"0.1.3":{"name":"@anabranch/queue","version":"0.1.3","license":"MIT","_id":"@anabranch/queue@0.1.3","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"7e3c6aa85b807f21f37a80d373c4b964acf9085a","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.1.3.tgz","fileCount":37,"integrity":"sha512-qQGnEjPVcKTKdFDxMp7lLMk6pcUujaYYwMOeD87xup1T9y80HTSnCHsseGm8Z5hAUvFVoV+FSsOQR+VarH9+uA==","signatures":[{"sig":"MEQCIEV2HF3Xm39dZ1b11bWp+SajHl9VOj4UZ9Xul2SfZ7h7AiAnjpxzAcJ7i+iL4bzsmWpf8Cm0KRWKgR31+TqqSoNbZg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.1.3","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":138679},"module":"./esm/queue/index.js","exports":{".":{"import":"./esm/queue/index.js"}},"gitHead":"d5669922bf5f6add420723fd0a9d2286035ada09","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Message queue with dead letter queue and visibility timeout support","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"_npmOperationalInternal":{"tmp":"tmp/queue_0.1.3_1772854582414_0.9943532534615183","host":"s3://npm-registry-packages-npm-production"}},"0.1.4":{"name":"@anabranch/queue","version":"0.1.4","license":"MIT","_id":"@anabranch/queue@0.1.4","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"aa2fe87f103f7a9e6b61ddba7629bc8e5fec1def","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.1.4.tgz","fileCount":19,"integrity":"sha512-sYDQ0rmwRQNEzk3LRoi6kZJYGlUrDfBaN7I/AL5uFM2qCZ+WDR1DF6iSFp0eELQQICkhq0hEy0gFhJnjawaL8A==","signatures":[{"sig":"MEUCIQCb5PNPCla0sz9nAzx2bKX4CEzpU6Ep5TpbDxL/4oBeIQIgOlLyaupUCTEGR31Z9AhetCeKUE8vVShEdAOaQVPO2gs=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.1.4","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":54837},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"2bd4067daac44eee7b6e9b70db97867408778ac9","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Message queue with dead letter queue and visibility timeout support","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"_npmOperationalInternal":{"tmp":"tmp/queue_0.1.4_1772855634577_0.847154174533232","host":"s3://npm-registry-packages-npm-production"}},"0.1.5":{"name":"@anabranch/queue","version":"0.1.5","license":"MIT","_id":"@anabranch/queue@0.1.5","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"e8a6ef34454b63338aba25f557d5a6a1f4b07599","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.1.5.tgz","fileCount":19,"integrity":"sha512-VCiyugjqB6f9vfywYEOnGtjTojqzyMcor/V24kIQ4raknZM/8b7rzW7Po8Ognxk7SpaGM8bCBAl3uhctazU+tA==","signatures":[{"sig":"MEUCIQCzqotusT2vsuzmB3GHMkvtkJxqN1AC5uMrR+CVD755+AIgTEteOwDgsY6CVWClv8pO+V3lP3vNePtiz5HVGRLndTE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.1.5","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":55720},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"a7c095bb1722912ba6afda32970a3b5ddcf6d668","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Message queue with dead letter queue and visibility timeout support","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"_npmOperationalInternal":{"tmp":"tmp/queue_0.1.5_1772924002274_0.6804294118216048","host":"s3://npm-registry-packages-npm-production"}},"0.1.10":{"name":"@anabranch/queue","version":"0.1.10","license":"MIT","_id":"@anabranch/queue@0.1.10","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"3025ba15112535e53309f602e83d7baa7b4503d6","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.1.10.tgz","fileCount":19,"integrity":"sha512-jNeb+UrpZrbzrBqxDnql9fR2gPURqiaRhOFo6ySV3vLRTgW08FVGZ00fOHoiaYF5jMIAANiMtw4hmjOTWP53Zw==","signatures":[{"sig":"MEUCIG8T0VkEf5kiJoRxzA68Kg8evfY+3mKsHrlIhfa4xRrvAiEAkspiWDZHUAMEt24PGAayaitbWR2rMwBq29iSajjNit4=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.1.10","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":55774},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"22c2ab92e8138249e5cb55850ed2235e5533f973","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Message queue with dead letter queue and visibility timeout support","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^22"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.1.10_1772982994973_0.5952375483541543","host":"s3://npm-registry-packages-npm-production"}},"0.1.11":{"name":"@anabranch/queue","version":"0.1.11","license":"MIT","_id":"@anabranch/queue@0.1.11","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"cf8b3c74536af6fb9f51b6950b0db87df1092dcd","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.1.11.tgz","fileCount":19,"integrity":"sha512-pBRLjstslzMD7khNS2nHofku5rnkzhgVZ33Aqiyrbcjvz3VTc0ZMXQLBX5pI1TtSBxUwwUmsrMk4vHDqvivBmg==","signatures":[{"sig":"MEYCIQCU37cpUkPL/+XtfgfMq024aTjQEzbevBP3xrwL8t6hrAIhANDmqbRBUghXJkovrvAsU6MeAMRmvHMaUdDr0IM+AFHQ","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.1.11","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":55833},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"9b3f55217aa7a1676de346dcb4c48d51ed171c17","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.1.11_1772988790953_0.9383825403279087","host":"s3://npm-registry-packages-npm-production"}},"0.2.0":{"name":"@anabranch/queue","version":"0.2.0","license":"MIT","_id":"@anabranch/queue@0.2.0","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"7f806be336ec4ff50f3490c5cae102ca6ffc5a88","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.2.0.tgz","fileCount":19,"integrity":"sha512-33PmA91ZHFOSLmfhlLOr1QknUFAYl9/dw+f2HVnf5oy9Y8tbH8uUMDdpMvFAHBs1eebrLO3qb/vLOlllwQKoUw==","signatures":[{"sig":"MEUCIQDQAPTOSVUZXf9JfYac61fosPh7mLpuuYQYUCIcLG1EFQIgeo05jvckxEd9gmX+CSIsLPcxvmvCGwQgn/NEedu7bBQ=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.2.0","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":58550},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"1b02d5135b166a5c2ffdb53f4af9b76fe4d4659d","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.0","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.2.0_1773155066774_0.8512290552520305","host":"s3://npm-registry-packages-npm-production"}},"0.3.1":{"name":"@anabranch/queue","version":"0.3.1","license":"MIT","_id":"@anabranch/queue@0.3.1","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"f709800191006f19b0ccef635861a2093fcab727","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.3.1.tgz","fileCount":19,"integrity":"sha512-L2IDSnAVkgEX1CEKQeENDL0L/UJj+srleDukSiC9uPV2Klq0hYKIp9CTcvx2njqlAnU3OdiHKLztYuP2n33YfQ==","signatures":[{"sig":"MEUCIB8YvzWB6Cmb+wzPcupPyeqfrW3HUomhtsXq2nYufVvjAiEAgcfVSzZs7H8dZzSEkY9qVvGL5MAhwMv2Q3+81MREY7I=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.3.1","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":66752},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"2d7e5c840ff2be91ac832daff4435cd080ebb78a","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","directories":{},"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.3.1_1773349438463_0.4520256670604088","host":"s3://npm-registry-packages-npm-production"}},"0.3.2":{"name":"@anabranch/queue","version":"0.3.2","license":"MIT","_id":"@anabranch/queue@0.3.2","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"b2be77b31ace35a4b4c520cad0ac402342204fe7","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.3.2.tgz","fileCount":19,"integrity":"sha512-dEhq8/xK1WPBcGNzmXjZhQZMlG8eSXPLUCoiCDQKtaG27YhCduJFnKs6fy5kUQNSf1Y3+0w0OLYLHHZkCHgrZg==","signatures":[{"sig":"MEUCID6QQh8hOkLW7v6DCOKYwXB2rwRPVmK8aUMj4K5zQHQaAiEA7K7Ton4r+zGmLmL7odjnjY8l33xjzdH2HTL5KyDBh7c=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.3.2","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":65356},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"4c2c0ca03ed88adb112fc872bd9bf850300d2cf2","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.3.2_1773587194938_0.21433192499559905","host":"s3://npm-registry-packages-npm-production"}},"0.3.3":{"name":"@anabranch/queue","version":"0.3.3","license":"MIT","_id":"@anabranch/queue@0.3.3","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"d7a6bfd7da8491d2ff201d6da8ee93772068974d","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.3.3.tgz","fileCount":19,"integrity":"sha512-OWGIyWZAVCO3iL89Dp7+qxBCsBcj1+crMDePdQBoznULx+p33WEAFzfdNONDdJYzcgc9OdwrYQARraEZzWu45A==","signatures":[{"sig":"MEUCIQC/klTi6XElFXXxwU64dijSYk4B9rkBjvPBY94Ba2NCNQIgK4VTA64fQiMqA8ePH46WFh2FrCIl/ilsQ61822RQwyI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.3.3","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":65356},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"091ffb1fa1a732d1c1e4f7032f2f5d404f14e82a","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.3.3_1773610024999_0.968869245526871","host":"s3://npm-registry-packages-npm-production"}},"0.3.4":{"name":"@anabranch/queue","version":"0.3.4","license":"MIT","_id":"@anabranch/queue@0.3.4","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"d491773b3cd90841ba52391d57a82597351b92db","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.3.4.tgz","fileCount":19,"integrity":"sha512-+yUDLAvftqdI6rIdghI8aMmpvdK9gST8bM9Un/Fv/25KVpioSmBqlPAJ2DSbsHofqxLmlIdjUAB5HovmHWjV+Q==","signatures":[{"sig":"MEYCIQC2SmelbsgiW/5SwzBN5NHZDwZnUUxAMr2pHhG956L+igIhAJUsskSVGFFSv8grgFgzRHEopSgWG2OYNURhZmY+UU5u","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.3.4","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":65356},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"a4c03810743f5196cc00c1b117c7870a7eb659e7","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.3.4_1773611227807_0.4380812873825384","host":"s3://npm-registry-packages-npm-production"}},"0.3.5":{"name":"@anabranch/queue","version":"0.3.5","license":"MIT","_id":"@anabranch/queue@0.3.5","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"4ce8538038552e0128d9119a5fb60828ea20543a","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.3.5.tgz","fileCount":19,"integrity":"sha512-slgf7owuafowYwPCYuaFlIMeFUMEcpPMWwR586hazRc2Qbug1ymGBpeWj+ffu4IdFt8b/e2AU5lcWONf0yyRjw==","signatures":[{"sig":"MEUCIE71V7Fjfa11HIktXuQ+SolI2hQoBUyVW0R/lVtDZQCTAiEAjjJ0rhnW08KElU+ooLx1k9747kq8D25S75/XR6+juAg=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.3.5","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":65356},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"c65b2bb9f8d92d77064cec236c3732bd5e0d8c76","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.3.5_1773614109856_0.3241572581403265","host":"s3://npm-registry-packages-npm-production"}},"0.3.6":{"name":"@anabranch/queue","version":"0.3.6","license":"MIT","_id":"@anabranch/queue@0.3.6","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"homepage":"https://github.com/frodi-karlsson/anabranch#readme","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"dist":{"shasum":"affe56787e59b26a977692b4d170d04e6fa515c0","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.3.6.tgz","fileCount":19,"integrity":"sha512-tSDKO5ZHad0cg9qneUeBJx/BHs4iIzGNMJ3y7elispMStVovN/figD1Njly6hLJ0Xo1NpaYb97BrDke/xUNmSQ==","signatures":[{"sig":"MEUCIQD0dJ3NilW1N8H3HN0pC6tdm9zlrFx/BTn5aNXMuxLGTgIgQt2vej/0JA1ZQehzYICQSluhuosAxbh6S5RW6UsWEeE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.3.6","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"unpackedSize":64631},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"gitHead":"748f940f5634aa22ce8fd330e10cfdc559949594","scripts":{},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"repository":{"url":"git+https://github.com/frodi-karlsson/anabranch.git","type":"git"},"_npmVersion":"11.11.1","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","directories":{},"sideEffects":false,"_nodeVersion":"24.14.0","dependencies":{"anabranch":"^0"},"_hasShrinkwrap":false,"devDependencies":{"@types/node":"^24"},"_npmOperationalInternal":{"tmp":"tmp/queue_0.3.6_1773746462301_0.7236675322078479","host":"s3://npm-registry-packages-npm-production"}},"0.3.7":{"name":"@anabranch/queue","version":"0.3.7","description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","repository":{"type":"git","url":"git+https://github.com/frodi-karlsson/anabranch.git"},"license":"MIT","bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"module":"./esm/index.js","exports":{".":{"import":"./esm/index.js"}},"scripts":{},"sideEffects":false,"dependencies":{"anabranch":"^0"},"devDependencies":{"@types/node":"^24"},"gitHead":"6fd573e3068a3f60814d0e57a3a7097b16c42381","_id":"@anabranch/queue@0.3.7","homepage":"https://github.com/frodi-karlsson/anabranch#readme","_nodeVersion":"24.18.0","_npmVersion":"11.18.0","dist":{"integrity":"sha512-T8FObWPO5smxcwZd/OtZHbr6Yi0/Nf4vOpMjjw+X/KyDOEPnRgUAvUv9DrEpZftn6gP2lHKMSB8WdhqEW1ju2A==","shasum":"28448b308399f0ba9720be0448d00b6b6d770507","tarball":"https://registry.npmjs.org/@anabranch/queue/-/queue-0.3.7.tgz","fileCount":19,"unpackedSize":64631,"attestations":{"url":"https://registry.npmjs.org/-/npm/v1/attestations/@anabranch%2fqueue@0.3.7","provenance":{"predicateType":"https://slsa.dev/provenance/v1"}},"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEQCIHE1a4xSTSWeN1RSrLx4qbS+2jHZuKub/PXlVStgw0/EAiBXFZysXeVbiDyvKz+SxsdihTwfFuggBVdD0dNE00I5qg=="}]},"_npmUser":{"name":"GitHub Actions","email":"npm-oidc-no-reply@github.com","trustedPublisher":{"id":"github","oidcConfigId":"oidc:aac61724-daae-4c13-87f4-e3fc601dce11"}},"directories":{},"maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/queue_0.3.7_1782955760944_0.5794848588151331"},"_hasShrinkwrap":false}},"time":{"created":"2026-03-07T03:05:52.564Z","modified":"2026-07-02T01:29:21.366Z","0.1.0":"2026-03-07T03:05:52.809Z","0.1.1":"2026-03-07T03:12:16.851Z","0.1.2":"2026-03-07T03:22:22.055Z","0.1.3":"2026-03-07T03:36:22.571Z","0.1.4":"2026-03-07T03:53:54.745Z","0.1.5":"2026-03-07T22:53:22.413Z","0.1.10":"2026-03-08T15:16:35.131Z","0.1.11":"2026-03-08T16:53:11.103Z","0.2.0":"2026-03-10T15:04:26.909Z","0.3.1":"2026-03-12T21:03:58.634Z","0.3.2":"2026-03-15T15:06:35.084Z","0.3.3":"2026-03-15T21:27:05.133Z","0.3.4":"2026-03-15T21:47:07.957Z","0.3.5":"2026-03-15T22:35:10.063Z","0.3.6":"2026-03-17T11:21:02.550Z","0.3.7":"2026-07-02T01:29:21.085Z"},"bugs":{"url":"https://github.com/frodi-karlsson/anabranch/issues"},"license":"MIT","homepage":"https://github.com/frodi-karlsson/anabranch#readme","repository":{"type":"git","url":"git+https://github.com/frodi-karlsson/anabranch.git"},"description":"Message queue with Task/Stream semantics. In-memory adapter with delayed messages, dead letter queues, and visibility timeout.","maintainers":[{"name":"frodikarlsson","email":"frodikarlsson@gmail.com"}],"readme":"# @anabranch/queue\n\nQueue primitives with Task/Stream semantics for error-tolerant message\nprocessing.\n\n## Description\n\nA queue abstraction that integrates with anabranch's Task and Stream types for\ncomposable error handling, concurrent processing, and automatic resource\nmanagement.\n\n## Features\n\n- **Task/Stream Integration**: Leverage Task's retry/timeout and Stream's error\n  collection\n- **Multiple Adapters**: In-memory implementation included, Redis/RabbitMQ/SQS\n  coming soon\n- **Delayed Messages**: Support for scheduled/delayed message delivery\n- **Dead Letter Queues**: Automatic routing of failed messages after max\n  attempts\n- **Batch Operations**: Send multiple messages, acknowledge multiple at once\n\n## Installation\n\n```bash\n# JSR\njsr add @anabranch/queue\n\n# Deno\ndeno add @anabranch/queue\n```\n\n## Quick Start\n\n```ts\nimport { createInMemory, Queue } from '@anabranch/queue'\n\nconst connector = createInMemory()\nconst queue = await Queue.connect(connector).run()\n\n// Send a message\nconst id = await queue\n  .send('notifications', { type: 'welcome', userId: 123 })\n  .run()\n\n// Process messages with error collection\nconst { successes, errors } = await queue\n  .stream('notifications', { concurrency: 5 })\n  .map(async (msg) => await sendNotification(msg.data))\n  .tapErr((err) => logError(err))\n  .collect()\n  .then((results) => {\n    const successes: typeof results = []\n    const errors: typeof results = []\n    for (const r of results) {\n      if (r.type === 'success') successes.push(r)\n      else errors.push(r)\n    }\n    return { successes, errors }\n  })\n```\n\n## API\n\n### Queue.send\n\nSend a message to a queue with optional delay:\n\n```ts\nawait queue.send('my-queue', { key: 'value' }, { delayMs: 30_000 }).run()\n```\n\n### Queue.stream\n\nStream messages with concurrent processing:\n\n```ts\nconst { successes, errors } = await queue\n  .stream('orders', { count: 10, concurrency: 10 })\n  .map(async (msg) => await processOrder(msg.data))\n  .partition()\n```\n\n### Queue.ack / Queue.nack\n\nAcknowledge successful processing or negative acknowledge with requeue:\n\n```ts\nawait queue.nack('orders', msg.id, { requeue: true, delay: 5_000 }).run()\n\n// Or route to dead letter queue\nawait queue.nack('orders', msg.id, { deadLetter: true }).run()\n```\n\n### Queue.sendBatch\n\nSend multiple messages efficiently:\n\n```ts\nconst ids = await queue\n  .sendBatch('notifications', [\n    { to: 'user1@example.com' },\n    { to: 'user2@example.com' },\n  ])\n  .run()\n```\n\n## Configuration\n\n### In-Memory Queue Options\n\n```ts\nconst connector = createInMemory({\n  maxBufferSize: 1000,\n  queues: {\n    orders: {\n      maxAttempts: 3,\n      deadLetterQueue: 'orders-failed',\n    },\n  },\n})\n```\n\n## Error Handling\n\nAll errors are typed for catchable handling:\n\n- `QueueConnectionFailed` - Connection establishment failed\n- `QueueSendFailed` - Send operation failed\n- `QueueReceiveFailed` - Receive operation failed\n- `QueueAckFailed` - Acknowledgment failed\n\n```ts\ntry {\n  await queue.send('my-queue', data).run()\n} catch (error) {\n  if (error instanceof QueueSendFailed) {\n    console.error('Failed to send:', error.message)\n  }\n}\n```\n\n## Related\n\n- [@anabranch/anabranch](https://jsr.io/@anabranch/anabranch) - Core Task/Stream\n  primitives\n- [@anabranch/db](https://jsr.io/@anabranch/db) - Database adapter pattern\n  (inspiration for this package)\n","readmeFilename":"README.md"}