com.github.pgasync.impl.netty

Class NettyPgProtocolStream

java.lang.Object

com.github.pgasync.impl.netty.NettyPgProtocolStream

All Implemented Interfaces:

PgProtocolStream

public class NettyPgProtocolStream
extends java.lang.Object
implements PgProtocolStream

Netty connection to PostgreSQL backend.

Author:

Antti Laisi

Constructor Summary

Constructors

Constructor and Description
NettyPgProtocolStream(java.net.SocketAddress address, io.netty.channel.EventLoopGroup group)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connect(StartupMessage startup, java.util.function.Consumer<java.util.List<Message>> replyTo)
boolean	isConnected()
void	send(java.util.List<Message> messages, java.util.function.Consumer<java.util.List<Message>> replyTo)
void	send(Message message, java.util.function.Consumer<java.util.List<Message>> replyTo)

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyPgProtocolStream

public NettyPgProtocolStream(java.net.SocketAddress address,
                             io.netty.channel.EventLoopGroup group)

Method Detail

connect

public void connect(StartupMessage startup,
                    java.util.function.Consumer<java.util.List<Message>> replyTo)

Specified by:

connect in interface PgProtocolStream

send

public void send(Message message,
                 java.util.function.Consumer<java.util.List<Message>> replyTo)

Specified by:

send in interface PgProtocolStream

send

public void send(java.util.List<Message> messages,
                 java.util.function.Consumer<java.util.List<Message>> replyTo)

Specified by:

send in interface PgProtocolStream

isConnected

public boolean isConnected()

Specified by:

isConnected in interface PgProtocolStream

close

public void close()

Specified by:

close in interface PgProtocolStream