notify when client connection lost;
implement onConnectionLost() method in AbstractInterceptHandler.java;
This commit is contained in:
@@ -30,6 +30,9 @@ public abstract class AbstractInterceptHandler implements InterceptHandler {
|
|||||||
@Override
|
@Override
|
||||||
public void onDisconnect(InterceptDisconnectMessage msg) {}
|
public void onDisconnect(InterceptDisconnectMessage msg) {}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onConnectionLost(InterceptConnectionLostMessage msg) {}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onPublish(InterceptPublishMessage msg) {}
|
public void onPublish(InterceptPublishMessage msg) {}
|
||||||
|
|
||||||
|
|||||||
@@ -51,6 +51,11 @@ public class BrokerInterceptorTest {
|
|||||||
n.set(50);
|
n.set(50);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void onConnectionLost(InterceptConnectionLostMessage msg) {
|
||||||
|
n.set(30);
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void onPublish(InterceptPublishMessage msg) {
|
public void onPublish(InterceptPublishMessage msg) {
|
||||||
n.set(60);
|
n.set(60);
|
||||||
|
|||||||
Reference in New Issue
Block a user