org.activemq.transport.stomp
Class StompTransportServerChannel
java.lang.Object
org.activemq.transport.TransportServerChannelSupport
org.activemq.transport.tcp.TcpTransportServerChannel
org.activemq.transport.stomp.StompTransportServerChannel
- All Implemented Interfaces:
- Runnable, Service, TransportServerChannel
public class StompTransportServerChannel
- extends TcpTransportServerChannel
- implements Runnable
A TTMP server connector
- Version:
- $Revision: 1.1.1.1 $
Methods inherited from class org.activemq.transport.tcp.TcpTransportServerChannel |
createServerSocket, getBacklog, getMaxOutstandingMessages, getSocketAddress, getWireFormat, isUseAsyncSend, run, setBacklog, setMaxOutstandingMessages, setUseAsyncSend, setWireFormat, start, stop, toString, updatePhysicalUri |
Methods inherited from interface java.lang.Runnable |
run |
StompTransportServerChannel
public StompTransportServerChannel(URI bindAddr)
throws JMSException
- Throws:
JMSException
StompTransportServerChannel
public StompTransportServerChannel(ServerSocket serverSocket)
throws JMSException
- Throws:
JMSException
createTransportChannel
protected TcpTransportChannel createTransportChannel(Socket socket,
PooledExecutor executor)
throws JMSException
- Overrides:
createTransportChannel
in class TcpTransportServerChannel
- Throws:
JMSException
Copyright © 2004-2008 Protique, Ltd.. All Rights Reserved.