Code cleanup/polish
This commit is contained in:
parent
615e224292
commit
b9c6a1422d
@ -312,7 +312,6 @@ class ConnectionManager<C extends Connection> implements Listeners, ISessionMana
|
|||||||
@Override
|
@Override
|
||||||
public final
|
public final
|
||||||
void onMessage(final ConnectionImpl connection, final Object message) {
|
void onMessage(final ConnectionImpl connection, final Object message) {
|
||||||
logger.trace("onMessage({}, {})", connection.id(), message.getClass());
|
|
||||||
notifyOnMessage0(connection, message, false);
|
notifyOnMessage0(connection, message, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -384,8 +383,6 @@ class ConnectionManager<C extends Connection> implements Listeners, ISessionMana
|
|||||||
@Override
|
@Override
|
||||||
public
|
public
|
||||||
void onConnected(final ConnectionImpl connection) {
|
void onConnected(final ConnectionImpl connection) {
|
||||||
logger.trace("onConnected({})", connection.id());
|
|
||||||
|
|
||||||
// we add the connection in a different step!
|
// we add the connection in a different step!
|
||||||
|
|
||||||
boolean foundListener = onConnectedManager.notifyConnected((C) connection, shutdown);
|
boolean foundListener = onConnectedManager.notifyConnected((C) connection, shutdown);
|
||||||
@ -438,8 +435,6 @@ class ConnectionManager<C extends Connection> implements Listeners, ISessionMana
|
|||||||
@Override
|
@Override
|
||||||
public
|
public
|
||||||
void addConnection(ConnectionImpl connection) {
|
void addConnection(ConnectionImpl connection) {
|
||||||
logger.trace("addConnection({})", connection.id());
|
|
||||||
|
|
||||||
addConnection0(connection);
|
addConnection0(connection);
|
||||||
|
|
||||||
// now have to account for additional (local) listener managers.
|
// now have to account for additional (local) listener managers.
|
||||||
|
Loading…
Reference in New Issue
Block a user