-
Notifications
You must be signed in to change notification settings - Fork 38
WIP #87
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: master
Are you sure you want to change the base?
WIP #87
Conversation
@@ -364,7 +365,9 @@ Subscription will be done only once within first request to backend server. | |||
|
|||
sub wait_for_messages { | |||
my ($self) = @_; | |||
$self->{already_waiting} //= $self->redis->subscribe([$self->whoami], $self->redis->curry::weak::on(message => $self->curry::weak::_on_message)); | |||
$self->{already_waiting} //= | |||
$self->redis->subscribe(['myriad.' . $self->whoami, $self->whoami], |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is it possible to only add the prefix based on msg_group
so we can subscribe to a single channel?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yes, we can also pass the prefix from our API and prepend it to $self->whoami
.
@@ -364,7 +365,9 @@ Subscription will be done only once within first request to backend server. | |||
|
|||
sub wait_for_messages { | |||
my ($self) = @_; | |||
$self->{already_waiting} //= $self->redis->subscribe([$self->whoami], $self->redis->curry::weak::on(message => $self->curry::weak::_on_message)); | |||
$self->{already_waiting} //= | |||
$self->redis->subscribe(['myriad.' . $self->whoami, $self->whoami], |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Let's not add myriad
hardcoded in proxy, it's an open source module. Pass it as a config or as a parameter
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We can pass it from websocket.conf.
No description provided.