JavaScript is disabled on your browser.

Interface ChannelPool

All Superinterfaces:: AutoCloseable, Closeable

All Known Implementing Classes:: FixedChannelPool, SimpleChannelPool

public interface ChannelPool extends Closeable

Allows to acquire and release Channel and so act as a pool of these.

Method Summary

Modifier and Type

Method

Description

Future <Channel>

acquire()

Acquire a Channel from this ChannelPool.

Future <Channel>

acquire (Promise<Channel> promise)

Acquire a Channel from this ChannelPool.

void

close()

Future <Void>

release (Channel channel)

Release a Channel back to this ChannelPool.

Future <Void>

release (Channel channel, Promise<Void> promise)

Release a Channel back to this ChannelPool.

Method Details
- acquire
  
  Future<Channel> acquire()
  
  Acquire a Channel from this ChannelPool. The returned Future is notified once the acquire is successful and failed otherwise. Its important that an acquired is always released to the pool again, even if the Channel is explicitly closed..
- acquire
  
  Future<Channel> acquire(Promise<Channel> promise)
  
  Acquire a Channel from this ChannelPool. The given Promise is notified once the acquire is successful and failed otherwise. Its important that an acquired is always released to the pool again, even if the Channel is explicitly closed..
- release
  
  Future<Void> release(Channel channel)
  
  Release a Channel back to this ChannelPool. The returned Future is notified once the release is successful and failed otherwise. When failed the Channel will automatically closed.
- release
  
  Future<Void> release(Channel channel, Promise<Void> promise)
  
  Release a Channel back to this ChannelPool. The given Promise is notified once the release is successful and failed otherwise. When failed the Channel will automatically closed.
- close
  
  void close()
  
  Specified by:
  
  close in interface AutoCloseable
  
  Specified by:
  
  close in interface Closeable