Skip to content

Reliable Producer and Reliable Consumer #92

@Gsantomaggio

Description

@Gsantomaggio

Proposal: Introduce two new classes:

  • Reliable Producer
  • Reliable Consumer

We'd like to keep the current StreamSystem implementation as simple as possible.
Up the current Producer and Consumer classes create two new classes with a few responsibilities like:

  • Auto-reconnect
  • handle metadata
  • message sent/received (producer)

That's would be the schema:

Reliable

atm we have layer1/3 Reliable* will be layer4

The user will be free to choose the basic implementation of the "smart" implementation.
( per conversation with @kjnilsson )

Responsibilities:

  • Reconnect the client when the connection is dropped
  • Handle the meta-data
  • Handle the messages confirmed and unconfirmed
  • In case of metadata update try to reconnect if the stream exists else close the connection

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions