|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.transport.TransportServerChannelSupport
org.codehaus.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,
ServerSocket serverSocket)
|
|
TcpTransportServerChannel(WireFormat wireFormat,
URI bindAddr)
Default Constructor |
Method Summary | |
protected ServerSocket |
createServerSocket(URI bind)
Factory method to create a new ServerSocket |
int |
getBacklog()
|
int |
getMaxOutstandingMessages()
|
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 |
String |
toString()
|
protected void |
updatePhysicalUri(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.codehaus.activemq.transport.TransportServerChannelSupport |
addClient, getTransportChannelListener, getUrl, 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, URI bindAddr) throws JMSException
bindAddr
-
JMSException
public TcpTransportServerChannel(WireFormat wireFormat, ServerSocket serverSocket) throws JMSException
Method Detail |
public void start() throws JMSException
TransportServerChannel
start
in interface TransportServerChannel
start
in class TransportServerChannelSupport
JMSException
public void stop() throws JMSException
TransportServerChannel
stop
in interface TransportServerChannel
stop
in class TransportServerChannelSupport
JMSException
public String toString()
public void run()
run
in interface Runnable
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(URI bindAddr) throws URISyntaxException
URISyntaxException
protected ServerSocket createServerSocket(URI bind) throws UnknownHostException, IOException
UnknownHostException
IOException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |