Package org.serviceconnector.net.req.netty.tcp

Class NettyTcpConnection

java.lang.Object

org.serviceconnector.net.req.netty.NettyConnectionAdpater

org.serviceconnector.net.req.netty.tcp.NettyTcpConnection

All Implemented Interfaces:

IConnection

public class NettyTcpConnection
extends NettyConnectionAdpater

The Class NettyTcpConnection. Concrete connection implementation with JBoss Netty for Tcp.

Field Summary

Fields inherited from class org.serviceconnector.net.req.netty.NettyConnectionAdpater

baseConf, bootstrap, channel, connectionContext, encoderDecoder, host, idleTimeout, operationListener, port, remotSocketAddress, workerGroup

Constructor Summary

Constructors

Constructor	Description
NettyTcpConnection(io.netty.channel.EventLoopGroup workerGroup)	Instantiates a new NettyTcpConnection.

Method Summary

Modifier and Type	Method	Description
void	connect()	Connect.
void	send(SCMPMessage scmp, ISCMPMessageCallback callback)	Send and receive asynchronous operation.
void	setQuietDisconnect()	Sets the quiet disconnect.

Methods inherited from class org.serviceconnector.net.req.netty.NettyConnectionAdpater

destroy, disconnect, getContext, getHost, getNrOfIdlesInSequence, getPort, incrementNrOfIdles, isConnected, resetNrOfIdles, setContext, setHost, setIdleTimeoutSeconds, setPort

Methods inherited from class java.lang.Object

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

Constructor Details

NettyTcpConnection

public NettyTcpConnection(io.netty.channel.EventLoopGroup workerGroup)

Instantiates a new NettyTcpConnection.

Parameters:

workerGroup - the channel factory

Method Details

connect

public void connect()
             throws Exception

Connect.

Specified by:

connect in interface IConnection

Specified by:

connect in class NettyConnectionAdpater

Throws:

Exception - the exception

send

public void send(SCMPMessage scmp,
 ISCMPMessageCallback callback)
          throws Exception

Send and receive asynchronous operation.

Specified by:

send in interface IConnection

Specified by:

send in class NettyConnectionAdpater

Parameters:

scmp - the scmp

callback - the callback

Throws:

Exception - the exception

setQuietDisconnect

public void setQuietDisconnect()
                        throws Exception

Description copied from interface: IConnection

Sets the quiet disconnect. Disconnect is not logged or does not reply any answer to higher layer.

Throws:

Exception - the exception