Author: niklas
Date: Wed Nov 22 07:10:49 2006
New Revision: 478186
URL: http://svn.apache.org/viewvc?view=rev&rev=478186
Log:
Added setSessionConfig(...) methods to acceptors and connectors for the
datagram and socket transports.
Modified:
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketConnector.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
Modified:
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java?view=diff&rev=478186&r1=478185&r2=478186
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
Wed Nov 22 07:10:49 2006
@@ -62,4 +62,15 @@
{
( ( DatagramAcceptorDelegate ) delegate ).setSessionRecycler(
sessionRecycler );
}
+
+ /**
+ * Sets the [EMAIL PROTECTED] DatagramSessionConfig} this acceptor will
use for new sessions.
+ *
+ * @param sessionConfig the config.
+ * @throws NullPointerException if the specified value is
<code>null</code>.
+ */
+ public void setSessionConfig( DatagramSessionConfig sessionConfig )
+ {
+ ( ( DatagramAcceptorDelegate ) delegate ).setSessionConfig(
sessionConfig );
+ }
}
Modified:
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramConnector.java?view=diff&rev=478186&r1=478185&r2=478186
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
Wed Nov 22 07:10:49 2006
@@ -62,4 +62,15 @@
{
( ( DatagramConnectorDelegate ) delegate ).setSessionRecycler(
sessionRecycler );
}
+
+ /**
+ * Sets the [EMAIL PROTECTED] DatagramSessionConfig} this connector will
use for new sessions.
+ *
+ * @param sessionConfig the config.
+ * @throws NullPointerException if the specified value is
<code>null</code>.
+ */
+ public void setSessionConfig( DatagramSessionConfig sessionConfig )
+ {
+ ( ( DatagramConnectorDelegate ) delegate ).setSessionConfig(
sessionConfig );
+ }
}
Modified:
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java?view=diff&rev=478186&r1=478185&r2=478186
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketAcceptor.java
Wed Nov 22 07:10:49 2006
@@ -148,6 +148,21 @@
}
/**
+ * Sets the [EMAIL PROTECTED] SocketSessionConfig} this acceptor will use
for new sessions.
+ *
+ * @param sessionConfig the config.
+ * @throws NullPointerException if the specified value is
<code>null</code>.
+ */
+ public void setSessionConfig( SocketSessionConfig sessionConfig )
+ {
+ if( sessionConfig == null )
+ {
+ throw new NullPointerException( "sessionConfig" );
+ }
+ this.sessionConfig = sessionConfig;
+ }
+
+ /**
* @see ServerSocket#getReuseAddress()
*/
public boolean isReuseAddress()
Modified:
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketConnector.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketConnector.java?view=diff&rev=478186&r1=478185&r2=478186
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketConnector.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketConnector.java
Wed Nov 22 07:10:49 2006
@@ -116,6 +116,21 @@
}
/**
+ * Sets the [EMAIL PROTECTED] SocketSessionConfig} this connector will use
for new sessions.
+ *
+ * @param sessionConfig the config.
+ * @throws NullPointerException if the specified value is
<code>null</code>.
+ */
+ public void setSessionConfig( SocketSessionConfig sessionConfig )
+ {
+ if( sessionConfig == null )
+ {
+ throw new NullPointerException( "sessionConfig" );
+ }
+ this.sessionConfig = sessionConfig;
+ }
+
+ /**
* How many seconds to keep the connection thread alive between connection
requests
*
* @return Number of seconds to keep connection thread alive
Modified:
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java?view=diff&rev=478186&r1=478185&r2=478186
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramAcceptorDelegate.java
Wed Nov 22 07:10:49 2006
@@ -57,7 +57,7 @@
private static volatile int nextId = 0;
private IoSessionRecycler sessionRecycler = DEFAULT_RECYCLER;
- private final IoSessionConfig sessionConfig = new
DatagramSessionConfigImpl();
+ private IoSessionConfig sessionConfig = new DatagramSessionConfigImpl();
private final IoAcceptor wrapper;
private final Executor executor;
@@ -244,6 +244,21 @@
return sessionConfig;
}
+ /**
+ * Sets the [EMAIL PROTECTED] DatagramSessionConfig} this acceptor will
use for new sessions.
+ *
+ * @param sessionConfig the config.
+ * @throws NullPointerException if the specified value is
<code>null</code>.
+ */
+ public void setSessionConfig( DatagramSessionConfig sessionConfig )
+ {
+ if( sessionConfig == null )
+ {
+ throw new NullPointerException( "sessionConfig" );
+ }
+ this.sessionConfig = sessionConfig;
+ }
+
public IoServiceListenerSupport getListeners()
{
return super.getListeners();
Modified:
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java?view=diff&rev=478186&r1=478185&r2=478186
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/support/DatagramConnectorDelegate.java
Wed Nov 22 07:10:49 2006
@@ -59,7 +59,7 @@
private static volatile int nextId = 0;
private IoSessionRecycler sessionRecycler = DEFAULT_RECYCLER;
- private final IoSessionConfig sessionConfig = new
DatagramSessionConfigImpl();
+ private IoSessionConfig sessionConfig = new DatagramSessionConfigImpl();
private final IoConnector wrapper;
private final Executor executor;
@@ -181,6 +181,21 @@
return sessionConfig;
}
+ /**
+ * Sets the [EMAIL PROTECTED] DatagramSessionConfig} this connector will
use for new sessions.
+ *
+ * @param sessionConfig the config.
+ * @throws NullPointerException if the specified value is
<code>null</code>.
+ */
+ public void setSessionConfig( DatagramSessionConfig sessionConfig )
+ {
+ if( sessionConfig == null )
+ {
+ throw new NullPointerException( "sessionConfig" );
+ }
+ this.sessionConfig = sessionConfig;
+ }
+
private synchronized void startupWorker() throws IOException
{
if( worker == null )
