Commit 056c6041 by Adi Amir

complete debuggibng of server side + increase version

parent 6fbbf406
group 'com.ipgallery.common' group 'com.ipgallery.common'
version '1.0.x' version '1.0.2'
apply plugin: 'java' apply plugin: 'java'
apply plugin: 'maven-publish' apply plugin: 'maven-publish'
...@@ -15,7 +15,7 @@ dependencies { ...@@ -15,7 +15,7 @@ dependencies {
//compile 'com.google.gdata:core:1.47.1:core-1.47.1' //compile 'com.google.gdata:core:1.47.1:core-1.47.1'
compile 'com.rabbitmq:amqp-client:3.6.3' //'com.rabbitmq:rabbitmq-client:1.3.0' compile 'com.rabbitmq:amqp-client:3.6.3' //'com.rabbitmq:rabbitmq-client:1.3.0'
compile 'com.fasterxml.jackson.core:jackson-databind:2.2.3' compile 'com.fasterxml.jackson.core:jackson-databind:2.2.3'
compile 'com.ipgallery.common:utils:1.1.2' compile 'com.ipgallery.common:utils:1.1.3'
compile 'com.ipgallery.common:itc:1.0.0' compile 'com.ipgallery.common:itc:1.0.0'
testCompile group: 'junit', name: 'junit', version: '4.11' testCompile group: 'junit', name: 'junit', version: '4.11'
} }
......
...@@ -85,19 +85,19 @@ public class RMQServer extends ITMManager { ...@@ -85,19 +85,19 @@ public class RMQServer extends ITMManager {
try { try {
// empty queue on init if configured to do so // empty queue on init if configured to do so
boolean isEmptyQueueOnLoad = false; // boolean isEmptyQueueOnLoad = false;
String strEmptyQueueOnLoad = System.getProperty("rmqServer.emptyQueueOnLoad"); // String strEmptyQueueOnLoad = System.getProperty("rmqServer.emptyQueueOnLoad");
if (strEmptyQueueOnLoad == null) { // if (strEmptyQueueOnLoad == null) {
logSevere("RMQServer::InitListenQ", "failed to read 'EmptyQueueOnLoad' from config file", null); // logSevere("RMQServer::InitListenQ", "failed to read 'EmptyQueueOnLoad' from config file", null);
return false; // return false;
} // }
isEmptyQueueOnLoad = Boolean.parseBoolean(strEmptyQueueOnLoad); // isEmptyQueueOnLoad = Boolean.parseBoolean(strEmptyQueueOnLoad);
// create the queue // create the queue
mRMQReciever = new RMQReciever(listenRMQId.getQueue(), listenRMQId.getHost()); mRMQReciever = new RMQReciever(listenRMQId.getQueue(), listenRMQId.getHost());
if (isEmptyQueueOnLoad) { // if (isEmptyQueueOnLoad) {
mRMQReciever.purge(); // mRMQReciever.purge();
} // }
logger.log(Level.INFO, "Connected successfully to: " + listenRMQId.getDescriptor()); logger.log(Level.INFO, "Connected successfully to: " + listenRMQId.getDescriptor());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment