Comments (5)
Hey @bokmann. So we're close to publishing v2 (see the branch) which dispenses with Fog for the AWS gem. I'll look at the option of FIFO as part of that. Thanks! :)
from propono.
Had a thought about this while looking into other queue attributes (issue for that to follow later). The SQS API enforces that all FIFO queues must end in .fifo
. Perhaps then, if the name of the queue when publishing ends in .fifo
, and the queue does not exist, then a FIFO queue is created.
Regular queues:
Propono::Client.new.listen('some-topic') { |message| puts "I just received: #{message}" }
Propono::Client.new.publish('some-topic', "The Best Message Ever")
FIFO queues:
Propono::Client.new.listen('some-topic.fifo') { |message| puts "I just received: #{message}" }
Propono::Client.new.publish('some-topic.fifo', "The Best Message Ever")
Assumes that the corrupt
, slow
, and failed
queues are also created as FIFO queues, with appropriate names.
from propono.
That's a nice idea. I'd be up for that as an implementation.
from propono.
So does this work yet? It looks like just giving the queue the right name or putting .fifo in the config’s queue_suffix might do this.
from propono.
It would be nice to have FIFO support
from propono.
Related Issues (20)
- Travis CI Build Failures Due to Bundler Version HOT 1
- wrong number of arguments (given 5, expected 4) HOT 3
- Asynchronous listen_to_queue HOT 2
- License info on gh-pages branch inconsistent with LICENSE.md HOT 1
- Use IAM role instead of access & secret keys HOT 3
- Need a way to pass Subject for the SNS payload HOT 9
- Should we merge iterum into Propono HOT 2
- Message Visibility Timeout is too short for some classes of tasks HOT 3
- Docs - Note about needing a subscriber before you publish
- Docs - Flowchart of corrupted/failed/etc queue logic
- Docs - Description/diagram of single-queue-multiple-listener vs fanout
- How do I use GoAWS? HOT 3
- Update repository HOT 1
- Javascript subscriber HOT 7
- ArgumentError: invalid configuration option `:use_iam_profile' HOT 2
- Queue size and oldest message? HOT 1
- Multiple listen blocks on the same file HOT 7
- Slow queue wait implementation causes delay in processing of new main queue messages HOT 2
- messages being processed multiple times by same worker name HOT 4
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 propono.