Comments (2)
Encountered same issue with putting jobs from PHP. It turned out, that fivebeans uses it's format of payload.
To make it work, i actually had to format it on PHP side:
$beanstalk->putInTube('testtube', [
'testtube', // Tube name has to be in the payload as well
[
'type' => 'handler-type', // Handler key defined in JS's options object
'payload' => $payload // Here goes actual data that worker will receive
]
], $priority, $delay);
And my JS code is
var Beanworker = require('fivebeans').worker;
var options =
{
id: 'my_worker',
host: '127.0.0.1',
port: 11300,
handlers:
{
'handler-type': notifier // 'type' in PHP code
},
ignoreDefault: true
}
var worker = new Beanworker(options);
worker.start(['testtube']);
I know this issue is old, but hope that helps anyone.
Maybe we really should cover it in Docs though? @ceejbot
from fivebeans.
@mdjaman You didn't really explain what your problem is.
Would you not use something like the following?
client.watch('testtube', watchErr => {
if (watchErr) console.log(watchErr)
client.reserve((err, jobId, rawPayload) => {
var payload = JSON.parse(rawPayload.toString())
// Process `payload` here
})
})
from fivebeans.
Related Issues (20)
- bug: if .connect() called more than once, incorrect callbacks are used HOT 1
- Obsolete documentation for yaml configuration HOT 3
- Release/Destroy fails to fire when using multiple Reserve in parallel HOT 4
- Is there a way to clear / destroy a queue?
- Connections left open
- Limit number of worker nodes.
- Security vulnerability
- Race condition
- Confused: Is Watch not allowed while in Reserve? HOT 1
- Havent check if callback is avilable
- Delayed job executes now
- Possible to support multiple beanstalkd servers? HOT 3
- Reserve doesn't respond after use tube HOT 3
- Multiple worker HOT 3
- Handlers issues HOT 2
- runner, why class?
- is connected method?
- eslint should only be in devDependencies HOT 2
- SyntaxError: Unexpected token HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from fivebeans.