com.github.pgasync.impl.netty

Class NettyPgConnectionPool

java.lang.Object

com.github.pgasync.impl.PgConnectionPool

com.github.pgasync.impl.netty.NettyPgConnectionPool

All Implemented Interfaces:

ConnectionPool, Db, QueryExecutor, TransactionExecutor, java.lang.AutoCloseable

public class NettyPgConnectionPool
extends PgConnectionPool

PgConnectionPool that uses NettyPgProtocolStream. Each pool starts a single Netty IO thread.

Author:

Antti Laisi

Constructor Summary

Constructors

Constructor and Description
NettyPgConnectionPool(ConnectionPoolBuilder.PoolProperties properties)

Method Summary

Modifier and Type	Method and Description
void	close() Closes the pool.
protected PgConnection	newConnection(java.net.InetSocketAddress address) Creates a new connection to the backend.

Methods inherited from class com.github.pgasync.impl.PgConnectionPool

begin, dataConverter, getConnection, query, query, release

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NettyPgConnectionPool

public NettyPgConnectionPool(ConnectionPoolBuilder.PoolProperties properties)

Method Detail

newConnection

protected PgConnection newConnection(java.net.InetSocketAddress address)

Description copied from class: PgConnectionPool

Creates a new connection to the backend.

Specified by:

newConnection in class PgConnectionPool

Parameters:

address - Server address

Returns:

Unconnected connection

close

public void close()

Description copied from interface: ConnectionPool

Closes the pool.

Specified by:

close in interface ConnectionPool

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class PgConnectionPool