- An example of a PersistentStreamProvider with a custom adapter.
- Uses Redis lists as queues.
- A way to implement replayable streams using a custom IQueueCache i.e. the client can ask to replay past events.
- A token has a timestamp. A client can request to replay since time X by passing a token with a timestamp in the past.
Currently, the main physical queue implmentation is using Redis and is used by default. You can also use an in-memory queue, but that's a bad idea. The in-memory queue will only work when writing from within the server (i.e. from a grain).
TimeLimit
how long to cache messages (in seconds) (default: 30)UseRedisForQueue="true"
to use Redis for the physical queue (default: "true")- Redis connection:
Server
=> Redis server (default: "localhost:6379")RedisDb
=> database number (default: -1)
Starts two clients, one writes to a stream and the other subscribes to it. You need to run Redis first.
- Make the physical queues pluggable as external libraries.