|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.transport.TransportServerChannelSupport
org.activemq.transport.tcp.TcpTransportServerChannel
Binds to a well known port and listens for Sockets ...
Field Summary | |
protected static int |
DEFAULT_BACKLOG
|
Constructor Summary | |
TcpTransportServerChannel(WireFormat wireFormat,
java.net.ServerSocket serverSocket)
|
|
TcpTransportServerChannel(WireFormat wireFormat,
java.net.URI bindAddr)
Default Constructor |
Method Summary | |
protected java.net.ServerSocket |
createServerSocket(java.net.URI bind)
Factory method to create a new ServerSocket |
protected TcpTransportChannel |
createTransportChannel(java.net.Socket socket,
EDU.oswego.cs.dl.util.concurrent.PooledExecutor executor)
|
int |
getBacklog()
|
int |
getMaxOutstandingMessages()
|
java.net.InetSocketAddress |
getSocketAddress()
An optional method to return the socket address if there is one on which this channel is listening. |
WireFormat |
getWireFormat()
|
boolean |
isUseAsyncSend()
|
void |
run()
pull Sockets from the ServerSocket |
void |
setBacklog(int backlog)
|
void |
setMaxOutstandingMessages(int maxOutstandingMessages)
|
void |
setUseAsyncSend(boolean useAsyncSend)
|
void |
setWireFormat(WireFormat wireFormat)
|
void |
start()
start listeneing for events |
void |
stop()
close the ServerChannel |
java.lang.String |
toString()
|
protected void |
updatePhysicalUri(java.net.URI bindAddr)
In cases where we construct ourselves with a zero port we need to regenerate the URI with the real physical port so that people can connect to us via discovery |
Methods inherited from class org.activemq.transport.TransportServerChannelSupport |
addClient, getTransportChannelListener, getUrl, removeClient, resolveHostName, setTransportChannelListener, setUrl |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
protected static final int DEFAULT_BACKLOG
Constructor Detail |
public TcpTransportServerChannel(WireFormat wireFormat, java.net.URI bindAddr) throws javax.jms.JMSException
bindAddr
-
javax.jms.JMSException
public TcpTransportServerChannel(WireFormat wireFormat, java.net.ServerSocket serverSocket) throws javax.jms.JMSException
Method Detail |
public void start() throws javax.jms.JMSException
TransportServerChannel
start
in interface TransportServerChannel
start
in class TransportServerChannelSupport
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
TransportServerChannel
stop
in interface TransportServerChannel
stop
in class TransportServerChannelSupport
javax.jms.JMSException
public java.net.InetSocketAddress getSocketAddress()
TransportServerChannel
getSocketAddress
in interface TransportServerChannel
getSocketAddress
in class TransportServerChannelSupport
public java.lang.String toString()
public void run()
run
in interface java.lang.Runnable
protected TcpTransportChannel createTransportChannel(java.net.Socket socket, EDU.oswego.cs.dl.util.concurrent.PooledExecutor executor) throws javax.jms.JMSException
javax.jms.JMSException
public boolean isUseAsyncSend()
public void setUseAsyncSend(boolean useAsyncSend)
public int getMaxOutstandingMessages()
public void setMaxOutstandingMessages(int maxOutstandingMessages)
public int getBacklog()
public void setBacklog(int backlog)
public WireFormat getWireFormat()
public void setWireFormat(WireFormat wireFormat)
protected void updatePhysicalUri(java.net.URI bindAddr) throws java.net.URISyntaxException
java.net.URISyntaxException
protected java.net.ServerSocket createServerSocket(java.net.URI bind) throws java.net.UnknownHostException, java.io.IOException
java.net.UnknownHostException
java.io.IOException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |