Changelog

Changelog#

2.1.1

  • Added InvalidConnectionException and ItemNotFound to exceptions module

  • Now InMemoryRepository raises an ItemNotFound on nonexistent key

2.1.0

  • General rework of persistence layer. Removed some modules and introduced repository one.

1.5.5

Added get_channel method to ChannelRepositoryInterface

1.5.4

Removed eric-redis-queues as optional dependency

1.5.3

  • Added kv_constructor_params_as_dict and kv_class_absolute_path to ObjectAsKeyValuePersistenceMixin

  • FIX: SimpleDistributedApplicationListener now extends MessageQueueListener

1.5.2

  • BREAKING: removed SSEChannel.payload_adapter

  • Added connection repository class name to SSEChannel set of values in persistence.

  • Minor: removed SSEChannel.create_from_dict

1.4.1

  • Minor: updated AbstractChannel and SSEChannel constructor params order

1.3.0.1

  • Fixed SimpleDistributedApplicationListener.register_listener signature

1.3.0

  • BREAKING AbstractChannel.open renamed to load_persisted_data

  • Fixed examples

1.2.0

  • BREAKING register_listener now accepts a PersistableListener

1.1.0

Full persistence support

  • added PersistableListener

  • added PersistableConnection

BREAKING

  • updated ConnectionRepositoryInterface’s persistence methods, now they accept and return ConnectionRepositoryInterface instances

  • AbstractChannel’s add_listener and register listener now accept PersistableListener instances

1.0.0

  • Rework of persistence layer support. Factories of queues have been replaced with connections repositories

  • Moved MessageQueueListener to a separate module

  • Removed _sync methods form MessageQueueListener

  • Moved RepositoryError to exception module

  • Prefabs dependencies were updated accordingly

  • Benchmark module renamed to profile

0.7.9

  • Channel and listener id generation now relies on uuid4

0.7.7

  • Now SocketServer starts correspondant listener on ‘l’ command

  • BREAKING DataProcessingChannel.process_queue and AbstractChannel.message_stream now cannot be awaited

  • BREAKING Changed DataProcessingChannel.process_queue ‘l’ parameter changed to ‘listener’

0.7.6

Added a get all channels’ ids to sse container

0.7.5

  • Removed eric redis queues references

0.7.4

  • Added AbstractQueuesFactory injection support to SSEChannelContainer.add

0.7.3

  • Fixed SSEChannelContainer.add and rm wrong exception thrown on no existent channel

0.7.2

  • Invalid Channel or Listener Exception now yields an error message to client (no logs anymore)

0.7.0

  • BREAKING: now Message’s subclasses payload properties contains original payload

0.6.5

  • Fixed UniqueMessage payload property, now behaviour is similar to SignedMessage

0.6.4.1

  • Changed method’s signature from Message to MessageContract

0.6.4

Breaking:

  • Updated Message constructor signature

0.6.3

Breaking:

  • General rework of model, if you are migrating to this version just update your namespaces accordingly

  • Redis support added as extra

0.6.2

Breaking:

  • Fixed property typo payload_adapter of SSEChannel

  • Changed MESSAGE_TYPE_END_OF_STREAM value

  • SimpleDistributedApplicationListener.on_message now requires a SignedMessage

0.6.1

  • Added watch support to SocketClient

  • Added payload_adapter to SSEChannel

  • Added dispatch_to to SimpleDistributedApplicationListener

0.6.0.4

  • Added more functionalities to SocketServer and SocketClient

0.6.0.2

  • Improved logging format

  • HTML documentation workflow

0.6.0

  • Added SimpleDistributedApplicationListener

  • ChannelContainerChannelContainer renamed to SSEChannelContainer

  • Added SignedMessage entity

0.5.4.1

  • Added SocketClient

0.5.3

  • Restored behaviour of AbstractChannel.message_stream. Multiple streaming calls with same listener are allowed

  • Added locking to queue pop

0.5.2

Fixed close stream too early in AbstractChannel.message_stream

0.5.1

AbstractChannel.message_stream raises and InvalidListenerException if invoked more than one time with same listener

0.5.0.2

Fix: SSEChannel must accept stream_delay_seconds as constructor parameter

0.5.0

  • Removed Threaded listener class

  • Added DataProcessingChannel.process_queue

0.4.1.0

  • Breaking: Changed DataProcessingChannel adapter to suit with SSE

0.4.0

Breaking changes:

  • Rework of DataProcessingChannel, now extends AbstractChannel and its methods’ signatures have been updated

  • AbstractChannel.retry_timeout_milliseconds have been moved to SSEChannel

0.3.2

  • Breaking change: now ThreadPoolListener callback only accepts Message as parameter

  • Fixed a concurrency bug in ThreadPoolListener