Only require &self for Connection::close about amqprs HOT 7 CLOSED

Hi, manually set is_open will alllow user to mutate the internal state of connection which break the the contract of open and close, I would perfer not to go this way.

I am not familar with deadpool, can you elaborate further why &self is necessary? current API will avoid user to use the connection unexpectedly after close the connection.
Can the new type pattern works for you? Usually we can implement new type in order to suite the contract required by other libraries

from amqprs.

Hi, manually set is_open will alllow user to mutate the internal state of connection which break the the contract of open and close, I would perfer not to go this way.

I am not familar with deadpool, can you elaborate further why &self is necessary? current API will avoid user to use the connection unexpectedly after close the connection. Can the new type pattern works for you? Usually we can implement new type in order to suite the contract required by other libraries

So deadpool is a connection pool, it allows user to implement their own pool with whatever library if they implement the Manager trait for their own Manager, the trait signature is as below:

#[async_trait]
impl managed::Manager for Manager {
    type Type = Connection;
    type Error = amqprs::error::Error;

    async fn create(&self) -> Result<Self::Type, Self::Error> {
        Ok(Connection::open(&self.con_args).await?)
    }

    async fn recycle(&self, conn: &mut Self::Type) -> RecycleResult<Self::Error> {
        todo!()
    }

Now the only method we are concerned here is recycle, which only provides a &mut Self::Type, while I am not entirely sure why, but is likely due to how deadpool holds each objects.

Can the new type pattern works for you? Usually we can implement new type in order to suite the contract required by other libraries

I am not entirely sure about what that means, can you please further elaborate?

from amqprs.

As I understand, you should not call close in recycle because it must be alive and be reused in a pool.

you can read about new type pattern, see explanation

from amqprs.

As I understand, you should not call close in recycle because it must be alive and be reused in a pool.

you can read about new type pattern, see explanation

Whoops, yes you are right I misunderstood what it means by recycle (should have looked at examples), based on the assumption that is_open will get automatically set to false when the connection closed, even if no callback is registered?

from amqprs.

is_open will get automatically set to false when the connection closed, even if no callback is registered?

That’s right

from amqprs.

if no more issue with it, I would close it in the near future

from amqprs.

if no more issue with it, I would close it in the near future

Yes there is no more issue related to this topic, feel free to close it if you want to.

from amqprs.