warnings cleanup
This commit is contained in:
parent
1c9c83f110
commit
5eaee3df47
@ -81,6 +81,7 @@ class Client<C extends Connection> extends EndPointClient<C> implements Connecti
|
|||||||
/**
|
/**
|
||||||
* Starts a REMOTE <b>only</b> client, which will connect to the specified host using the specified Connections Options
|
* Starts a REMOTE <b>only</b> client, which will connect to the specified host using the specified Connections Options
|
||||||
*/
|
*/
|
||||||
|
@SuppressWarnings("AutoBoxing")
|
||||||
public
|
public
|
||||||
Client(final Configuration options) throws InitializationException, SecurityException, IOException {
|
Client(final Configuration options) throws InitializationException, SecurityException, IOException {
|
||||||
super(options);
|
super(options);
|
||||||
@ -255,7 +256,7 @@ class Client<C extends Connection> extends EndPointClient<C> implements Connecti
|
|||||||
/**
|
/**
|
||||||
* Allows the client to reconnect to the last connected server
|
* Allows the client to reconnect to the last connected server
|
||||||
*
|
*
|
||||||
* @throws InterruptedException if the client is unable to reconnect in the previously requested connection-timeout
|
* @throws IOException if the client is unable to reconnect in the previously requested connection-timeout
|
||||||
*/
|
*/
|
||||||
public
|
public
|
||||||
void reconnect() throws IOException {
|
void reconnect() throws IOException {
|
||||||
@ -265,7 +266,7 @@ class Client<C extends Connection> extends EndPointClient<C> implements Connecti
|
|||||||
/**
|
/**
|
||||||
* Allows the client to reconnect to the last connected server
|
* Allows the client to reconnect to the last connected server
|
||||||
*
|
*
|
||||||
* @throws InterruptedException if the client is unable to reconnect in the requested time
|
* @throws IOException if the client is unable to reconnect in the requested time
|
||||||
*/
|
*/
|
||||||
public
|
public
|
||||||
void reconnect(int connectionTimeout) throws IOException {
|
void reconnect(int connectionTimeout) throws IOException {
|
||||||
@ -412,9 +413,9 @@ class Client<C extends Connection> extends EndPointClient<C> implements Connecti
|
|||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
public
|
public
|
||||||
<Iface, Impl extends Iface> Iface createRemoteObject(final Class<Impl> remoteImplementationClass) throws IOException {
|
<Iface, Impl extends Iface> Iface createProxyObject(final Class<Impl> remoteImplementationClass) throws IOException {
|
||||||
return this.connectionManager.getConnection0()
|
return this.connectionManager.getConnection0()
|
||||||
.createRemoteObject(remoteImplementationClass);
|
.createProxyObject(remoteImplementationClass);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -442,9 +443,9 @@ class Client<C extends Connection> extends EndPointClient<C> implements Connecti
|
|||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
public
|
public
|
||||||
<Iface, Impl extends Iface> Iface getRemoteObject(final int objectId) throws IOException {
|
<Iface, Impl extends Iface> Iface getProxyObject(final int objectId) throws IOException {
|
||||||
return this.connectionManager.getConnection0()
|
return this.connectionManager.getConnection0()
|
||||||
.getRemoteObject(objectId);
|
.getProxyObject(objectId);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -87,6 +87,7 @@ class Server<C extends Connection> extends EndPointServer<C> {
|
|||||||
/**
|
/**
|
||||||
* Convenience method to starts a server with the specified Connection Options
|
* Convenience method to starts a server with the specified Connection Options
|
||||||
*/
|
*/
|
||||||
|
@SuppressWarnings("AutoBoxing")
|
||||||
public
|
public
|
||||||
Server(Configuration options) throws InitializationException, SecurityException, IOException {
|
Server(Configuration options) throws InitializationException, SecurityException, IOException {
|
||||||
// watch-out for serialization... it can be NULL incoming. The EndPoint (superclass) sets it, if null, so
|
// watch-out for serialization... it can be NULL incoming. The EndPoint (superclass) sets it, if null, so
|
||||||
@ -175,7 +176,7 @@ class Server<C extends Connection> extends EndPointServer<C> {
|
|||||||
.channel(LocalServerChannel.class)
|
.channel(LocalServerChannel.class)
|
||||||
.option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)
|
.option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)
|
||||||
.localAddress(new LocalAddress(this.localChannelName))
|
.localAddress(new LocalAddress(this.localChannelName))
|
||||||
.childHandler(new RegistrationLocalHandlerServer(threadName, this.registrationWrapper));
|
.childHandler(new RegistrationLocalHandlerServer<C>(threadName, this.registrationWrapper));
|
||||||
|
|
||||||
manageForShutdown(boss);
|
manageForShutdown(boss);
|
||||||
manageForShutdown(worker);
|
manageForShutdown(worker);
|
||||||
|
Loading…
Reference in New Issue
Block a user