Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1687 added connection validation and reconnect logic for outbound XMPP adapters, added ConnectionListener to the XMPPConnection to log (DEBUG level) connection events

Browse Source
This commit is contained in:
Oleg Zhurakousky
2010-12-16 12:47:25 -05:00
parent 6d07e51bb0
commit 424d48f145
3 changed files with 29 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
spring-integration-xmpp/src/main/java/org/springframework/integration/xmpp/config/XmppConnectionFactoryBean.java
View File

@@ -17,6 +17,7 @@
package org.springframework.integration.xmpp.config;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.ConnectionListener;
import org.jivesoftware.smack.Roster;
import org.jivesoftware.smack.XMPPConnection;
import org.springframework.beans.factory.BeanInitializationException;
@@ -96,6 +97,28 @@ public class XmppConnectionFactoryBean extends AbstractFactoryBean<XMPPConnectio
public void start() {
try {
connection.connect();
connection.addConnectionListener(new ConnectionListener() {
public void reconnectionSuccessful() {
logger.debug("Reconnection is successfull");
}
public void reconnectionFailed(Exception e) {
logger.debug("Reconnection failed", e);
}
public void reconnectingIn(int seconds) {
logger.debug("Reconnecting in " + seconds + " seconds");
}
public void connectionClosedOnError(Exception e) {
logger.debug("Connection closed", e);
}
public void connectionClosed() {
logger.debug("Connection closed");
}
});
if (StringUtils.hasText(user)){
connection.login(user, password, resource);
Assert.isTrue(connection.isAuthenticated(), "Failed to authenticate user: " + user);

3
spring-integration-xmpp/src/main/java/org/springframework/integration/xmpp/outbound/ChatMessageSendingMessageHandler.java
View File

@@ -68,6 +68,9 @@ public class ChatMessageSendingMessageHandler extends AbstractXmppConnectionAwar
"are suported. Was '" + messageBody.getClass().getName() +
"' Consider adding a transformer prior to sending message to this handler");
}
if (!this.xmppConnection.isConnected()){
this.xmppConnection.connect();
}
this.xmppConnection.sendPacket(xmppMessage);
}
}

3
spring-integration-xmpp/src/main/java/org/springframework/integration/xmpp/outbound/PresenceSendingMessageHandler.java
View File

@@ -46,6 +46,9 @@ public class PresenceSendingMessageHandler extends AbstractXmppConnectionAwareMe
Object payload = message.getPayload();
Assert.isInstanceOf(Presence.class, payload, "'payload' must be of type 'org.jivesoftware.smack.packet.Presence', was: "
+ payload.getClass().getName());
if (!this.xmppConnection.isConnected()){
this.xmppConnection.connect();
}
this.xmppConnection.sendPacket((Presence)payload);
}