Commit 98bf09bf authored by Shrikant Garg's avatar Shrikant Garg
Browse files

Merge branch 'records-copy-ibm' into 'master'

For records copy test

See merge request !33
parents a430a0eb e107fd89
Pipeline #70707 failed with stages
in 5 minutes and 34 seconds
......@@ -45,7 +45,7 @@ public class ActiveMQFactory implements IMessageFactory {
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
for (String queue : Arrays.asList(INDEXER_QUEUE_NAME, LEGAL_QUEUE_NAME, DEFAULT_QUEUE_NAME)) {
for (String queue : Arrays.asList(INDEXER_QUEUE_NAME, LEGAL_QUEUE_NAME, DEFAULT_QUEUE_NAME, DEFAULT_QUEUE_COPY_NAME)) {
session.createQueue(prefix + "-" + queue);
logger.debug("Queue [" + prefix + "-" + queue + "] declared");
}
......@@ -61,6 +61,7 @@ public class ActiveMQFactory implements IMessageFactory {
@Override
public void sendMessage(String msg) {
sendMessage(DEFAULT_QUEUE_NAME, msg, -1L);
sendMessage(DEFAULT_QUEUE_COPY_NAME, msg, -1L); // For WKE
}
@Override
......
......@@ -8,6 +8,7 @@ public interface IMessageFactory {
public final static String DEFAULT_QUEUE_NAME = "records";
public final static String LEGAL_QUEUE_NAME = "legal";
public final static String INDEXER_QUEUE_NAME = "indexer";
public final static String DEFAULT_QUEUE_COPY_NAME = "reocrds-copy";
public final static String DLQ_QUEUE_NAME = "DLQ";
public final static String RECORDS_CHANGED_QUEUE_NAME="records-changed";
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment