{"_id":"@voltro/plugin-queue","_rev":"75-fa5f8c8e20e76ee09eef27e43eaef0b1","name":"@voltro/plugin-queue","dist-tags":{"latest":"0.83.0","incoming":"0.83.0"},"versions":{"0.53.0":{"name":"@voltro/plugin-queue","version":"0.53.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.53.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"d3a72c10f05057b8270e14b0a9f93d85bb1cbe67","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.53.0.tgz","fileCount":8,"integrity":"sha512-KOflehx70AoKG/fFPYKbctBlOzGLInLAOgBXTY4or4hDoZupaaVht9JZyhWXI68dR52CY3x0yb6lmLp03WtGOg==","signatures":[{"sig":"MEQCIEKe/vLlsmO5m1McHVuA9PGcqALwK68whhWYyvBposYLAiAexLaMjLIRTMqwfJHsAvzuGScmN+7HqjU2BpQyukhsqg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":1882247},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"03bf0e8839a07c8233a5bd24017735a79d7f65ce","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/database":"0.53.0","@voltro/protocol":"0.53.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.53.0_1787786649212_0.7789769424260735","host":"s3://npm-registry-packages-npm-production"}},"0.54.0":{"name":"@voltro/plugin-queue","version":"0.54.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.54.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"7085f9b8a01ddfdceb2aa67240c9d14c4474e186","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.54.0.tgz","fileCount":8,"integrity":"sha512-s9dgcS/PI9lW7u9jaSNBTKqOmZOiL6Kq8Vo08C2gTZ0Kc/RZHSIcAYch6Dca9HD+43pUwAX++S+annDuw8TKPw==","signatures":[{"sig":"MEQCIBXfwD26tSswdzTxs/Ya9dyaVnXUOQorLZHPzYqqrkX8AiBKkT0nQ0A5GKrdJWmLC2id+ybcORFQXBTCCkC0dAW/6Q==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2146407},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"73603bc1854047db6a2d224a3a35646a81e710e2","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.54.0","@voltro/database":"0.54.0","@voltro/protocol":"0.54.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.54.0_1787816916830_0.44676779713436754","host":"s3://npm-registry-packages-npm-production"}},"0.55.0":{"name":"@voltro/plugin-queue","version":"0.55.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.55.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"66dfb5bd2f9c0a14e471ef1e9bf9495a1740188d","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.55.0.tgz","fileCount":8,"integrity":"sha512-cdJUKUpyv3ImvgGwSegojcll194kDSDn/LPRI4P5ZXwLXuTGznMCquZJCEKG/kvHVg14L33owqX1SLl+Op+AQg==","signatures":[{"sig":"MEQCIFVc6sQPBYnTNL9of/4V/8NeGBcWkXzBPjOPHJu352ymAiAeMpd/rD7ScGuFDroJBET3W2Y1UTcKso4DXULwtZ/g0Q==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2172603},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"e2b4fa926667e21442c7e67acc6e261631c4d348","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.55.0","@voltro/database":"0.55.0","@voltro/protocol":"0.55.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.55.0_1787847330610_0.09489497049116569","host":"s3://npm-registry-packages-npm-production"}},"0.56.0":{"name":"@voltro/plugin-queue","version":"0.56.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.56.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"8349817141ea7c06d69089db185a8baa3e719f23","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.56.0.tgz","fileCount":8,"integrity":"sha512-IErEK0vxiH3atFEFm/uYcm//b/uZ5Ikzsfwodw7C5gjP8Bi6KqV9jnbIvmuWwbjKWSF/JabQrgQmdfJ7zhA3Uw==","signatures":[{"sig":"MEUCIQD85oIXX7ZB4qMkX9WWP8rQuWkDGCoaGXcnTfcPdFpWpAIgHzyPNzah5/kEVpSdLFqpspd3vTx/2DsOpIVJaO2Ws10=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2254048},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"91ca4885463de6812c5e9bf05dc4667ae41d0f26","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.56.0","@voltro/database":"0.56.0","@voltro/protocol":"0.56.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.56.0_1788013041605_0.9971060406209091","host":"s3://npm-registry-packages-npm-production"}},"0.57.0":{"name":"@voltro/plugin-queue","version":"0.57.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.57.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"592684309079689316373f13f5134ef59b97db30","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.57.0.tgz","fileCount":8,"integrity":"sha512-l61guH+OoLvp3kxYuelfChk77bY71T8kK7LZsU8q7GSgYUmnW9ytA7q8t2bfwDD8fUp/dzCsKOzB4Cq9FQkfxw==","signatures":[{"sig":"MEUCIBZc8jUy8yBeUf+suvZS7xhJzv+Nsks0GqK6HonsVlAQAiEAgakMdaUo+oNvZwLXcXtVL1kr0setLR61N6PsTF5LkWQ=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2287464},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"82a79a78af1e24398fa862863c774cc862efd19f","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.57.0","@voltro/database":"0.57.0","@voltro/protocol":"0.57.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.57.0_1788055986405_0.981616553754693","host":"s3://npm-registry-packages-npm-production"}},"0.58.0":{"name":"@voltro/plugin-queue","version":"0.58.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.58.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"211c672ebe13f697aba385116223b1e23ef1514c","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.58.0.tgz","fileCount":8,"integrity":"sha512-Bd2KH3YcIldmZrqi0UJ4H7tCM5PQyNbW2sbAHLSAn2MV25gFYejfFKmZapBmPugpllJySk1qyx7iCNh6TFZaMA==","signatures":[{"sig":"MEYCIQCRiUIc7JPbvh3e392mMkegNZARcDSG4cZiWrFpsX4TrAIhANb0An3+vGK4pI/K1Xln2gb6g6GmHXBRadIqp7pyfZFV","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2324664},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"1f3159350f155c2d0bd392f8c26684133c9cc563","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.58.0","@voltro/database":"0.58.0","@voltro/protocol":"0.58.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.58.0_1788093258958_0.4467106875486324","host":"s3://npm-registry-packages-npm-production"}},"0.59.0":{"name":"@voltro/plugin-queue","version":"0.59.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.59.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"21dfb8dc29b4749ab40fd8c83000c8e57e6b2d35","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.59.0.tgz","fileCount":8,"integrity":"sha512-ZRYQrvXdvFEZXg91DuFR9YxS++Cgjl6GNv+UHRipQ1KLkeBt2Queq9Lfr7jX+zYTAqSCjehQJY+lwAWfIzL7Fw==","signatures":[{"sig":"MEUCIQDrP/IgaP91rMZCb9rxbjBkSGqI6CUC6IGXNPcf42gzwAIgBkqHKxveyNG75jPKj7nbZna5BjNGHVoR1b2LlxeEtgI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2332082},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"d149a12f758b3f38879c25daf5ac1747673fc01b","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.59.0","@voltro/database":"0.59.0","@voltro/protocol":"0.59.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.59.0_1788120832362_0.9113828645204332","host":"s3://npm-registry-packages-npm-production"}},"0.60.0":{"name":"@voltro/plugin-queue","version":"0.60.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.60.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"bc77bbc45de15d2f832d486d554741aca5b595ff","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.60.0.tgz","fileCount":8,"integrity":"sha512-XDzSKHn/oFGXtZyzpytH5LnMIiJxfIB6Bbz6LYKlbOaoMdamPpf7aDTuOhLUB4cX911rBTgTY/7SeD94lwhNIw==","signatures":[{"sig":"MEUCIGUG91DsiMRP2vlHWzsMX8wxqWsl2SwZEqbUTzJfB7iDAiEA7fRg/bKOZLkr21YMB9Mrs306n6pNNt1D4pTmjZ4Qku0=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2339653},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"52b50761a6e6a9d14594982aa44558ca1320b8ab","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.60.0","@voltro/database":"0.60.0","@voltro/protocol":"0.60.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.60.0_1788166813331_0.1393827685372293","host":"s3://npm-registry-packages-npm-production"}},"0.61.0":{"name":"@voltro/plugin-queue","version":"0.61.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.61.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"326207ddc827ce8deef8b236f1960d51ea99f797","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.61.0.tgz","fileCount":8,"integrity":"sha512-tEubrRRKj2r8mLBDIQSjU9TaP/xnutJtIjHY6qyYEBCvFU2vF50jNJ/rgYxZTSVtvx6gSlPddxujbsPrOjpdJQ==","signatures":[{"sig":"MEUCIQDHCY6XtElgbZpMKcwxOcVCuclf+auuU0kp7ObrqzK65wIgGTN3SMfVq1fSgkb0wnmCUzE7cziqPHabvxOVj1OFOJM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2342074},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"c1530cfb73190230ccaebc83efe6976b5d73bb71","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.61.0","@voltro/database":"0.61.0","@voltro/protocol":"0.61.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.61.0_1788227603584_0.917858408258484","host":"s3://npm-registry-packages-npm-production"}},"0.62.0":{"name":"@voltro/plugin-queue","version":"0.62.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.62.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"0898b37ea8da2412f11e3f9e503fc1da11c36d75","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.62.0.tgz","fileCount":8,"integrity":"sha512-XmwXbR4Gu2totiCvyb6B6FB9IA825XWMievZRDwUPc8YSTKsSERkypxzKC7Td+pmduf/UGO6JVMy872JV5NHYQ==","signatures":[{"sig":"MEUCIGlIofZZ+v3ma13UK7724mASelrYYkZkFdkSDCyUZxaQAiEAspRRTV7wiNtfE3TqRHVZCnSpF9YZ5EHZQbntniA6PFQ=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2343780},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"dbfefd2f5dcf6c1222826b30e3485bd557bdd8a7","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.62.0","@voltro/database":"0.62.0","@voltro/protocol":"0.62.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.62.0_1788299599779_0.2462611233430747","host":"s3://npm-registry-packages-npm-production"}},"0.62.1":{"name":"@voltro/plugin-queue","version":"0.62.1","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.62.1","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"5d18079276f40998ca18e541742c3b5e38a56efb","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.62.1.tgz","fileCount":8,"integrity":"sha512-y1VFZ6K2JVeYO4fQp02S2+U6+JlxBRzKtP20/vk5fyaAu+JkmS0EWpq30wdUpipvp86mnp2vBMLRUtcjboRGNA==","signatures":[{"sig":"MEQCIHTJpRs3NYf78vr0Sv71dZAKR2cxYZS6HwC76mBaCHzKAiBRSthkI+wziu6KZ2yJV/cO5hWXZx4tRaulFp5OG+7Ykg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2344836},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"13c2f101db4729ce9b1a3bc189bb11340b7cc2a5","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.62.1","@voltro/database":"0.62.1","@voltro/protocol":"0.62.1"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.62.1_1788383872507_0.058249075614164036","host":"s3://npm-registry-packages-npm-production"}},"0.62.2":{"name":"@voltro/plugin-queue","version":"0.62.2","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.62.2","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"b2956f6f1d0a5c1f6953cba5ed9f3fafb8f558a4","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.62.2.tgz","fileCount":8,"integrity":"sha512-WSZpre4W0rDjZipHRJVEZsiiPLgc5PjzC3tz9u8jb23FNoVJqP6rNjvavv7NTXWRS8id1uuRs19quMCik0cPmA==","signatures":[{"sig":"MEQCIA2YAj965M5HNcdXTWXMwDOgu5froGm1+vmvRsEIOgw3AiAxgJKbNuoqX9IGd5FURPK2XZSGCPjCu3hzqQdnGOPfQA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2347305},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"76c126e35e35a3cb75552cdede9c0f9c0c57728e","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.62.2","@voltro/database":"0.62.2","@voltro/protocol":"0.62.2"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.62.2_1788423452477_0.14266109522847392","host":"s3://npm-registry-packages-npm-production"}},"0.62.3":{"name":"@voltro/plugin-queue","version":"0.62.3","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.62.3","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"3a38dfa12d7416bad9cd9de91e6b792b5f16eb76","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.62.3.tgz","fileCount":8,"integrity":"sha512-9b9qe74CKYNsdAp5/28burh4wuVhYjNdTZZoe32mPCgDfMeRDttInx3yR54DJbtYuPvAPX4266XXDInlD/94Aw==","signatures":[{"sig":"MEUCIQDRVVfqIn/B+sHteVJoy10RguLn24kT/CgxxweEgiCRtAIgFX6oT7cAPfCF13AbsMQwdlGb22nHupYcKXozyJ3+QT4=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2348367},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"3e30ebeb70aa0be1fb0311609a44265a231c9975","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.17.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.19.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.62.3","@voltro/database":"0.62.3","@voltro/protocol":"0.62.3"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.62.3_1788458295322_0.08788935226618899","host":"s3://npm-registry-packages-npm-production"}},"0.63.0":{"name":"@voltro/plugin-queue","version":"0.63.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.63.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"a59ddd87f69a84328cf077c295fcbc1cf26fe532","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.63.0.tgz","fileCount":8,"integrity":"sha512-vdacaIdyZ6M/p9GxCD5CXc6oenZmVZef8/EuLXdNVOXGZh2irOYytWrpXibEYF9n/0Sl/OlcrqggCGTlckwdDw==","signatures":[{"sig":"MEYCIQCx+goh1Vmb5scuQYJIL+M5cDsytbxpHwJSVdb4W/2EtwIhAPjdp8m40OHMx2rMQ/fZdvAKHcLudDyXiApFjGGsLBhq","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2350067},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"2f18a271d7375410e01ac2232d5bc4a54cb31940","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.63.0","@voltro/database":"0.63.0","@voltro/protocol":"0.63.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.63.0_1788484446773_0.6453783607341241","host":"s3://npm-registry-packages-npm-production"}},"0.64.0":{"name":"@voltro/plugin-queue","version":"0.64.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.64.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"32e2f43b53072748ee78c0394e93b6c42da0987a","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.64.0.tgz","fileCount":8,"integrity":"sha512-kGxgWvpRlfYFluWwbCcB329fzaG8m65+0o5bux0coNErZIsmbx7opNeqcmkA9gHSWFwb96qbQRXm4aHgekCWGA==","signatures":[{"sig":"MEQCIFcIeeAJuFb/d/9bLRvRmF+E6X0H/1Y/9H9hhEdJ7pdDAiBpHgv93bGFOK0b6S3ttMo5ddLKTSpmYNAbGB/GgMpBPw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2390045},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"ba9a7ddc9715a118514b775b3b8e32ab40423126","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.64.0","@voltro/database":"0.64.0","@voltro/protocol":"0.64.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.64.0_1788529943426_0.9410431907209682","host":"s3://npm-registry-packages-npm-production"}},"0.65.0":{"name":"@voltro/plugin-queue","version":"0.65.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.65.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"aa936361c34e6a62c0cf38bf4e9a63e3b99860bd","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.65.0.tgz","fileCount":8,"integrity":"sha512-+AC8MoUHITUyBqNhggLKBqvs598Eycy7fKGF2Wr2s6iGlrcUzGLDNF+jxXoPL3EjFW1f9iAjVelj8Kl3Xm6yqA==","signatures":[{"sig":"MEQCIDSZpQGaZ8VVaaVIdNXsxFA0vdYDJ2nDALxlyYsp2kvcAiBvjpFkT2h5zH7yNXUFNVKrcEXgcF2GcnWebX7fslNKzw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2401871},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"5bc9ba8630674b3d4ce4b7495ec54d9f49b27d26","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.65.0","@voltro/database":"0.65.0","@voltro/protocol":"0.65.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.65.0_1788557572749_0.24699887297256184","host":"s3://npm-registry-packages-npm-production"}},"0.66.0":{"name":"@voltro/plugin-queue","version":"0.66.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.66.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"c17dacccbd24075ebcced6f118481c04010da7d0","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.66.0.tgz","fileCount":8,"integrity":"sha512-D/7JuL5hrXjx60TW+9eUsKT0Vo45Uj7kqwVnIe33lL7YN8xS+BHJJl8YSWxMbyfARJzH0vvWsTHhwTrJ/ICn9w==","signatures":[{"sig":"MEQCIC1lpAof/po7yLddTeMu2YairwSwM16ao5qLSfrnppe1AiAQpYWlKE2fIW+AKKuQ9j8XK5blO0sEP+moD6ZBBsb/Rg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2426644},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"4c2c7537648a1451c49c7fccc2389becb5b27fdb","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.66.0","@voltro/database":"0.66.0","@voltro/protocol":"0.66.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.66.0_1788696071652_0.7818155892954828","host":"s3://npm-registry-packages-npm-production"}},"0.66.1":{"name":"@voltro/plugin-queue","version":"0.66.1","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.66.1","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"143bff609dbcbbfd9c8e0bf135d92a8455d255a7","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.66.1.tgz","fileCount":8,"integrity":"sha512-qhgJk7goLejmAxc94YDkyCs+iBgEI48ZDvPc+jLHTZjBDjyGB/oR9hwi/oGJ8sE5DKgEkHxU8zMvOYVnfzr5DQ==","signatures":[{"sig":"MEUCIArDJSHFA7vzKSGzlyCUvbu6x+5qJJ/VP/WsO0NnwEWgAiEAzx66z5KnDy9Q+WZWIS0/WxbKrzzdfuXVaqV5xFNMcFQ=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2427403},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"8c2fce7d2284145215ab4990414663d498eb22d9","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.66.1","@voltro/database":"0.66.1","@voltro/protocol":"0.66.1"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.0"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.66.1_1788722153259_0.11048392732195467","host":"s3://npm-registry-packages-npm-production"}},"0.67.0":{"name":"@voltro/plugin-queue","version":"0.67.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.67.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"f34a8c86a043d4b2912152056bbeca362d8711ef","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.67.0.tgz","fileCount":8,"integrity":"sha512-fspq3ATq0rvytD6EbswgEZAWWmeNPuFtAlVQevusXgcB9C/kPjDrzRExUfo1a/pfzJN9d+qrp5al1IkHP/zrKg==","signatures":[{"sig":"MEQCIG6hGD46c2oi7Vb1t80QZqYD6lokxhyvO4yakNGLsP3eAiB3mwms7QzP3/V37Wl/+gn6DOrPjpcL1WckgQZR08cn6g==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2436029},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"e77a85c1f075e2767aba0ce0214e6976ea2bf89d","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.67.0","@voltro/database":"0.67.0","@voltro/protocol":"0.67.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.67.0_1788774788691_0.24091128760567715","host":"s3://npm-registry-packages-npm-production"}},"0.68.0":{"name":"@voltro/plugin-queue","version":"0.68.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.68.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"c5a0d119235e3dc1fffc330a0408c332a8280c04","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.68.0.tgz","fileCount":8,"integrity":"sha512-VllTRgcXn912MlzFFKbajvlSKQT6LIUSlRNVVlEYZ/+XlvMatyzfDCtm21Z7BcblNW/AU8ZpJ3P5NAtm2uAMxA==","signatures":[{"sig":"MEYCIQCKjCexRmFaMNvwoOggJir851n8vrNcWywETdwVfQfrGAIhAKv/X1SlAe9MLH1jqNI0FZ/CPPGa6xxWsS8vi9rThOUu","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2474585},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"1424c773bcd815024459e96b54cb8a28562dc925","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.68.0","@voltro/database":"0.68.0","@voltro/protocol":"0.68.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.68.0_1788997131185_0.0005914135531117637","host":"s3://npm-registry-packages-npm-production"}},"0.69.0":{"name":"@voltro/plugin-queue","version":"0.69.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.69.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"9d4e6fe0b91434eca9d09c96f068e8e76d56864c","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.69.0.tgz","fileCount":8,"integrity":"sha512-g6i9GbDwwqSev3ceB5g2U5awYaRsB+mNoUovaJBaH3UnPNCnLfU6ddBDRmhqeT9RftGweHxCpIQnf7VDCEPLOg==","signatures":[{"sig":"MEQCIHBVEqfjERAj9ax7oiG8xai1fKNEVfXDnO71BIGt/1KLAiAjU/aVL6ihg4Z4IQ/RILNXZm6ZdKJMjgb28fq3QEMPTQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2509324},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"759902527c6e630c6fd5e7d0dfb4e1d72f473f96","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.69.0","@voltro/database":"0.69.0","@voltro/protocol":"0.69.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.69.0_1789063404609_0.214960055332873","host":"s3://npm-registry-packages-npm-production"}},"0.69.1":{"name":"@voltro/plugin-queue","version":"0.69.1","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.69.1","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"54af19421cda801f5cf0ba8c5f481e2d415cab5e","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.69.1.tgz","fileCount":8,"integrity":"sha512-BLE3wn7w0kDYkTAQIuXo9Eq8z0RRJcAUKktUwzXkKBrMHxXkFl6BaLAZ3OfASS+yEotdRBZASHjb7jcBdC1y+g==","signatures":[{"sig":"MEQCIDoUog2lMxWsS/DR+S6Kq61PNZw0jeAVcwVUPP7WRymyAiACgqa8E4cxy4aAGAMEqjoAG3YBL4jJqdG/zCbzSPv/qQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2532919},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"0146bf846c8d7725a229e27d075ae1faed6a39b8","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.69.1","@voltro/database":"0.69.1","@voltro/protocol":"0.69.1"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.69.1_1789135397828_0.09978171981061079","host":"s3://npm-registry-packages-npm-production"}},"0.70.0":{"name":"@voltro/plugin-queue","version":"0.70.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.70.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"0140b9ae0e62ed1a15f353dca9b7dae7e40912ce","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.70.0.tgz","fileCount":8,"integrity":"sha512-NPSv/8ZN8EPnGr9I48zGwsK14q9tqOqCh8jNRN0knFQeGH81s8CWHZ1V9QtxKs6SEyd8erq+oI6n7qmUIFT+nw==","signatures":[{"sig":"MEYCIQCDZcH0Hu2E0F7F8GEpsdYrQO4bhLFqtQ3FB2jkGmLaCQIhAMMj6iYDF3EaS8MjNDpFulNlKsN1vNBsATpU6z6ZmL0K","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2553920},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"7489970500b6c06dccd46cb777a11277c06ea53b","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.70.0","@voltro/database":"0.70.0","@voltro/protocol":"0.70.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.70.0_1789165339685_0.8788849560066925","host":"s3://npm-registry-packages-npm-production"}},"0.71.0":{"name":"@voltro/plugin-queue","version":"0.71.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.71.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"9771c2b8672d69897f9b9620144955759b4fe3e9","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.71.0.tgz","fileCount":8,"integrity":"sha512-aatr1xZaxq1k3SFmujP8cZH8p2K0Wdt7FVSWEtrUMeSyrYhdq4QbHKoPPbsakW3ETobLjWuq/84TgmuHQrh2Rw==","signatures":[{"sig":"MEUCIHYobSuNDNbqV9nx2SOAa6dWNI7nC4QJgzcFOLpHhHqYAiEAmBVNIvVuSKJeTR5kYy3R5zlZ8Q4vyqDXQFOJJedmQN0=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2752250},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"28f5a0f72991a6403342aa0a7d1f54f7038bcf2d","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.71.0","@voltro/database":"0.71.0","@voltro/protocol":"0.71.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.71.0_1789386773226_0.343329725923875","host":"s3://npm-registry-packages-npm-production"}},"0.71.1":{"name":"@voltro/plugin-queue","version":"0.71.1","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.71.1","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"978e460807bbb257784cdfc103bc07130d8917ce","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.71.1.tgz","fileCount":8,"integrity":"sha512-NXzU3n/CCyPy3nPPeLaPM/93Y7jSVJDBbepjGKwv/WvYMB2f6aXGvRMfP4G7PLS5sz9pktpupSTRwMy+D6zuNw==","signatures":[{"sig":"MEQCIC7pybt3C054R7FfmE/v9+Qz/T5y7rl3gOQLky4JYdqNAiBUkpc+1h3nbhuU43/Gfuggm/2FPT4nN2m1zdy771VCsQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2760029},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"3f5e511181306d80ca031926aeafe8c6d3120ead","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.71.1","@voltro/database":"0.71.1","@voltro/protocol":"0.71.1"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.71.1_1789425608110_0.7696095601288793","host":"s3://npm-registry-packages-npm-production"}},"0.72.0":{"name":"@voltro/plugin-queue","version":"0.72.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.72.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"c49a297f92485c4e82e6f829f71ed9890faf06b7","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.72.0.tgz","fileCount":8,"integrity":"sha512-FrS8c2RYeayQoptAO3sr8WnzjNOSXOYVUcirSp69UFQ2P9omAwtfHBtZ6wIK3h6tzZwmD5ALiSlzTJOASGdavg==","signatures":[{"sig":"MEQCICMGtcH36S5kc1u8Fi+yhNR5IlOhQxvWUgPNn8ocLH4oAiB79/tI6tBZWE8BRL/IoBfpNm3ppMK5zQ3SWJ9OAgagtg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2840002},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"ba4a226e081f61873b1014a20fc21cf4a18ff556","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.72.0","@voltro/database":"0.72.0","@voltro/protocol":"0.72.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.72.0_1789614895305_0.47762827398000063","host":"s3://npm-registry-packages-npm-production"}},"0.73.0":{"name":"@voltro/plugin-queue","version":"0.73.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.73.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"4ddffc1287c5a120dfbc0412c5962db5bfae2c58","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.73.0.tgz","fileCount":8,"integrity":"sha512-OXUc3IG9d/vVvs6/mU9Z5x4y6AsmnMWM1y07pYyCrAqwPWHe1Iph5n9f/72P8wDl6UBs6EG+JhCGltmrAKM+ww==","signatures":[{"sig":"MEQCIEh67V5bGlxvFC3Y+qg3ctJW4dJr5lmTsLXtnioLjVIfAiA/tUrXng73lsryCS3zTrn/q2N1IpO1hq+HGtIkdSrksA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEUCIHz+iM0PUfmd/ODpGVPLC94dFD7EU/mKlY05mY1m/w91AiEAyi7tx6GRbHA/fl2h3+ASgb+v4LXCh4uFBrEArc7QegQ=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2847213},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"a8b471cc7d96dacfdc99eb3a39efdc196e397864","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.73.0","@voltro/database":"0.73.0","@voltro/protocol":"0.73.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.73.0_1789680970769_0.5671783928064529","host":"s3://npm-registry-packages-npm-production"}},"0.74.0":{"name":"@voltro/plugin-queue","version":"0.74.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.74.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"40865a603ad3dc11fb693d1bad3bdc57749724ab","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.74.0.tgz","fileCount":8,"integrity":"sha512-VP0p27n/9R/YC7CAFcPdV6J+WH2s3hufhtHc8YPEHRj3Un7pfSZ/z91cBSeFIESi2fq4TMbE/t5DUepIaYTKCA==","signatures":[{"sig":"MEUCIDmaIXyepP1tvDSnpBz1qLTLeUkq0SaokXxRyal2026VAiEA7TPd9Ow+q4dh2VHyAdhymtwi2A3HYeReRYBGjhgcf18=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEUCIQCFUxRCG1t4orBeNDDu+xwqjaw6b1yknTwie59YPz/s6gIgGwWlLJBEGneFqRhdiLefIJrt/ikHCi1KfunfomPhQMs=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2859594},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"367c5f25e3514f82d35eea0c3b01e5d6b32bf29e","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.74.0","@voltro/database":"0.74.0","@voltro/protocol":"0.74.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.74.0_1789788375108_0.9257890570942229","host":"s3://npm-registry-packages-npm-production"}},"0.75.0":{"name":"@voltro/plugin-queue","version":"0.75.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.75.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"ee7005b64a3eaf70f3c1223b898b33bb6054ac04","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.75.0.tgz","fileCount":8,"integrity":"sha512-cyvw9cB3JYtvELLQeb2L6BaOO6U8EP1gb7A1OnkyJqsSP3Mwnm2f0qAmv4WJz5Aa4OHA5XfvfHYbh5hPLyKh+g==","signatures":[{"sig":"MEQCIHErfh15VpLZ1yY5V9JMmfVuyzne0BR9ERGTa6tKu8udAiAejugcN0t3mOvg77KJ3uiBryROAOHNMnqKR00DA7/uxA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEUCIGnPM7PsGf7nOAzl7dmwc494lv5mGZZURnxso4XNIAyLAiEAiJ646s9sqfUK2TOCjuiyp7dFnaxpG4fCi7r17tG5uI0=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2899062},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"6042badbdbf164167c525bbc2f90043a56b74321","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.75.0","@voltro/database":"0.75.0","@voltro/protocol":"0.75.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.1"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.75.0_1789850525485_0.90696551015563","host":"s3://npm-registry-packages-npm-production"}},"0.76.0":{"name":"@voltro/plugin-queue","version":"0.76.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.76.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"9b2a355f215f64f7fc14a9b9fb797631146e481a","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.76.0.tgz","fileCount":8,"integrity":"sha512-0EfoPlSAr9KKuREExNJlFf3wn79+LtDIjCHihJW2DmkFIqIFPnpnwkdrhBhVv29KSZxrMWsI2tPMqNN3PhKdzA==","signatures":[{"sig":"MEYCIQDpS7BXbEkAuU0uaCYI8Lnj44gtzz6MiMi/nz+tdZMqcAIhAN3Eg9BuC4xWKzodl/W+UaNtEJbC0Ef9d1tUHw1sDWSq","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEQCIDBz7hp7RfWPGgF1FVG86OeYKvyFp1M5fXjL5RfgQnz7AiBvYfRdVQQG5lltpZEFtw/xKyWmn9EDw5+FXqMU/SJMpQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2951139},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"383197b8e70b788d7471a9c8b786cb52958239a1","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.76.0","@voltro/database":"0.76.0","@voltro/protocol":"0.76.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.76.0_1789977910213_0.9566896984605884","host":"s3://npm-registry-packages-npm-production"}},"0.77.0":{"name":"@voltro/plugin-queue","version":"0.77.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.77.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"1e4e290b94556e7787af1c0f419fc3674c6ea2d0","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.77.0.tgz","fileCount":8,"integrity":"sha512-+0vZs+L5e6hMobvc6yiamsr/cJGAgXBgpgbFN3JXkQqPFq8dd9dRhpArJxc7tXPqt6UQGTbe5mLemHdqzPSMpw==","signatures":[{"sig":"MEUCIE3iwZYv+8dT3fwkOpqhySDkIoPH4hLoq+YIODokNQYWAiEAlShzr1sBw6VE0vzhNdi6upK7B7D0bmYqjC7TRkslXeE=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEQCIFK1WhjNtkJNk3ub9bldcJzA0mbIwduDoCJ8LZWVFFTvAiAB2iqJL8Jb6AXdLXAcqaUFmmYFQTDyrx7KouptBx4Dpw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2964950},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"a121036fb2e7a0f83d436e03f6dbf81d1eccadb9","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.77.0","@voltro/database":"0.77.0","@voltro/protocol":"0.77.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.77.0_1790049334867_0.0331398592900225","host":"s3://npm-registry-packages-npm-production"}},"0.77.1":{"name":"@voltro/plugin-queue","version":"0.77.1","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.77.1","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"d809be5606f2b0c025fd0f47839dba30323f6912","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.77.1.tgz","fileCount":8,"integrity":"sha512-9zUPe2DLL5z/+5hrkAK5RLdJK2kOXzpFEexciy7ZwALKlsB6aWOmjked7YzzLcXCZOrszCDMcKGR71CcOgOrkg==","signatures":[{"sig":"MEUCIQDBGr5R4YrGMMTre7rEiFNvsEQ3yEHHGaErc/R3oEKNpgIgORAD1IpyvcUYcYNIbbIL01kuVKb47ikBx84wR4C4rhs=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEYCIQCQFj7/92oTsI8QeN5I3yspvzgeNXUN8hX+GbTnMkErHgIhAIPT2Onc0NDAMKz5G4zFz5f1ovGVz5sLyXb5Ezg/0UI+","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2965827},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"5906837eda2dae522829a02ccae313bb49f5fedf","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.77.1","@voltro/database":"0.77.1","@voltro/protocol":"0.77.1"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.77.1_1790060865051_0.4209787556479885","host":"s3://npm-registry-packages-npm-production"}},"0.78.0":{"name":"@voltro/plugin-queue","version":"0.78.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.78.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"2df462396610b1cdea1617e7158f5ae9f81c8de4","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.78.0.tgz","fileCount":8,"integrity":"sha512-bwHU1DCxTzvrWUeovDL8jJOBtv7DAqVQpgNqKmmaSVyRD8I3tODYCav3s+pwLV1NY/9jTbIgDmlq1bIYxJqxYQ==","signatures":[{"sig":"MEUCIQDUhTa23uuMMC0s+/vTFtQTki3BYeHHFjSgD/RQ5BPdmgIgBaHM1xF3366smtkf7xMxEFwTpNvFk75sMacCm6WI2rs=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEYCIQCMf+wgyqnSpQZCmZvwt8EMiWrH+4nuYFggDw7ipUrv+gIhAJ/iM2xAZWVXVvzoEs5zjj4Kq2wADiQ40kzrzI9Mq8b/","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2974779},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"eea3c6f1fcef03b7239ae7e133c246cea4f17f74","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.78.0","@voltro/database":"0.78.0","@voltro/protocol":"0.78.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.78.0_1790092073834_0.6348483238506399","host":"s3://npm-registry-packages-npm-production"}},"0.79.0":{"name":"@voltro/plugin-queue","version":"0.79.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.79.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"b6ffdc9e5eeba8f45fa90af3dae09482210ffd7e","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.79.0.tgz","fileCount":8,"integrity":"sha512-T287JVDgyqrj8qZL2DncifeVy//FrD3jhj1HMcG+WF+kEAGftBHodpeiMEctMe5PnP/Z2nPOmQenQLvKGwEWjw==","signatures":[{"sig":"MEQCICaHZtbDbtKyZIekLPmwLZe3FYb1Z3wIpjN6GI7sNpoRAiAoNF9BuTlrDQ+ZFqkrAfPLOfIMK6+8BX8XyZ7UCaGg0w==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEQCICC044Doddc8xxGuaOEq54tAxKcSpi0KugYd8BzC6FKUAiArzfOcz3XbNuCUHrE6BgGSBg1eBhrLK8YRSkwPECHTRQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2987646},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"72134ee7c16cc20aface9e1246d787ecb3cfef21","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.20.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.79.0","@voltro/database":"0.79.0","@voltro/protocol":"0.79.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.79.0_1790168505636_0.8374270920010685","host":"s3://npm-registry-packages-npm-production"}},"0.79.1":{"name":"@voltro/plugin-queue","version":"0.79.1","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.79.1","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"eb97c7b970515f0c55335a112e6dfacaa57d2de9","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.79.1.tgz","fileCount":8,"integrity":"sha512-RiyBw5NfcKs5wB1nm+Rpch0Esz9YbdLIB9smg3c3SjL53ompq9AGjVWDWrdf+zAE0E0ROaFxOhp/5FpE/MBrCw==","signatures":[{"sig":"MEUCIDwk8o8J04PYZHECZB20kBPLOrdmxjzr0P2c5SOCe0VbAiEA95J4UVpe9fjxMlfiniOkzSyrNJcJ6yDqHO/8iivh61A=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEYCIQC4alUHVT0HmskCTeshlaGnf37SwCMdf4EB+EHDwDCaCgIhAOLVSi8ZQlVNpqijyd1yp6XAp0Jgg26op0xowD+ujwas","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":2998330},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"1e68bd1e02947739638d7e96dbbc75bc91bd0759","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.21.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.79.1","@voltro/database":"0.79.1","@voltro/protocol":"0.79.1"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.79.1_1790233455742_0.022981040690491117","host":"s3://npm-registry-packages-npm-production"}},"0.80.0":{"name":"@voltro/plugin-queue","version":"0.80.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.80.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"53a8024f658053ac00c0ce58dbc1acaa993646d9","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.80.0.tgz","fileCount":8,"integrity":"sha512-jio7dJFSMWyb9Zpgqum3gHK26ghuW94AdlWqvoUkYJgc/1VfMLJbjPAssmRgWCsiwfpAGXcUiV6xT4wQR+hepA==","signatures":[{"sig":"MEUCIAppTDtQZFdtOO2O0DNZxQ83qHW1G1YOtp5577vCNldbAiEAvJWID3yaHNAoWMcA2cqGc96C+fJHWZ5TPAjeBzeh20c=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEQCIFS0BoSEA5pxvyFgx/sV6yDkJ67/6Qp1TmqbUTrOMuBqAiBPpEQ9d+uVdEQTsqVoMlApvmZdrMtVmQqOU9qHgSzHGA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":3012422},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"7a1c8d4209e7113e47e8670d00d6f3e5f81ed43e","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.21.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.80.0","@voltro/database":"0.80.0","@voltro/protocol":"0.80.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.80.0_1790262835526_0.2951423850713839","host":"s3://npm-registry-packages-npm-production"}},"0.81.0":{"name":"@voltro/plugin-queue","version":"0.81.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.81.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"61327e05d900f129b869baec75f16b545b267213","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.81.0.tgz","fileCount":8,"integrity":"sha512-OA41TEngN5/h3q1FArHLDbbgLD2Sg4t6MlL6o6FO//3pUatBW6icWQNe1bRQsfPqLzFJhvv0zEIeMyfALJ3y/Q==","signatures":[{"sig":"MEQCIHTVmoAN1FbrWIufWxAfUaUeCm16GTx6hPtgO5faQaDXAiAaGaUTEANCYk4oUmaBEGzTTwvXYrCaFg140D5RPEGYEw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEYCIQC6lUIqm1ffz3YZjYZSygKdPa17bHbc5r5IP01wdouVwQIhALR02gp5g2b3/XQwd/WgZgNcKs5OGsh6l+q2TLRB484W","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":3032474},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"7962df65adc3beadaa9290086b09a40ca6496348","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.21.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.81.0","@voltro/database":"0.81.0","@voltro/protocol":"0.81.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.81.0_1790392301919_0.4148504206838002","host":"s3://npm-registry-packages-npm-production"}},"0.82.0":{"name":"@voltro/plugin-queue","version":"0.82.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.82.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"03dc2c1d540e49bc37e3a09c8adfd0396f551ee2","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.82.0.tgz","fileCount":8,"integrity":"sha512-NWXtONa4M/AB7BAoWMYbT6fg+ZM6D93c2A18xGbTWxGlSs5jB+ZLB9ZvYnn3UMnrT/qobe3eYcwo/UPg0bCQ4Q==","signatures":[{"sig":"MEUCIQCfXlyxXS1DiPOCf5udnS7IcxLllg5N7Z0f97a3zrFgqQIgKvyWiyfl61dWj+tUD8JduDFAyDpmQy0+HQ37L+1m2z4=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEYCIQDnRMivf4aj332zKNkhDYTNLs84aHm3azHL9KIIjO48xwIhAOKokNuPjCnIan6Y3xHVyKujPMqZ9SoPU1LzynEyYRj4","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":3292103},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"6c752e58261688d1a08b95f5aaadb5146f372084","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.21.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.82.0","@voltro/database":"0.82.0","@voltro/protocol":"0.82.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.82.0_1790867142533_0.6603986730149285","host":"s3://npm-registry-packages-npm-production"}},"0.83.0":{"name":"@voltro/plugin-queue","version":"0.83.0","keywords":["voltro","typescript","framework"],"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","_id":"@voltro/plugin-queue@0.83.0","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"homepage":"https://voltro.dev","bugs":{"email":"support@voltro.dev"},"dist":{"shasum":"33ee97d375445ade497c978e351a7c541659cf66","tarball":"https://registry.npmjs.org/@voltro/plugin-queue/-/plugin-queue-0.83.0.tgz","fileCount":8,"integrity":"sha512-AGzqSueAsrrYwq7Lmc22F6vDALfZPjuI+lHOSapQRq/L4Nbc9bughLRofgdjWgz2ZgxMP9RHjdCikYNbDC4X1Q==","signatures":[{"sig":"MEQCIGn7v550IL5RpoX8oUio131l/TWrbN+Vih5DIRFp/+c4AiACXzUgqiX5SG2X2DDxad7oYQyPzurocNfgPCY0RdTQkg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"},{"sig":"MEUCIQDvYCrJYU6G/G6IDpR0AjY94LtlVb07c8pYmlXItJOZUgIgBB9dEEUDOMVmS3fMJX8YUSeZpapbLtlPLFLr3ZF2iHg=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":3337910},"main":"./dist/index.js","type":"module","types":"./dist/index.d.ts","module":"./dist/index.js","engines":{"node":">=24.0.0"},"exports":{".":{"types":"./dist/index.d.ts","import":"./dist/index.js","default":"./dist/index.js"},"./package.json":"./package.json"},"gitHead":"51d1cdd3159ac3cf07bcf43f96e61cf45c3c8c31","_npmUser":{"name":"voltro.dev","email":"dev@voltro.dev"},"_npmVersion":"11.19.0","description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","directories":{},"sideEffects":false,"_nodeVersion":"24.21.0","dependencies":{"kafkajs":"^2.2.4","@voltro/runtime":"0.83.0","@voltro/database":"0.83.0","@voltro/protocol":"0.83.0"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"readmeFilename":"README.md","peerDependencies":{"effect":"^3.22.2"},"_npmOperationalInternal":{"tmp":"tmp/plugin-queue_0.83.0_1791010112774_0.3456652905874973","host":"s3://npm-registry-packages-npm-production"}}},"time":{"created":"2026-08-26T23:24:08.986Z","modified":"2026-10-03T06:56:13.072Z","0.53.0":"2026-08-26T23:24:09.386Z","0.54.0":"2026-08-27T07:48:37.027Z","0.55.0":"2026-08-27T16:15:30.759Z","0.56.0":"2026-08-29T14:17:21.803Z","0.57.0":"2026-08-30T02:13:06.625Z","0.58.0":"2026-08-30T12:34:19.196Z","0.59.0":"2026-08-30T20:13:52.563Z","0.60.0":"2026-08-31T09:00:13.488Z","0.61.0":"2026-09-01T01:53:23.777Z","0.62.0":"2026-09-01T21:53:19.984Z","0.62.1":"2026-09-02T21:17:52.681Z","0.62.2":"2026-09-03T08:17:32.646Z","0.62.3":"2026-09-03T17:58:15.557Z","0.63.0":"2026-09-04T01:14:07.015Z","0.64.0":"2026-09-04T13:52:23.595Z","0.65.0":"2026-09-04T21:32:53.000Z","0.66.0":"2026-09-06T12:01:11.812Z","0.66.1":"2026-09-06T19:15:53.465Z","0.67.0":"2026-09-07T09:53:08.855Z","0.68.0":"2026-09-09T23:38:51.370Z","0.69.0":"2026-09-10T18:03:24.829Z","0.69.1":"2026-09-11T14:03:17.977Z","0.70.0":"2026-09-11T22:22:19.904Z","0.71.0":"2026-09-14T11:52:53.373Z","0.71.1":"2026-09-14T22:40:08.266Z","0.72.0":"2026-09-17T03:14:55.460Z","0.73.0":"2026-09-17T21:36:10.936Z","0.74.0":"2026-09-19T03:26:15.265Z","0.75.0":"2026-09-19T20:42:05.594Z","0.76.0":"2026-09-21T08:05:10.380Z","0.77.0":"2026-09-22T03:55:34.978Z","0.77.1":"2026-09-22T07:07:45.163Z","0.78.0":"2026-09-22T15:47:53.953Z","0.79.0":"2026-09-23T13:01:45.749Z","0.79.1":"2026-09-24T07:04:15.835Z","0.80.0":"2026-09-24T15:13:55.700Z","0.81.0":"2026-09-26T03:11:42.037Z","0.82.0":"2026-10-01T15:05:42.662Z","0.83.0":"2026-10-03T06:48:32.934Z"},"bugs":{"email":"support@voltro.dev"},"author":{"url":"https://voltro.dev","name":"Voltro UG"},"license":"SEE LICENSE IN LICENSE","homepage":"https://voltro.dev","keywords":["voltro","typescript","framework"],"description":"Queue interop — consume and produce against an existing Kafka: Schema-decoded consumers via defineQueueConsumer (*.consumer.ts; at-least-once, serial per partition, retry + dead-letter), batched producing via QueueService or transactionally through the ou","maintainers":[{"name":"voltro.dev","email":"dev@voltro.dev"}],"readme":"","readmeFilename":"README.md"}