pass whether it is retained to the subscribe handler
This commit is contained in:
parent
98483b4892
commit
388328391e
@ -587,7 +587,7 @@ class ApplicationSession(BaseSession):
|
||||
invoke_kwargs = msg.kwargs if msg.kwargs else dict()
|
||||
|
||||
if handler.details_arg:
|
||||
invoke_kwargs[handler.details_arg] = types.EventDetails(publication=msg.publication, publisher=msg.publisher, publisher_authid=msg.publisher_authid, publisher_authrole=msg.publisher_authrole, topic=topic, enc_algo=msg.enc_algo)
|
||||
invoke_kwargs[handler.details_arg] = types.EventDetails(publication=msg.publication, publisher=msg.publisher, publisher_authid=msg.publisher_authid, publisher_authrole=msg.publisher_authrole, topic=topic, retained=msg.retained, enc_algo=msg.enc_algo)
|
||||
|
||||
def _error(e):
|
||||
errmsg = 'While firing {0} subscribed under {1}.'.format(
|
||||
|
Loading…
Reference in New Issue
Block a user