Home » activemq-parent-5.3.1-source-release » org.apache » activemq » transport » tcp » [javadoc | source]
org.apache.activemq.transport.tcp
public class: TcpTransportServer [javadoc | source]
java.lang.Object
   org.apache.activemq.util.ServiceSupport
      org.apache.activemq.transport.TransportServerSupport
         org.apache.activemq.transport.TransportServerThreadSupport
            org.apache.activemq.transport.tcp.TcpTransportServer

All Implemented Interfaces:
    ServiceListener, Runnable, TransportServer, Service

Direct Known Subclasses:
    SslTransportServer, XmppTransportServer

A TCP based implementation of TransportServer
Field Summary
protected  ServerSocket serverSocket     
protected  int backlog     
protected  WireFormatFactory wireFormatFactory     
protected final  TcpTransportFactory transportFactory     
protected  long maxInactivityDuration     
protected  long maxInactivityDurationInitalDelay     
protected  int minmumWireFormatVersion     
protected  boolean useQueueForAccept     
protected  boolean trace    trace=true -> the Transport stack where this TcpTransport object will be, will have a TransportLogger layer trace=false -> the Transport stack where this TcpTransport object will be, will NOT have a TransportLogger layer, and therefore will never be able to print logging messages. This parameter is most probably set in Connection or TransportConnector URIs. 
protected  int soTimeout     
protected  int socketBufferSize     
protected  int connectionTimeout     
protected  String logWriterName    Name of the LogWriter implementation to use. Names are mapped to classes in the resources/META-INF/services/org/apache/activemq/transport/logwriters directory. This parameter is most probably set in Connection or TransportConnector URIs. 
protected  boolean dynamicManagement    Specifies if the TransportLogger will be manageable by JMX or not. Also, as long as there is at least 1 TransportLogger which is manageable, a TransportLoggerControl MBean will me created. 
protected  boolean startLogging    startLogging=true -> the TransportLogger object of the Transport stack will initially write messages to the log. startLogging=false -> the TransportLogger object of the Transport stack will initially NOT write messages to the log. This parameter only has an effect if trace == true. This parameter is most probably set in Connection or TransportConnector URIs. 
protected  Map<String, Object> transportOptions     
protected final  ServerSocketFactory serverSocketFactory     
protected  BlockingQueue<Socket> socketQueue     
protected  Thread socketHandlerThread     
protected  int maximumConnections    The maximum number of sockets allowed for this server 
protected  int currentTransportCount     
Constructor:
 public TcpTransportServer(TcpTransportFactory transportFactory,
    URI location,
    ServerSocketFactory serverSocketFactory) throws IOException, URISyntaxException 
Method from org.apache.activemq.transport.tcp.TcpTransportServer Summary:
bind,   createTransport,   doStart,   doStop,   getBacklog,   getConnectionTimeout,   getLogWriterName,   getMaxInactivityDuration,   getMaxInactivityDurationInitalDelay,   getMaximumConnections,   getMinmumWireFormatVersion,   getSoTimeout,   getSocketAddress,   getSocketBufferSize,   getWireFormatFactory,   handleSocket,   isDynamicManagement,   isStartLogging,   isTrace,   isUseQueueForAccept,   resolveHostName,   run,   setBacklog,   setBrokerInfo,   setConnectionTimeout,   setDynamicManagement,   setLogWriterName,   setMaxInactivityDuration,   setMaxInactivityDurationInitalDelay,   setMaximumConnections,   setMinmumWireFormatVersion,   setSoTimeout,   setSocketBufferSize,   setStartLogging,   setTrace,   setTransportOption,   setUseQueueForAccept,   setWireFormatFactory,   started,   stopped,   toString
Methods from org.apache.activemq.transport.TransportServerThreadSupport:
doStart,   doStop,   getStackSize,   isDaemon,   isJoinOnStop,   setDaemon,   setJoinOnStop,   setStackSize
Methods from org.apache.activemq.transport.TransportServerSupport:
getAcceptListener,   getBindLocation,   getConnectURI,   onAcceptError,   setAcceptListener,   setBindLocation,   setConnectURI
Methods from org.apache.activemq.util.ServiceSupport:
addServiceListener,   dispose,   doStart,   doStop,   isStarted,   isStopped,   isStopping,   removeServiceListener,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.transport.tcp.TcpTransportServer Detail:
 public  void bind() throws IOException 
 protected Transport createTransport(Socket socket,
    WireFormat format) throws IOException 
    Allow derived classes to override the Transport implementation that this transport server creates.
 protected  void doStart() throws Exception 
 protected  void doStop(ServiceStopper stopper) throws Exception 
 public int getBacklog() 
 public int getConnectionTimeout() 
 public String getLogWriterName() 
 public long getMaxInactivityDuration() 
 public long getMaxInactivityDurationInitalDelay() 
 public int getMaximumConnections() 
 public int getMinmumWireFormatVersion() 
 public int getSoTimeout() 
 public InetSocketAddress getSocketAddress() 
 public int getSocketBufferSize() 
 public WireFormatFactory getWireFormatFactory() 
 protected final  void handleSocket(Socket socket) 
 public boolean isDynamicManagement() 
 public boolean isStartLogging() 
 public boolean isTrace() 
 public boolean isUseQueueForAccept() 
 protected String resolveHostName(ServerSocket socket,
    InetAddress bindAddress) throws UnknownHostException 
 public  void run() 
    pull Sockets from the ServerSocket
 public  void setBacklog(int backlog) 
 public  void setBrokerInfo(BrokerInfo brokerInfo) 
    Associates a broker info with the transport server so that the transport can do discovery advertisements of the broker.
 public  void setConnectionTimeout(int connectionTimeout) 
 public  void setDynamicManagement(boolean useJmx) 
 public  void setLogWriterName(String logFormat) 
 public  void setMaxInactivityDuration(long maxInactivityDuration) 
 public  void setMaxInactivityDurationInitalDelay(long maxInactivityDurationInitalDelay) 
 public  void setMaximumConnections(int maximumConnections) 
 public  void setMinmumWireFormatVersion(int minmumWireFormatVersion) 
 public  void setSoTimeout(int soTimeout) 
 public  void setSocketBufferSize(int socketBufferSize) 
 public  void setStartLogging(boolean startLogging) 
 public  void setTrace(boolean trace) 
 public  void setTransportOption(Map<String, Object> transportOptions) 
 public  void setUseQueueForAccept(boolean useQueueForAccept) 
 public  void setWireFormatFactory(WireFormatFactory wireFormatFactory) 
 public  void started(Service service) 
 public  void stopped(Service service) 
 public String toString()