public abstract class AbstractSocketJaffreConnector extends Object implements JaffreConnector
Constructor and Description |
---|
AbstractSocketJaffreConnector() |
Modifier and Type | Method and Description |
---|---|
InetAddress |
getBindingInetAddress()
Get the connector's binding address.
|
JaffreCallFrameSerializer |
getCallFrameSerializer()
Get the serializer for Jaffre frames.
|
int |
getCoreThreadPoolSize() |
int |
getMaxThreadPoolSize() |
int |
getPort() |
JaffreReturnFrameSerializer |
getReturnFrameSerializer()
Get the serializer for Jaffre return frames.
|
JaffreServer |
getServer()
Get the server this connector is connected to.
|
long |
getStopTimeout()
Get the timeout to wait for worker threads when this connector's
JaffreConnector.stop() method is being called. |
void |
setBindingAddress(String p_strBindingAddress)
Set the connector's binding address.
|
void |
setBindingInetAddress(InetAddress p_inetAddr)
Set the connector's binding address.
|
void |
setCallFrameSerializer(JaffreCallFrameSerializer p_serializer)
Set the serializer for Jaffre frames.
|
void |
setCoreThreadPoolSize(int p_iCoreThreadPoolSize) |
void |
setMaxThreadPoolSize(int p_iMaxThreadPoolSize) |
void |
setPort(int p_iPort) |
void |
setReturnFrameSerializer(JaffreReturnFrameSerializer p_serializer)
Set the serializer for Jaffre return frames.
|
void |
setServer(JaffreServer p_server)
Connect this connector with a server.
|
void |
setStopTimeout(long p_lStopTimeout)
Set the timeout to wait for worker threads when this connector's
JaffreConnector.stop() method is being called. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isRunning, start, stop
public int getCoreThreadPoolSize()
public void setCoreThreadPoolSize(int p_iCoreThreadPoolSize)
public int getMaxThreadPoolSize()
public void setMaxThreadPoolSize(int p_iMaxThreadPoolSize)
public long getStopTimeout()
JaffreConnector.stop()
method is being called. The default value is
1000
milliseconds.public void setStopTimeout(long p_lStopTimeout)
JaffreConnector.stop()
method is being called.p_lStopTimeout
- The timeout in milliseconds.IllegalArgumentException
- - If p_lStopTimeout
is negative.public InetAddress getBindingInetAddress()
public void setBindingInetAddress(InetAddress p_inetAddr)
p_inetAddr
- The connector's binding address.public void setBindingAddress(String p_strBindingAddress) throws UnknownHostException
p_strBindingAddress
- The connector's binding address.UnknownHostException
- See InetAddress.getByName(String)
.public int getPort()
public void setPort(int p_iPort)
public JaffreCallFrameSerializer getCallFrameSerializer()
public void setCallFrameSerializer(JaffreCallFrameSerializer p_serializer)
p_serializer
- The serializer for Jaffre frames.public JaffreReturnFrameSerializer getReturnFrameSerializer()
public void setReturnFrameSerializer(JaffreReturnFrameSerializer p_serializer)
p_serializer
- The serializer for Jaffre return frames.public JaffreServer getServer()
JaffreConnector
getServer
in interface JaffreConnector
null
.public void setServer(JaffreServer p_server)
JaffreConnector
setServer
in interface JaffreConnector
p_server
- The server to connect with.Copyright © 2009-2013 Alexander Veit. All Rights Reserved.