roblperry

Looking at the integration tests, I see what my / the problem is. The resource works fine if the private key is set with `OpenSSL::PKey::RSA.new(File.read(private_key_text), secret).to_pem`, but not if it...

I wonder if this relates to an issue I am having. I was trying to offload the processing of deliveries to other tasks and then accept the messages after processing...

Removing the need for a mutable reference for the accept sounds like a win. I could use a RwLock instead of a Mutex and have less contention between tasks wanting...

Awesome!!! The new cancel_safety example looks like a good test. I look forward to seeing what I can learn by reviewing the rest of the changes and retesting my code...

Seems rock solid to me. My code that was previously dropping between 4-20 deliveries in 100,000 has not processed 500,000 without a single drop.

PG gets into a state where I get the error described above for the query: ``` INSERT INTO "identity" ("signature_id", "environment_id", "organization_uuid", "is_active") VALUES ($1, $2, $3, $4) ON CONFLICT...

@Thesohan , thank you for reminding me to add a comment. Leaving out a lot of superfluous details about my adventures, the problem is the `"identity"."is_active" = $5`. It's fine...