Подключение к Marklogic с помощью модуля EJB

Question

Я пытаюсь подключиться к marklogic, используя java-api-клиент из java в EMB, как показано ниже. Я создал в netbeans проект Maven EJB Module и добавил зависимость marklogic к pom.

<dependency> 
     <groupId>com.marklogic</groupId> 
     <artifactId>java-client-api</artifactId> 
     <version>3.0.1</version> 
    </dependency> 



    package com.xx.yy; 
    import java.io.IOException; 
    import java.util.concurrent.atomic.AtomicLong; 
    import javax.ejb.ActivationConfigProperty; 
    import javax.ejb.MessageDriven; 
    import javax.jms.JMSException; 
    import javax.jms.Message; 
    import javax.jms.MessageListener; 
    import javax.jms.TextMessage; 
    import javax.xml.xpath.XPathExpressionException; 


    @MessageDriven(activationConfig = { 
     @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"), 
     @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "jms/MyTopic"), 
     @ActivationConfigProperty(propertyName = "subscriptionDurability", propertyValue = "Durable"), 
     @ActivationConfigProperty(propertyName = "clientId", propertyValue = "jms/MyTopic"), 
     @ActivationConfigProperty(propertyName = "subscriptionName", propertyValue = "jms/MyTopic") 
    }) 
    public class CreateBlock implements MessageListener { 

     AtomicLong count = new AtomicLong(0); 

     public CreateBlock() { 
     } 

     @Override 
     public void onMessage(Message m){ 
      long i; 

      try { 
       if (m instanceof TextMessage) { 
        i = count.incrementAndGet(); 

        System.out.println("Reading message: " + m.getBody(String.class)); 
        GenerateBlock.createblock(m.getBody(String.class)); 

       } else { 
        System.err.println("Message is not a TextMessage"); 
       } 
      } catch (JMSException e) { 
       System.err.println("JMSException in onMessage(): " + e.toString()); 
      } 
      catch (IOException e){ 
       System.err.println("IOException in onMessage(): " + e.toString()); 
      } 
      catch (XPathExpressionException e){ 
        System.err.println("XPathExpressionException in onMessage(): " + e.toString()); 

      } 
     } 
} 

, который выполняет следующие ,,, только некоторый код из Java API клиента поваренной книги, чтобы подтвердить я могу читать из базы данных

package com.xx.yy; 
import java.io.IOException; 
import javax.xml.xpath.XPathExpressionException; 
import org.w3c.dom.Document; 

import com.marklogic.client.DatabaseClient; 
import com.marklogic.client.DatabaseClientFactory; 
import com.marklogic.client.document.XMLDocumentManager; 
import com.marklogic.client.DatabaseClientFactory.Authentication; 


public class GenerateBlock { 


    public static void createblock(String docId) throws IOException, XPathExpressionException { 


     DatabaseClient client = DatabaseClientFactory.newClient(
        "domain.com", 8012, "dbname", "admin", "password", 
        Authentication.valueOf("DIGEST")); 

     XMLDocumentManager docMgr = client.newXMLDocumentManager(); 
     docMgr.setForestName("forestname"); 

     // read the document content 
     Document document = docMgr.readAs(docId, Document.class); 

     // access the document content 
     String rootName = document.getDocumentElement().getTagName(); 
     System.out.println("(Shortcut) Read " + docId + " content with the <" + rootName + "/> root element"); 
     client.release(); 
    } 

} 

однако, когда код выполняется, как получено сообщение JMS, следующие исключения происходят

** 

Info: MQJMSRA_MR1101: run:Message returned & marked for routing to the DMQ 
    Warning: MDB00037: [StoneManBuilder:CreateBlock]: Message-driven bean invocation exception: [javax.ejb.EJBException]  
    Warning: javax.ejb.EJBException 
    javax.ejb.EJBException 
    at com.sun.ejb.containers.EJBContainerTransactionManager.processSystemException(EJBContainerTransactionManager.java:750) 
    at com.sun.ejb.containers.EJBContainerTransactionManager.completeNewTx(EJBContainerTransactionManager.java:700) 
    at com.sun.ejb.containers.EJBContainerTransactionManager.postInvokeTx(EJBContainerTransactionManager.java:505) 
    at com.sun.ejb.containers.BaseContainer.postInvokeTx(BaseContainer.java:4566) 
    at org.glassfish.ejb.mdb.MessageBeanContainer.afterMessageDeliveryInternal(MessageBeanContainer.java:1326) 
    at org.glassfish.ejb.mdb.MessageBeanContainer.afterMessageDelivery(MessageBeanContainer.java:1301) 
    at org.glassfish.ejb.mdb.MessageBeanListenerImpl.afterMessageDelivery(MessageBeanListenerImpl.java:86) 
    at com.sun.enterprise.connectors.inbound.MessageEndpointInvocationHandler.invoke(MessageEndpointInvocationHandler.java:143) 
    at com.sun.proxy.$Proxy348.afterDelivery(Unknown Source) 
    at com.sun.messaging.jms.ra.OnMessageRunner.run(OnMessageRunner.java:361) 
    at com.sun.enterprise.connectors.work.OneWork.doWork(OneWork.java:107) 
    at com.sun.corba.ee.impl.threadpool.ThreadPoolImpl$WorkerThread.performWork(ThreadPoolImpl.java:497) 
    at com.sun.corba.ee.impl.threadpool.ThreadPoolImpl$WorkerThread.run(ThreadPoolImpl.java:540) 
    Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.marklogic.client.DatabaseClientFactory 
    at com.kode100.stonemanbuilder.GenerateBlock.createblock(GenerateBlock.java:31) 
    at com.kode100.stonemanbuilder.CreateBlock.onMessage(CreateBlock.java:45) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:606) 
    at org.glassfish.ejb.security.application.EJBSecurityManager.runMethod(EJBSecurityManager.java:1081) 
    at org.glassfish.ejb.security.application.EJBSecurityManager.invoke(EJBSecurityManager.java:1153) 
    at com.sun.ejb.containers.BaseContainer.invokeBeanMethod(BaseContainer.java:4786) 
    at com.sun.ejb.EjbInvocation.invokeBeanMethod(EjbInvocation.java:656) 
    at com.sun.ejb.containers.interceptors.AroundInvokeChainImpl.invokeNext(InterceptorManager.java:822) 
    at com.sun.ejb.EjbInvocation.proceed(EjbInvocation.java:608) 
    at org.jboss.weld.ejb.AbstractEJBRequestScopeActivationInterceptor.aroundInvoke(AbstractEJBRequestScopeActivationInterceptor.java:73) 
    at org.jboss.weld.ejb.SessionBeanInterceptor.aroundInvoke(SessionBeanInterceptor.java:52) 
    at sun.reflect.GeneratedMethodAccessor196.invoke(Unknown Source) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:606) 
    at com.sun.ejb.containers.interceptors.AroundInvokeInterceptor.intercept(InterceptorManager.java:883) 
    at com.sun.ejb.containers.interceptors.AroundInvokeChainImpl.invokeNext(InterceptorManager.java:822) 
    at com.sun.ejb.containers.interceptors.InterceptorManager.intercept(InterceptorManager.java:369) 
    at com.sun.ejb.containers.BaseContainer.__intercept(BaseContainer.java:4758) 
    at com.sun.ejb.containers.BaseContainer.intercept(BaseContainer.java:4746) 
    at org.glassfish.ejb.mdb.MessageBeanContainer.deliverMessage(MessageBeanContainer.java:1219) 
    at org.glassfish.ejb.mdb.MessageBeanListenerImpl.deliverMessage(MessageBeanListenerImpl.java:81) 
    at com.sun.enterprise.connectors.inbound.MessageEndpointInvocationHandler.invoke(MessageEndpointInvocationHandler.java:171) 
    at com.sun.proxy.$Proxy348.onMessage(Unknown Source) 
    at com.sun.messaging.jms.ra.OnMessageRunner.run(OnMessageRunner.java:283) 
    ... 3 more 

**

Я могу подключиться к да tabase с тем же кодом соединения и параметрами из приложения JSF, которое загружает файлы в базу данных. Затем он освобождает клиента и вызывает вышеуказанный код с помощью JMS, чтобы в итоге сделать больше обработки данных, чтения и записи в marklogic.

Должен ли я использовать проект другого типа для работы с marklogic с помощью JMS или что-то не так с моим кодом?

С уважением Конт

Answer 1

Учитывая, что ошибка ядра:

Caused by: java.lang.NoClassDefFoundError: Could not initialize class com.marklogic.client.DatabaseClientFactory 

вы можете иметь проблемы окружающей среды вместо выдачи коды - в частности, проблема с созданием баночки MarkLogic доступна загрузчик классов EJB.

В производственном коде, кстати, вы хотели бы создать клиента один раз и использовать его повторно для всех запросов на одном и том же хосте вместо создания нового клиента для каждого запроса.

Каждый рецепт поваренной книги стоит один, поэтому у них нет одного и того же клиента базы данных.

Надеясь, что помогает,