clebertsuconic

Fix incorrect stop order: pagingManager cannot be closed at this point. (commit: 3b689bc61362273cb7a5300850d9134b2065713c) (detail)
Fix replicating backup start-up issues. (commit: 91bf7702faf2763f77b19e2d2f9b209e2b9b0960) (detail)
Ensure the server thread calling close will access the fields' current value (commit: 262722c54771ed7ae12b39397eb782c53827e534) (detail)
These exceptions are normal at a server close event, so do not output warnings (commit: d0a88b4fa4f1a531738cfae172945231b4422640) (detail)
Reduce scope of throws declaration. (commit: 79485ceb97a6eed8cba23f093e1a7322fb2ffe3f) (detail)
Correct spelling/capitalization in logging method name (commit: 44e9f742b6ee71b2d21ba67475796d2d30cdc1f7) (detail)

clebertsuconic

junit.framework.AssertionFailedError: test 'testG' left serverlocator running, this could effect other tests
	at junit.framework.Assert.fail(Assert.java:47)
	at org.hornetq.tests.util.UnitTestCase.tearDown(UnitTestCase.java:1024)
	at org.hornetq.tests.util.ServiceTestBase.tearDown(ServiceTestBase.java:72)
	at org.hornetq.tests.integration.cluster.reattach.MultiThreadReattachSupport.tearDown(MultiThreadReattachSupport.java:70)
	at org.hornetq.tests.integration.cluster.reattach.MultiThreadRandomReattachTestBase.tearDown(MultiThreadRandomReattachTestBase.java:1268)
	at junit.framework.TestCase.runBare(TestCase.java:136)
	at junit.framework.TestResult$1.protect(TestResult.java:106)
	at junit.framework.TestResult.runProtected(TestResult.java:124)
	at junit.framework.TestResult.run(TestResult.java:109)

clebertsuconic

   public void testBody() throws Exception
   {
      final String QUEUE_NAME = "A1";
      HornetQServer server = createServer(true);
      server.start();
      ServerLocator locator = createInVMNonHALocator();
      ClientSessionFactory factory = locator.createSessionFactory();
      ClientSession session = factory.createSession(false, true, true);

      session.createQueue(QUEUE_NAME, QUEUE_NAME);

clebertsuconic

  private void printMessageBody(ServerMessage message) throws XMLStreamException
   {
      xmlWriter.writeStartElement(XmlDataConstants.MESSAGE_BODY);

      if (message.isLargeMessage())
      {
         printLargeMessageBody((LargeServerMessage) message);
      }
      else
      {

clebertsuconic

   public void testFailMessages() throws Exception
   {
      clearData();

      Configuration config = createDefaultConfig();

      HashMap<String, AddressSettings> settings = new HashMap<String, AddressSettings>();

      AddressSettings set = new AddressSettings();

clebertsuconic

                    <connection-factory name="XAInVmConnectionFactory">
                        <transaction mode="xa"/>
                        <connectors>
                            <connector-ref connector-name="in-vm"/>
                        </connectors>
                        <entries>
                            <entry name="java:/XAConnectionFactory"/>
                        </entries>
                    </connection-factory>

clebertsuconic

on QueueImpl:


      // Step1: open a new transaction
      Transaction tx = new TransactionImpl(storageManager);

      LinkedListIterator<MessageReference> iter = iterator();
      try
      {

clebertsuconic

[INFO] Compiling 50 source files to /work/hornetq/hornetq/hornetq-commons/target/classes
[INFO] -------------------------------------------------------------
[ERROR] COMPILATION ERROR : 
[INFO] -------------------------------------------------------------
[ERROR] error: java.lang.NullPointerException
[INFO] 1 error
[INFO] -------------------------------------------------------------
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------

clebertsuconic

   private class MyOutgoingInterceptor2 implements Interceptor
   {
      public boolean intercept(final Packet packet, final RemotingConnection connection) throws HornetQException
      {
         if (packet.getType() == PacketImpl.SESS_RECEIVE_MSG)
         {
            SessionReceiveMessage msg = (SessionReceiveMessage) packet;
            if (msg.getMessage().containsProperty(ClientConsumerImpl.FORCED_DELIVERY_MESSAGE))
            {
               return true;

clebertsuconic

      System.out.println("Serq que essa porra funciona??");
      log.debug("registering recovery for factory : " + factory);
      XARecoveryConfig config = newResourceConfig(factory, userName, password);
      resources.add(config);
      if (registry != null)
      {
         System.out.println("legal!!!!... deu certo!!!!!");
         registry.register(config);
      }
      else