org.hornetq.core.remoting.impl.netty

Class NettyServerConnection

java.lang.Object

org.hornetq.core.remoting.impl.netty.NettyConnection

org.hornetq.core.remoting.impl.netty.NettyServerConnection

All Implemented Interfaces:

Connection

public class NettyServerConnection
extends NettyConnection

Author:

Norman Maurer

Field Summary

Fields inherited from class org.hornetq.core.remoting.impl.netty.NettyConnection

channel

Constructor Summary

Constructors

Constructor and Description
NettyServerConnection(Map<String,Object> configuration, io.netty.channel.Channel channel, ConnectionLifeCycleListener listener, boolean batchingEnabled, boolean directDeliver)

Method Summary

Modifier and Type	Method and Description
HornetQBuffer	createTransportBuffer(int size) Create a new HornetQBuffer of the given size.

Methods inherited from class org.hornetq.core.remoting.impl.netty.NettyConnection

addReadyListener, checkFlushBatchBuffer, close, forceClose, getChannel, getConnectorConfig, getDefaultHornetQPrincipal, getID, getNettyChannel, getRemoteAddress, isDirectDeliver, removeReadyListener, toString, write, write

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyServerConnection

public NettyServerConnection(Map<String,Object> configuration,
                             io.netty.channel.Channel channel,
                             ConnectionLifeCycleListener listener,
                             boolean batchingEnabled,
                             boolean directDeliver)

Method Detail

createTransportBuffer

public HornetQBuffer createTransportBuffer(int size)

Description copied from interface: Connection

Create a new HornetQBuffer of the given size.

Specified by:

createTransportBuffer in interface Connection

Overrides:

createTransportBuffer in class NettyConnection

Parameters:

size - the size of buffer to create

Returns:

the new buffer.