Skip to content
This repository has been archived by the owner on Jun 17, 2024. It is now read-only.

How to send a manual NotAcknowledge to a persistent subscriber #97

Open
zacacj opened this issue Jun 22, 2017 · 7 comments
Open

How to send a manual NotAcknowledge to a persistent subscriber #97

zacacj opened this issue Jun 22, 2017 · 7 comments

Comments

@zacacj
Copy link
Contributor

zacacj commented Jun 22, 2017

I'd like to send a NotAcknoledge message when for some reason I need the message to be reprocessed by a persistent subscriber, instead of only wait for the timeout...is there a way?

@michielboekhoff
Copy link
Contributor

@zacacj

I'm reasonably certain manually sending a Nak will achieve what you want. Take a look at Message.scala:250.

@zacacj
Copy link
Contributor Author

zacacj commented Jun 23, 2017

@michielboekhoff for sure, my point is that since I cannot send this Nak to PersistentSubscriptionActor as I can send a ManualAck, I need to pass the reference of the ConnectionActor to my "client", I just think it would be better archieve similar work same way would be better.

@michielboekhoff
Copy link
Contributor

@zacacj I'll create a PR for this later today.

@michielboekhoff
Copy link
Contributor

@zacacj Just to confirm, a similar interface to ManualAck would fulfil your use-case, right?

@zacacj
Copy link
Contributor Author

zacacj commented Jun 23, 2017

Yes it will!!

@zacacj
Copy link
Contributor Author

zacacj commented Jul 10, 2017

Hi, this is what I did to have this feature for now...

ZupIT@b12d754

And since I'm using the lib on a java project I dont have visibility over sealed classes so I implemented with the default behavior of Retry

@t3hnar
Copy link
Contributor

t3hnar commented Jul 10, 2017

@zacacj looks like a valid code, would be nice to add a test case covering this, so I could merge in.
Thanks.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

3 participants