public interface ChannelPool extends io.micronaut.core.naming.Named
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.
|Modifier and Type||Method and Description|
Retrieves a channel from the pool.
Returns a channel to the pool.
com.rabbitmq.client.Channel getChannel() throws IOException
IOException- If a channel needed to be created and encountered an error
void returnChannel(com.rabbitmq.client.Channel channel)
channel- The channel