class TransportPoolProxy extends PoolProxy implements Stringable, TransportInterface

Methods

__construct(PoolDefinition $definition, Closure $createCallback, Factory $pools, Closure|null $releaseCallback = null)

Create a proxy that resolves its current pool per operation.

pool()

Resolve the current pool for this proxy's definition.

lease()

Borrow an object under an exactly-once lease.

mixed
invoke(string $method, array $arguments)

Invoke a synchronous method on a borrowed object.

void
configureBorrowed(object $object)

Apply proxy-held state to a freshly borrowed object.

getDefinition()

Get this proxy's immutable pool definition.

string
getPoolName()

Return the pool's fully qualified registry name.

bool
invalidatePool()

Remove and close this proxy's current shared pool.

SentMessage|null
send(RawMessage $message, Envelope|null $envelope = null)

No description

string
__toString()

No description

Details

in PoolProxy at line 18
__construct(PoolDefinition $definition, Closure $createCallback, Factory $pools, Closure|null $releaseCallback = null)

Create a proxy that resolves its current pool per operation.

Parameters

PoolDefinition $definition
Closure $createCallback
Factory $pools
Closure|null $releaseCallback

in PoolProxy at line 29
protected ObjectPool pool()

Resolve the current pool for this proxy's definition.

Return Value

ObjectPool

in PoolProxy at line 37
protected Lease lease()

Borrow an object under an exactly-once lease.

Return Value

Lease

in PoolProxy at line 55
protected mixed invoke(string $method, array $arguments)

Invoke a synchronous method on a borrowed object.

Parameters

string $method
array $arguments

Return Value

mixed

in PoolProxy at line 73
protected void configureBorrowed(object $object)

Apply proxy-held state to a freshly borrowed object.

Parameters

object $object

Return Value

void

in PoolProxy at line 80
PoolDefinition getDefinition()

Get this proxy's immutable pool definition.

Return Value

PoolDefinition

in PoolProxy at line 88
string getPoolName()

Return the pool's fully qualified registry name.

Return Value

string

in PoolProxy at line 96
bool invalidatePool()

Remove and close this proxy's current shared pool.

Return Value

bool

at line 20
SentMessage|null send(RawMessage $message, Envelope|null $envelope = null)

No description

Parameters

RawMessage $message
Envelope|null $envelope

Return Value

SentMessage|null

Exceptions

TransportExceptionInterface

at line 25
string __toString()

No description

Return Value

string