org.apache.activemq.artemis.core.remoting.impl.netty

Class NettyServerConnection

java.lang.Object

org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnection

org.apache.activemq.artemis.core.remoting.impl.netty.NettyServerConnection

All Implemented Interfaces:

Connection

public class NettyServerConnection
extends NettyConnection

Field Summary

Fields inherited from class org.apache.activemq.artemis.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
ActiveMQBuffer	createTransportBuffer(int size) Create a new ActiveMQBuffer of the given size.

Methods inherited from class org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnection

checkFlushBatchBuffer, close, fireReady, forceClose, getChannel, getConnectorConfig, getDefaultActiveMQPrincipal, getID, getLocalAddress, getNettyChannel, getProtocolConnection, getRemoteAddress, isDirectDeliver, isUsingProtocolHandling, isWritable, setProtocolConnection, toString, write, 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 ActiveMQBuffer createTransportBuffer(int size)

Description copied from interface: Connection

Create a new ActiveMQBuffer 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.