eclipse-sailing-analytics/sailing-analytics
1
0 Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-10-11 06:40:53 +00:00
Code Activity

Fixed consumer channel selection and added better exception logging

Browse Source
This commit is contained in:
Simon Pamies committed 2013-06-19 18:52:10 +02:00
1 parent 4539a19cb0
commit b23ae0defb
2 files changed
+10 -2
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

java/com.sap.sailing.server.replication/src/com/sap/sailing/server/replication/impl/ReplicationMasterDescriptorImpl.java
+1 -1
View File
@@ -48,7 +48,7 @@ public class ReplicationMasterDescriptorImpl implements ReplicationMasterDescrip
connectionFactory.setPort(port);
}
Connection connection = connectionFactory.newConnection();
Channel channel = connection.createChannel(0);
Channel channel = connection.createChannel();
channel.exchangeDeclare(exchangeName, "fanout");
QueueingConsumer consumer = new QueueingConsumer(channel);
String queueName = channel.queueDeclare().getQueue();
java/com.sap.sailing.server.replication/src/com/sap/sailing/server/replication/impl/ReplicationServiceImpl.java
+9 -1
View File
@@ -181,7 +181,15 @@ public class ReplicationServiceImpl implements ReplicationService, OperationExec
logger.info("Starting to replicate from "+master);
replicatingFromMaster = master;
registerReplicaWithMaster(master);
QueueingConsumer consumer = master.getConsumer();
logger.info("Registered replica with master");
QueueingConsumer consumer = null;
try {
consumer = master.getConsumer();
} catch (Exception ex) {
ex.printStackTrace();
throw ex;
}
logger.info("Connection to exchange successful.");
URL initialLoadURL = master.getInitialLoadURL();
logger.info("Initial load URL is "+initialLoadURL);
final Replicator replicator = new Replicator(master, this, /* startSuspended */ true, consumer);