io.micronaut.configuration.rabbitmq.connect

Interface ChannelPool

All Superinterfaces:

io.micronaut.core.naming.Named

All Known Implementing Classes:

DefaultChannelPool

public interface ChannelPool
extends io.micronaut.core.naming.Named

A pool of Channels to allow for channels to be shared across threads but not at the same time. A channel retrieved from the pool should not be accessible to any other threads until the channel is returned from the pool.

Since:

1.1.0

Author:

James Kleeh

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.Channel	getChannel() Retrieves a channel from the pool.
void	returnChannel(com.rabbitmq.client.Channel channel) Returns a channel to the pool.

Methods inherited from interface io.micronaut.core.naming.Named

getName

Method Detail

getChannel

com.rabbitmq.client.Channel getChannel()
                                throws IOException

Retrieves a channel from the pool. The channel must be returned to the pool after it is no longer being used.

Returns:

The channel

Throws:

IOException - If a channel needed to be created and encountered an error

returnChannel

void returnChannel(com.rabbitmq.client.Channel channel)

Returns a channel to the pool. No further use of the channel is allowed by the returner.

Parameters:

channel - The channel