Clustering using ActiveMQ and Tomcat

George Christman <[email protected]>
Newsgroups gmane.comp.java.tapestry.user
Message-ID <CADYqYfmtLu_dA-2uMUYi=2MT22e2=9QvYBYr2yFE9x-y1OKngg@mail.gmail.com>
Hi Guys, I'm working with an older 5.4 application at work that I built a
few years back with Hibernate-Search. Recently management wanted to start
load balancing the app on our own network. This would require replication
and synchronization of the indexes using a master / slave configuration.

Hibernate Search doc shows there examples being used with JBOSS, we do use
tomcat, so I would be required to do some additional work on my end. Doc.
https://docs.jboss.org/hibernate/search/4.5/reference/en-US/html/search-configuration.html#jms-backend

I ran across these two articles.

https://forum.hibernate.org/viewtopic.php?p=2422173

and

https://developer.jboss.org/wiki/ClusteringUsingActiveMQAndTomcat

I'm struggling to understand how to implement the subclass of
AbstractJMSHibernateSearchController in the master application and register
it into the listener queue. Could someone please provide some pointers.?

"

Last step is to implement a subclass of
*AbstractJMSHibernateSearchController* in the master application. This
class has to register itself as listener to the queue. The code could look
somewhat like this:

   1.                 Context initCtx = new InitialContext();
   2.
   3.
   // Look up for connection factory & create connection, session
   4.
                   ConnectionFactory connectionFactory =
(ConnectionFactory) initCtx.lookup(
   "java:comp/env/jms/ConnectionFactory");
   5.                 connection = connectionFactory.createConnection();
   6.                 connection.start();
   7.                 javax.jms.Session session = connection.createSession(
   true, 0);
   8.
   9.                 // Look up for destination and set listner
   10.                 Queue queue = (Queue) initCtx.lookup(
   "java:comp/env/queue/hibernatesearch");
   11.
                   MessageConsumer consumer = session.createConsumer(queue);
   12.                 consumer.setMessageListener(this);

"

-- 
George Christman
Senior Engineer
www.CarDaddy.com
lmpx.com only provides a reader for public news (NNTP) servers. It is not affiliated with the servers or forums shown here and is not responsible for the content of articles, which is written by their respective authors.