Skip to content

[Exchange channels] enable consumer filters #152

Open
@GuillaumeDSM

Description

@GuillaumeDSM

For now it's impossible to specify a consumer filter when registering to an exchange channel:

    async def new_consumer(self,
                           callback: object = None,
                           consumer_filters: dict = None,
                           consumer_instance: object = None,
                           size=0,
                           symbol=CHANNEL_WILDCARD,
                           cryptocurrency=CHANNEL_WILDCARD):
        consumer = consumer_instance if consumer_instance else self.CONSUMER_CLASS(callback, size=size)
        await self._add_new_consumer_and_run(consumer,
                                             cryptocurrency=cryptocurrency,
                                             symbol=symbol,
                                             with_time_frame=self.WITH_TIME_FRAME)
        await self._check_producers_state()
        return consumer

consumer_filters is not taken into acount

Metadata

Metadata

Assignees

Labels

No labels
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions