org.apache.activemq.transport.nio

Class NIOSSLTransportServer

java.lang.Object

org.apache.activemq.util.ServiceSupport

org.apache.activemq.transport.TransportServerSupport

org.apache.activemq.transport.TransportServerThreadSupport

org.apache.activemq.transport.tcp.TcpTransportServer

org.apache.activemq.transport.nio.NIOSSLTransportServer

All Implemented Interfaces:

java.lang.Runnable, Service, TransportServer, ServiceListener

public class NIOSSLTransportServer
extends TcpTransportServer

Field Summary

Fields inherited from class org.apache.activemq.transport.tcp.TcpTransportServer

allowLinkStealing, backlog, connectionTimeout, currentTransportCount, dynamicManagement, logWriterName, maximumConnections, maxInactivityDuration, maxInactivityDurationInitalDelay, minmumWireFormatVersion, serverSocket, serverSocketFactory, socketBufferSize, socketHandlerThread, socketQueue, soTimeout, startLogging, trace, transportFactory, useQueueForAccept, wireFormatFactory

Fields inherited from class org.apache.activemq.transport.TransportServerSupport

transportOptions

Constructor Summary

Constructors

Constructor and Description
NIOSSLTransportServer(javax.net.ssl.SSLContext context, TcpTransportFactory transportFactory, java.net.URI location, javax.net.ServerSocketFactory serverSocketFactory)

Method Summary

Methods

Modifier and Type	Method and Description
protected Transport	createTransport(java.net.Socket socket, WireFormat format) Allow derived classes to override the Transport implementation that this transport server creates.
boolean	isNeedClientAuth()
boolean	isSslServer() For TransportServers that provide SSL connections to their connected peers they should return true here if and only if they populate the ConnectionInfo command presented to the Broker with the peers certificate chain so that the broker knows it can use that information to authenticate the connected peer.
boolean	isWantClientAuth()
void	setNeedClientAuth(boolean value)
void	setWantClientAuth(boolean value)

Methods inherited from class org.apache.activemq.transport.tcp.TcpTransportServer

bind, doStart, doStop, getBacklog, getConnectionTimeout, getLogWriterName, getMaximumConnections, getMaxInactivityDuration, getMaxInactivityDurationInitalDelay, getMinmumWireFormatVersion, getSocketAddress, getSocketBufferSize, getSoTimeout, getWireFormatFactory, handleSocket, isAllowLinkStealing, isDynamicManagement, isStartLogging, isTrace, isUseQueueForAccept, resolveHostName, run, setAllowLinkStealing, setBacklog, setBrokerInfo, setConnectionTimeout, setDynamicManagement, setLogWriterName, setMaximumConnections, setMaxInactivityDuration, setMaxInactivityDurationInitalDelay, setMinmumWireFormatVersion, setSocketBufferSize, setSoTimeout, setStartLogging, setTrace, setUseQueueForAccept, setWireFormatFactory, started, stopped, toString

Methods inherited from class org.apache.activemq.transport.TransportServerThreadSupport

getStackSize, isDaemon, isJoinOnStop, setDaemon, setJoinOnStop, setStackSize

Methods inherited from class org.apache.activemq.transport.TransportServerSupport

getAcceptListener, getBindLocation, getConnectURI, onAcceptError, setAcceptListener, setBindLocation, setConnectURI, setTransportOption

Methods inherited from class org.apache.activemq.util.ServiceSupport

addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.Service

start, stop

Constructor Detail

NIOSSLTransportServer

public NIOSSLTransportServer(javax.net.ssl.SSLContext context,
                     TcpTransportFactory transportFactory,
                     java.net.URI location,
                     javax.net.ServerSocketFactory serverSocketFactory)
                      throws java.io.IOException,
                             java.net.URISyntaxException

Throws:

java.io.IOException

java.net.URISyntaxException

Method Detail

createTransport

protected Transport createTransport(java.net.Socket socket,
                        WireFormat format)
                             throws java.io.IOException

Description copied from class: TcpTransportServer

Allow derived classes to override the Transport implementation that this transport server creates.

Overrides:

createTransport in class TcpTransportServer

Returns:

Throws:

java.io.IOException

isSslServer

public boolean isSslServer()

Description copied from interface: TransportServer

For TransportServers that provide SSL connections to their connected peers they should return true here if and only if they populate the ConnectionInfo command presented to the Broker with the peers certificate chain so that the broker knows it can use that information to authenticate the connected peer.

Specified by:

isSslServer in interface TransportServer

Overrides:

isSslServer in class TcpTransportServer

Returns:

true if this transport server provides SSL level security over its connections.

isNeedClientAuth

public boolean isNeedClientAuth()

setNeedClientAuth

public void setNeedClientAuth(boolean value)

isWantClientAuth

public boolean isWantClientAuth()

setWantClientAuth

public void setWantClientAuth(boolean value)