Author: clebert.suconic(a)jboss.com
Date: 2011-08-11 20:05:39 -0400 (Thu, 11 Aug 2011)
New Revision: 11193
Modified:
branches/Branch_2_2_EAP/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/MessageServiceManager.java
Log:
fixing typo on code
Modified:
branches/Branch_2_2_EAP/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/MessageServiceManager.java
===================================================================
---
branches/Branch_2_2_EAP/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/MessageServiceManager.java 2011-08-11
23:19:56 UTC (rev 11192)
+++
branches/Branch_2_2_EAP/hornetq-rest/hornetq-rest/src/main/java/org/hornetq/rest/MessageServiceManager.java 2011-08-12
00:05:39 UTC (rev 11193)
@@ -33,7 +33,7 @@
{
protected ExecutorService threadPool;
protected QueueServiceManager queueManager = new QueueServiceManager();
- protected TopicServiceManager topicManager = new TopicServiceManager();
+ protected TopicServiceManager topicManager = new TopicServiceManager();
protected TimeoutTask timeoutTask;
protected int timeoutTaskInterval = 1;
protected MessageServiceConfiguration configuration = new
MessageServiceConfiguration();
@@ -178,7 +178,7 @@
queueManager.setLinkStrategy(linkStrategy);
queueManager.setRegistry(registry);
- queueManager.setServerLocator(defaultLocator);
+ topicManager.setServerLocator(defaultLocator);
topicManager.setSessionFactory(sessionFactory);
topicManager.setTimeoutTask(timeoutTask);
topicManager.setConsumerServerLocator(consumerLocator);
Show replies by date