diff --git a/resources/releasedocs/changelog.html b/resources/releasedocs/changelog.html index 7d4dbc1d9..9e95e8297 100644 --- a/resources/releasedocs/changelog.html +++ b/resources/releasedocs/changelog.html @@ -141,6 +141,37 @@ hr {
+ * Note: This method is only called if {@link ReconnectionManager#isAutomaticReconnectEnabled()} returns true, i.e. + * only when the reconnection manager is enabled for the connection. + *
+ * + * @param seconds remaining seconds before attempting a reconnection. + */ + public void reconnectingIn(int seconds); + + /** + * An attempt to connect to the server has failed. The connection will keep trying reconnecting to the server in a + * moment. + *+ * Note: This method is only called if {@link ReconnectionManager#isAutomaticReconnectEnabled()} returns true, i.e. + * only when the reconnection manager is enabled for the connection. + *
+ * + * @param e the exception that caused the reconnection to fail. + */ + public void reconnectionFailed(Exception e); +} diff --git a/smack-core/src/main/java/org/jivesoftware/smack/ReconnectionManager.java b/smack-core/src/main/java/org/jivesoftware/smack/ReconnectionManager.java index 2cd0b7c8d..18cbcc1dc 100644 --- a/smack-core/src/main/java/org/jivesoftware/smack/ReconnectionManager.java +++ b/smack-core/src/main/java/org/jivesoftware/smack/ReconnectionManager.java @@ -20,7 +20,9 @@ import java.io.IOException; import java.lang.ref.WeakReference; import java.util.Map; import java.util.Random; +import java.util.Set; import java.util.WeakHashMap; +import java.util.concurrent.CopyOnWriteArraySet; import java.util.logging.Level; import java.util.logging.Logger; @@ -103,6 +105,8 @@ public final class ReconnectionManager { return enabledPerDefault; } + private final Settrue
if the listener was not already added
+ * @since 4.2.2
+ */
+ public boolean addReconnectionListener(ReconnectionListener listener) {
+ return reconnectionListeners.add(listener);
+ }
+
+ /**
+ * Remove a reconnection listener.
+ * @param listener the listener to remove
+ * @return true
if the listener was active and got removed.
+ * @since 4.2.2
+ */
+ public boolean removeReconnectionListener(ReconnectionListener listener) {
+ return reconnectionListeners.remove(listener);
+ }
+
/**
* Set the fixed delay in seconds between the reconnection attempts Also set the connection
* policy to {@link ReconnectionPolicy#FIXED_DELAY}.
@@ -208,6 +233,7 @@ public final class ReconnectionManager {
/**
* The process will try the reconnection until the connection succeed or the user cancel it
*/
+ @SuppressWarnings("deprecation")
@Override
public void run() {
final AbstractXMPPConnection connection = weakRefConnection.get();
@@ -233,6 +259,9 @@ public final class ReconnectionManager {
try {
Thread.sleep(1000);
remainingSeconds--;
+ for (ReconnectionListener listener : reconnectionListeners) {
+ listener.reconnectingIn(remainingSeconds);
+ }
for (ConnectionListener listener : connection.connectionListeners) {
listener.reconnectingIn(remainingSeconds);
}
@@ -244,6 +273,9 @@ public final class ReconnectionManager {
}
}
+ for (ReconnectionListener listener : reconnectionListeners) {
+ listener.reconnectingIn(0);
+ }
for (ConnectionListener listener : connection.connectionListeners) {
listener.reconnectingIn(0);
}
@@ -269,6 +301,9 @@ public final class ReconnectionManager {
}
catch (SmackException | IOException | XMPPException e) {
// Fires the failed reconnection notification
+ for (ReconnectionListener listener : reconnectionListeners) {
+ listener.reconnectionFailed(e);
+ }
for (ConnectionListener listener : connection.connectionListeners) {
listener.reconnectionFailed(e);
}
diff --git a/smack-core/src/main/java/org/jivesoftware/smack/debugger/AbstractDebugger.java b/smack-core/src/main/java/org/jivesoftware/smack/debugger/AbstractDebugger.java
index 62ebeb959..a345a7228 100644
--- a/smack-core/src/main/java/org/jivesoftware/smack/debugger/AbstractDebugger.java
+++ b/smack-core/src/main/java/org/jivesoftware/smack/debugger/AbstractDebugger.java
@@ -18,8 +18,13 @@ package org.jivesoftware.smack.debugger;
import java.io.Reader;
import java.io.Writer;
+import java.util.logging.Logger;
+import org.jivesoftware.smack.AbstractConnectionListener;
+import org.jivesoftware.smack.AbstractXMPPConnection;
import org.jivesoftware.smack.ConnectionListener;
+import org.jivesoftware.smack.ReconnectionListener;
+import org.jivesoftware.smack.ReconnectionManager;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.packet.TopLevelStreamElement;
import org.jivesoftware.smack.util.ObservableReader;
@@ -31,9 +36,12 @@ import org.jxmpp.jid.EntityFullJid;
public abstract class AbstractDebugger extends SmackDebugger {
+ private static final Logger LOGGER = Logger.getLogger(AbstractDebugger.class.getName());
+
public static boolean printInterpreted = false;
private final ConnectionListener connListener;
+ private final ReconnectionListener reconnectionListener;
private final ReaderListener readerListener;
private final WriterListener writerListener;
@@ -63,7 +71,7 @@ public abstract class AbstractDebugger extends SmackDebugger {
};
this.writer.addWriterListener(writerListener);
- connListener = new ConnectionListener() {
+ connListener = new AbstractConnectionListener() {
@Override
public void connected(XMPPConnection connection) {
log("XMPPConnection connected ("
@@ -92,6 +100,9 @@ public abstract class AbstractDebugger extends SmackDebugger {
connection +
")", e);
}
+ };
+
+ reconnectionListener = new ReconnectionListener() {
@Override
public void reconnectionFailed(Exception e) {
log(
@@ -100,13 +111,6 @@ public abstract class AbstractDebugger extends SmackDebugger {
")", e);
}
@Override
- public void reconnectionSuccessful() {
- log(
- "XMPPConnection reconnected (" +
- connection +
- ")");
- }
- @Override
public void reconnectingIn(int seconds) {
log(
"XMPPConnection (" +
@@ -114,6 +118,14 @@ public abstract class AbstractDebugger extends SmackDebugger {
") will reconnect in " + seconds);
}
};
+
+ if (connection instanceof AbstractXMPPConnection) {
+ AbstractXMPPConnection abstractXmppConnection = (AbstractXMPPConnection) connection;
+ ReconnectionManager.getInstanceFor(abstractXmppConnection).addReconnectionListener(reconnectionListener);
+ } else {
+ LOGGER.info("The connection instance " + connection
+ + " is not an instance of AbstractXMPPConnection, thus we can not install the ReconnectionListener");
+ }
}
protected abstract void log(String logMessage);
diff --git a/smack-core/src/test/java/org/jivesoftware/smack/DummyConnection.java b/smack-core/src/test/java/org/jivesoftware/smack/DummyConnection.java
index b871b27cb..e5351835e 100644
--- a/smack-core/src/test/java/org/jivesoftware/smack/DummyConnection.java
+++ b/smack-core/src/test/java/org/jivesoftware/smack/DummyConnection.java
@@ -88,6 +88,7 @@ public class DummyConnection extends AbstractXMPPConnection {
user = getUserJid();
}
+ @SuppressWarnings("deprecation")
@Override
protected void connectInternal() {
connected = true;
@@ -95,6 +96,7 @@ public class DummyConnection extends AbstractXMPPConnection {
tlsHandled.reportSuccess();
streamId = "dummy-" + new Random(new Date().getTime()).nextInt();
+ // TODO: Remove in Smack 4.3, and likely the suppression of the deprecation warning.
if (reconnect) {
notifyReconnection();
}
diff --git a/smack-debug-slf4j/src/main/java/org/jivesoftware/smackx/debugger/slf4j/SLF4JLoggingConnectionListener.java b/smack-debug-slf4j/src/main/java/org/jivesoftware/smackx/debugger/slf4j/SLF4JLoggingConnectionListener.java
index 61ea3a9d9..a6e0a41cb 100644
--- a/smack-debug-slf4j/src/main/java/org/jivesoftware/smackx/debugger/slf4j/SLF4JLoggingConnectionListener.java
+++ b/smack-debug-slf4j/src/main/java/org/jivesoftware/smackx/debugger/slf4j/SLF4JLoggingConnectionListener.java
@@ -17,12 +17,15 @@
package org.jivesoftware.smackx.debugger.slf4j;
-import org.jivesoftware.smack.ConnectionListener;
+import org.jivesoftware.smack.AbstractConnectionListener;
+import org.jivesoftware.smack.ReconnectionListener;
import org.jivesoftware.smack.XMPPConnection;
import org.slf4j.Logger;
-class SLF4JLoggingConnectionListener implements ConnectionListener {
+// TODO: The suppression of deprecated API can be removed in Smack 4.3.
+@SuppressWarnings("deprecation")
+class SLF4JLoggingConnectionListener extends AbstractConnectionListener implements ReconnectionListener {
private final XMPPConnection connection;
private final Logger logger;
@@ -56,11 +59,6 @@ class SLF4JLoggingConnectionListener implements ConnectionListener {
logger.debug("({}) Reconnection failed due to an exception: {}", connection.hashCode(), e);
}
- @Override
- public void reconnectionSuccessful() {
- logger.debug("({}) Connection reconnected", connection.hashCode());
- }
-
@Override
public void reconnectingIn(int seconds) {
logger.debug("({}) Connection will reconnect in {}", connection.hashCode(), seconds);
diff --git a/smack-debug-slf4j/src/main/java/org/jivesoftware/smackx/debugger/slf4j/SLF4JSmackDebugger.java b/smack-debug-slf4j/src/main/java/org/jivesoftware/smackx/debugger/slf4j/SLF4JSmackDebugger.java
index 7b10b38dd..83b15aadf 100644
--- a/smack-debug-slf4j/src/main/java/org/jivesoftware/smackx/debugger/slf4j/SLF4JSmackDebugger.java
+++ b/smack-debug-slf4j/src/main/java/org/jivesoftware/smackx/debugger/slf4j/SLF4JSmackDebugger.java
@@ -21,6 +21,8 @@ import java.io.Reader;
import java.io.Writer;
import java.util.concurrent.atomic.AtomicBoolean;
+import org.jivesoftware.smack.AbstractXMPPConnection;
+import org.jivesoftware.smack.ReconnectionManager;
import org.jivesoftware.smack.SmackConfiguration;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.debugger.SmackDebugger;
@@ -40,6 +42,8 @@ import org.slf4j.LoggerFactory;
*/
public class SLF4JSmackDebugger extends SmackDebugger {
+ private static final java.util.logging.Logger LOGGER = java.util.logging.Logger.getLogger(SLF4JSmackDebugger.class.getName());
+
public static final String LOGGER_NAME = "SMACK";
private static final Logger logger = LoggerFactory.getLogger(LOGGER_NAME);
public static final AtomicBoolean printInterpreted = new AtomicBoolean(true);
@@ -70,7 +74,17 @@ public class SLF4JSmackDebugger extends SmackDebugger {
this.writer.addWriterListener(slf4JRawXmlListener);
this.reader = new ObservableReader(Validate.notNull(reader));
this.reader.addReaderListener(slf4JRawXmlListener);
- this.connection.addConnectionListener(new SLF4JLoggingConnectionListener(connection, logger));
+
+ final SLF4JLoggingConnectionListener loggingConnectionListener = new SLF4JLoggingConnectionListener(connection, logger);
+ this.connection.addConnectionListener(loggingConnectionListener);
+
+ if (connection instanceof AbstractXMPPConnection) {
+ AbstractXMPPConnection abstractXmppConnection = (AbstractXMPPConnection) connection;
+ ReconnectionManager.getInstanceFor(abstractXmppConnection).addReconnectionListener(loggingConnectionListener);
+ } else {
+ LOGGER.info("The connection instance " + connection
+ + " is not an instance of AbstractXMPPConnection, thus we can not install the ReconnectionListener");
+ }
}
@Override
diff --git a/smack-debug/src/main/java/org/jivesoftware/smackx/debugger/EnhancedDebugger.java b/smack-debug/src/main/java/org/jivesoftware/smackx/debugger/EnhancedDebugger.java
index b8982a583..fe5446e94 100644
--- a/smack-debug/src/main/java/org/jivesoftware/smackx/debugger/EnhancedDebugger.java
+++ b/smack-debug/src/main/java/org/jivesoftware/smackx/debugger/EnhancedDebugger.java
@@ -61,7 +61,10 @@ import javax.swing.table.DefaultTableModel;
import javax.swing.text.BadLocationException;
import org.jivesoftware.smack.AbstractConnectionListener;
+import org.jivesoftware.smack.AbstractXMPPConnection;
import org.jivesoftware.smack.ConnectionListener;
+import org.jivesoftware.smack.ReconnectionListener;
+import org.jivesoftware.smack.ReconnectionManager;
import org.jivesoftware.smack.SmackException.NotConnectedException;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.debugger.SmackDebugger;
@@ -143,6 +146,7 @@ public class EnhancedDebugger extends SmackDebugger {
private JFormattedTextField statusField = null;
private ConnectionListener connListener = null;
+ private final ReconnectionListener reconnectionListener;
private Writer writer;
private Reader reader;
@@ -169,6 +173,36 @@ public class EnhancedDebugger extends SmackDebugger {
public EnhancedDebugger(XMPPConnection connection) {
super(connection);
+ reconnectionListener = new ReconnectionListener() {
+ @Override
+ public void reconnectingIn(final int seconds) {
+ SwingUtilities.invokeLater(new Runnable() {
+ @Override
+ public void run() {
+ statusField.setValue("Attempt to reconnect in " + seconds + " seconds");
+ }
+ });
+ }
+
+ @Override
+ public void reconnectionFailed(Exception e) {
+ SwingUtilities.invokeLater(new Runnable() {
+ @Override
+ public void run() {
+ statusField.setValue("Reconnection failed");
+ }
+ });
+ }
+ };
+
+ if (connection instanceof AbstractXMPPConnection) {
+ AbstractXMPPConnection abstractXmppConnection = (AbstractXMPPConnection) connection;
+ ReconnectionManager.getInstanceFor(abstractXmppConnection).addReconnectionListener(reconnectionListener);
+ } else {
+ LOGGER.info("The connection instance " + connection
+ + " is not an instance of AbstractXMPPConnection, thus we can not install the ReconnectionListener");
+ }
+
// We'll arrange the UI into six tabs. The first tab contains all data, the second
// client generated XML, the third server generated XML, the fourth allows to send
// ad-hoc messages and the fifth contains connection information.
@@ -208,36 +242,6 @@ public class EnhancedDebugger extends SmackDebugger {
});
}
- @Override
- public void reconnectingIn(final int seconds) {
- SwingUtilities.invokeLater(new Runnable() {
- @Override
- public void run() {
- statusField.setValue("Attempt to reconnect in " + seconds + " seconds");
- }
- });
- }
-
- @Override
- public void reconnectionSuccessful() {
- SwingUtilities.invokeLater(new Runnable() {
- @Override
- public void run() {
- statusField.setValue("Reconnection stablished");
- EnhancedDebuggerWindow.connectionEstablished(EnhancedDebugger.this);
- }
- });
- }
-
- @Override
- public void reconnectionFailed(Exception e) {
- SwingUtilities.invokeLater(new Runnable() {
- @Override
- public void run() {
- statusField.setValue("Reconnection failed");
- }
- });
- }
};
EnhancedDebuggerWindow.addDebugger(this);
diff --git a/smack-extensions/src/main/java/org/jivesoftware/smackx/bytestreams/ibb/InBandBytestreamManager.java b/smack-extensions/src/main/java/org/jivesoftware/smackx/bytestreams/ibb/InBandBytestreamManager.java
index 3b0be019c..a4e956c25 100644
--- a/smack-extensions/src/main/java/org/jivesoftware/smackx/bytestreams/ibb/InBandBytestreamManager.java
+++ b/smack-extensions/src/main/java/org/jivesoftware/smackx/bytestreams/ibb/InBandBytestreamManager.java
@@ -120,8 +120,7 @@ public final class InBandBytestreamManager extends Manager implements Bytestream
}
@Override
- public void reconnectionSuccessful() {
- // re-create the manager for this connection
+ public void connected(XMPPConnection connection) {
InBandBytestreamManager.getByteStreamManager(connection);
}
diff --git a/smack-extensions/src/main/java/org/jivesoftware/smackx/jingle/transports/JingleTransportManager.java b/smack-extensions/src/main/java/org/jivesoftware/smackx/jingle/transports/JingleTransportManager.java
index 75d8797b0..96fd3b54a 100644
--- a/smack-extensions/src/main/java/org/jivesoftware/smackx/jingle/transports/JingleTransportManager.java
+++ b/smack-extensions/src/main/java/org/jivesoftware/smackx/jingle/transports/JingleTransportManager.java
@@ -16,7 +16,7 @@
*/
package org.jivesoftware.smackx.jingle.transports;
-import org.jivesoftware.smack.ConnectionListener;
+import org.jivesoftware.smack.AbstractConnectionListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smackx.jingle.JingleSession;
import org.jivesoftware.smackx.jingle.element.JingleContentTransport;
@@ -25,7 +25,7 @@ import org.jivesoftware.smackx.jingle.element.JingleContentTransport;
* Manager for a JingleTransport method.
* @param