Skip to content

Commit a3e1d58

Browse files
committed
Pave the way for DNS discovery
1 parent e4eb312 commit a3e1d58

2 files changed

Lines changed: 17 additions & 5 deletions

File tree

pom.xml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,11 @@
1010
<url>https://github.com/buddycloud/buddycloud-server-java</url>
1111
</scm>
1212
<dependencies>
13+
<dependency>
14+
<groupId>dnsjava</groupId>
15+
<artifactId>dnsjava</artifactId>
16+
<version>2.1.1</version>
17+
</dependency>
1318
<dependency>
1419
<groupId>junit</groupId>
1520
<artifactId>junit</artifactId>

src/main/java/org/buddycloud/channelserver/queue/FederatedQueueManager.java

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import org.xmpp.packet.JID;
2020
import org.xmpp.packet.Packet;
2121
import org.xmpp.packet.PacketError;
22+
import org.xbill.DNS.*;
2223

2324
public class FederatedQueueManager {
2425
private static final Logger logger = Logger
@@ -199,19 +200,25 @@ public void processDiscoInfoResponse(JID from, String id,
199200
sendFederatedRequests(originatingServer);
200201
}
201202
}
202-
203+
203204
if (remoteServerItemsToProcess.get(originatingServer) < 1) {
204205
if (!discoveredServers.containsKey(originatingServer)) {
205-
sendRemoteChannelServerNotFoundErrorResponses(originatingServer);
206-
remoteChannelDiscoveryStatus.put(originatingServer,
207-
NO_CHANNEL_SERVER);
208-
waitingStanzas.remove(originatingServer);
206+
if (false == attemptDnsDiscovery(originatingServer)) {
207+
sendRemoteChannelServerNotFoundErrorResponses(originatingServer);
208+
remoteChannelDiscoveryStatus.put(originatingServer,
209+
NO_CHANNEL_SERVER);
210+
waitingStanzas.remove(originatingServer);
211+
}
209212
} else {
210213
remoteChannelDiscoveryStatus.put(originatingServer, DISCOVERED);
211214
}
212215
}
213216
}
214217

218+
private void attemptDnsDiscovery(String originatingServer) {
219+
return false;
220+
}
221+
215222
private void sendFederatedRequests(String originatingServer)
216223
throws ComponentException {
217224
String remoteServer = discoveredServers.get(originatingServer);

0 commit comments

Comments
 (0)