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:

org.apache.activemq.artemis.spi.core.remoting.Connection

public class NettyServerConnection
extends org.apache.activemq.artemis.core.remoting.impl.netty.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, ServerConnectionLifeCycleListener listener, boolean batchingEnabled, boolean directDeliver)

Method Summary

Modifier and Type	Method and Description
org.apache.activemq.artemis.api.core.ActiveMQBuffer	createTransportBuffer(int 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, setAutoRead, 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,
                             ServerConnectionLifeCycleListener listener,
                             boolean batchingEnabled,
                             boolean directDeliver)

Method Detail

createTransportBuffer

public org.apache.activemq.artemis.api.core.ActiveMQBuffer createTransportBuffer(int size)

Specified by:

createTransportBuffer in interface org.apache.activemq.artemis.spi.core.remoting.Connection

Overrides:

createTransportBuffer in class org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnection