Error: java.lang.UnsatisfiedLinkError: org.hornetq.core.asyncio.impl.AsynchronousFileImpl.init(Ljava/lang/String;ILorg/hornetq/core/logging/Logger;)Ljava/nio/ByteBuffer;

[karlicontrol]

I am getting an error when trying to run an in-vm broker for my unit tests.  I followed nearly exactly the example in the user manual.

I saw a similar message between developers but I don't understand what the solution is.  What do I need to do to successfully run this embedded server within my unit tests?  Thank you.

The code:

        Configuration config = new ConfigurationImpl();

        HashSet<TransportConfiguration> transports = new HashSet<TransportConfiguration>();
        transports.add(new TransportConfiguration(InVMAcceptorFactory.class.getName()));

        config.setAcceptorConfigurations(transports);
        HornetQServer server = new HornetQServerImpl(config);
        server.start();

Error is:

java.lang.UnsatisfiedLinkError: org.hornetq.core.asyncio.impl.AsynchronousFileImpl.init(Ljava/lang/String;ILorg/hornetq/core/logging/Logger;)Ljava/nio/ByteBuffer;
    at org.hornetq.core.asyncio.impl.AsynchronousFileImpl.init(Native Method)
    at org.hornetq.core.asyncio.impl.AsynchronousFileImpl.open(AsynchronousFileImpl.java:206)
    at org.hornetq.core.journal.impl.AIOSequentialFile.open(AIOSequentialFile.java:190)
    at org.hornetq.core.journal.impl.JournalImpl.createFile(JournalImpl.java:3037)
    at org.hornetq.core.journal.impl.JournalImpl.load(JournalImpl.java:2004)
    at org.hornetq.core.journal.impl.JournalImpl.load(JournalImpl.java:1374)
    at org.hornetq.core.persistence.impl.journal.JournalStorageManager.loadMessageJournal(JournalStorageManager.java:772)
    at org.hornetq.core.server.impl.HornetQServerImpl.loadJournals(HornetQServerImpl.java:1206)
    at org.hornetq.core.server.impl.HornetQServerImpl.initialisePart2(HornetQServerImpl.java:1056)
    at org.hornetq.core.server.impl.HornetQServerImpl.start(HornetQServerImpl.java:310)
    at com.mycompany.util.messaging.MessagingTest.setUp(MessagingTest.java:33)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:44)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:15)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:41)
    at org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:27)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:31)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:76)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:50)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:193)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:52)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:191)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:42)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:184)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:236)
    at org.junit.runner.JUnitCore.run(JUnitCore.java:157)
    at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:64)

[karlicontrol]

I tried setting the JournalType to NIO in the configuration programmatically and now get a different error.  Here is the change:

config.setJournalType(JournalType.NIO);

I ensured that my client has all of the libraries from HornetQ's /lib directory on its classpath.

java.lang.NoSuchMethodError: org.hornetq.core.server.ServerMessage.page(Z)Z
    at org.hornetq.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:609)
    at org.hornetq.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:538)
    at org.hornetq.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:533)
    at org.hornetq.core.server.management.impl.ManagementServiceImpl.sendNotification(ManagementServiceImpl.java:723)
    at org.hornetq.core.remoting.impl.invm.InVMAcceptor.start(InVMAcceptor.java:92)
    at org.hornetq.core.remoting.server.impl.RemotingServiceImpl.start(RemotingServiceImpl.java:226)
    at org.hornetq.core.server.impl.HornetQServerImpl.start(HornetQServerImpl.java:315)

[karlicontrol]

I got past the previous error -- it did indeed work after I set the journal type to NIO.

However, it is giving me a NullPointerException from within the security manager code (inside HornetQ).  I do not set a security manager set in any of the embedded examples -- what's wrong?

SEVERE: Failed to create session
java.lang.NullPointerException
    at org.hornetq.core.security.impl.SecurityStoreImpl.authenticate(SecurityStoreImpl.java:128)
    at org.hornetq.core.server.impl.HornetQServerImpl.createSession(HornetQServerImpl.java:576)
    at org.hornetq.core.protocol.core.impl.HornetQPacketHandler.handleCreateSession(HornetQPacketHandler.java:158)
    at org.hornetq.core.protocol.core.impl.HornetQPacketHandler.handlePacket(HornetQPacketHandler.java:84)
    at org.hornetq.core.protocol.core.impl.ChannelImpl.handlePacket(ChannelImpl.java:471)
    at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:451)
    at org.hornetq.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:412)
    at org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:459)
    at org.hornetq.core.remoting.impl.invm.InVMConnection$1.run(InVMConnection.java:135)
    at org.hornetq.utils.OrderedExecutorFactory$OrderedExecutor$1.run(OrderedExecutorFactory.java:100)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:680)

[clebert.suconic]

I - When you set the Configuration object, you need to set the journal type you want to use explicitly. You can check the AsynchronousfilImpl.isLoaded() before setting it. This is the logic we do on the server

II - That was a classpath versioning in your system.

III - you're setting up something wrong in your security manager. Look at the jms embedded example. Look at that example and you should be good to go. You may also provide some code here so we can understand what you're doing. (something up to 10 lines of code to how you're instantiating your server).

[karlicontrol]

Hey Clebert -- Yes you're right about #1 and #2.

Here is a section of code for the third thing -- I get the same error when using JMS and Core (I actually tried both), but here's a simple core test I used:

ClientSessionFactory sf = null;
        ClientSession coreSession = null;

        try {
            sf = HornetQClient.createClientSessionFactory(new TransportConfiguration(InVMConnectorFactory.class.getName()));
            coreSession = sf.createSession(false, false, false); //error thrown here
            coreSession.createQueue(name, name, false);
        }
        catch (HornetQException hqe) {
            throw makeJMS(hqe);
        }

[karlicontrol]

Incidentally, when I tried to specify the port for my "InVM", I'd get errors about the port being an illegal config setting, so I removed that config.

[karlicontrol]

Hey Clebert -- I didn't see how to do it in the JMS embedded example, but I saw that in the core example, it set security to false in the config.  I did that and it got me past the hurdle.  Thanks for the help.

I'm not using JNDI (maybe I should be), but I wonder if there is a way to avoid having to map my own configuration file for all of these settings (TTL, etc.):

ConnectionFactory cf = HornetQJMSClient.createConnectionFactory(transportConfiguration);

                HornetQConnectionFactory hqcf = (HornetQConnectionFactory) cf;
               
                hqcf.setBlockOnNonDurableSend(true);
                hqcf.setBlockOnDurableSend(true);
                hqcf.setPreAcknowledge(false);
                hqcf.setFailoverOnInitialConnection(false);
                hqcf.setRetryInterval(10000);
                hqcf.setConnectionTTL(300000);
                hqcf.setReconnectAttempts(-1);
                hqcf.setClientFailureCheckPeriod(120000);
                hqcf.setConsumerWindowSize(0);
                hqcf.setProducerWindowSize(-1);

Is there a way to just point the HornetQ client to a config file where it can get all of these settings?  Thanks.

[clebert.suconic]

Is there a way to just point the HornetQ client to a config file where it can get all of these settings?  Thanks.

Look at this post, it may be helpful for you:

http://community.jboss.org/thread/157628?tstart=30

This is exactly what this user did. It's just not productized yet. I am thinking about getting more integration stuff like this for 2.3. This user is using internal objects to read the XMLs and create the objects directly. Maybe that's what you need now.

[clebert.suconic]

BTW: I'm confused on what's still a problem for you.. you got a few message along the way and i'm not sure which ones you fixed and which ones you still looking for a solution.

[karlicontrol]

Hey Clebert,

Thanks very much for the help.  I am now past all of the issues I ran into earlier, with my automated tests running.

The next steps will be either formalizing the configs (like was done in the link you provided) and in running clustered servers for redundancy.

Happy Halloween!

Karl

[jgbaylon]

I'm stuck in this error. I already added this line

config.setJournalType(JournalType.NIO)

but I'm still getting

java.lang.NoSuchMethodError: org.hornetq.core.server.ServerMessage.page()Z

    at org.hornetq.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:607)

    at org.hornetq.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:536)

    at org.hornetq.core.postoffice.impl.PostOfficeImpl.route(PostOfficeImpl.java:531)

    at org.hornetq.core.server.management.impl.ManagementServiceImpl.sendNotification(ManagementServiceImpl.java:725)

    at org.hornetq.core.remoting.impl.invm.InVMAcceptor.start(InVMAcceptor.java:92)

    at org.hornetq.core.remoting.server.impl.RemotingServiceImpl.start(RemotingServiceImpl.java:226)

    at org.hornetq.core.server.impl.HornetQServerImpl.start(HornetQServerImpl.java:318)

How did your resolve this?

[clebert.suconic]

Versioning and classpath... you have different versions on the classpath. Version mismatch.