Package org.hornetq.core.journal

Examples of org.hornetq.core.journal.SequentialFileFactory

227
228
229
230
231
232
233
234
235
236
237
    * @return
    * @throws Exception
    */
   protected static PageCursorsInfo loadCursorACKs(final String journalLocation) throws Exception
   {
      SequentialFileFactory messagesFF = new NIOSequentialFileFactory(journalLocation, null);

      // Will use only default values. The load function should adapt to anything different
      ConfigurationImpl defaultValues = new ConfigurationImpl();

      JournalImpl messagesJournal = new JournalImpl(defaultValues.getJournalFileSize(),
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
         printUsage();
         System.exit(-1);
         return; // dumb compiler don't know System.exit interrupts the execution, some variables wouldn't be init
      }

      SequentialFileFactory messagesFF = new NIOSequentialFileFactory(directoryName, null);

      // Will use only default values. The load function should adapt to anything different
      ConfigurationImpl defaultValues = new ConfigurationImpl();

      try
View Full Code Here
342
343
344
345
346
347
348
349
350
351
352
      }
   }

   private void getJmsBindings() throws Exception
   {
      SequentialFileFactory bindingsJMS = new NIOSequentialFileFactory(config.getBindingsDirectory());

      Journal jmsJournal = new JournalImpl(1024 * 1024,
                                           2,
                                           config.getJournalCompactMinFiles(),
                                           config.getJournalCompactPercentage(),
View Full Code Here
240
241
242
243
244
245
246
247
248
249
250
    * @return
    * @throws Exception
    */
   protected static PageCursorsInfo loadCursorACKs(final String journalLocation) throws Exception
   {
      SequentialFileFactory messagesFF = new NIOSequentialFileFactory(journalLocation, null);

      // Will use only default values. The load function should adapt to anything different
      ConfigurationImpl defaultValues = new ConfigurationImpl();

      JournalImpl messagesJournal = new JournalImpl(defaultValues.getJournalFileSize(),
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
      createBindingsDir = config.isCreateBindingsDir();

      journalDir = config.getJournalDirectory();

      SequentialFileFactory bindingsFF = new NIOSequentialFileFactory(bindingsDir, criticalErrorListener);

      Journal localBindings = new JournalImpl(1024 * 1024,
         2,
         config.getJournalCompactMinFiles(),
         config.getJournalCompactPercentage(),
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
         throw new NullPointerException("bindings-dir is null");
      }

      createDir = config.isCreateBindingsDir();

      SequentialFileFactory bindingsJMS = new NIOSequentialFileFactory(journalDir);

      Journal localJMS = new JournalImpl(1024 * 1024,
                                              2,
                                              config.getJournalCompactMinFiles(),
                                              config.getJournalCompactPercentage(),
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
      createBindingsDir = config.isCreateBindingsDir();

      journalDir = config.getJournalDirectory();

      SequentialFileFactory bindingsFF = new NIOSequentialFileFactory(bindingsDir, criticalErrorListener);

      Journal localBindings = new JournalImpl(1024 * 1024,
         2,
         config.getJournalCompactMinFiles(),
         config.getJournalCompactPercentage(),
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
         throw new NullPointerException("bindings-dir is null");
      }

      createDir = config.isCreateBindingsDir();

      SequentialFileFactory bindingsJMS = new NIOSequentialFileFactory(journalDir);

      Journal localJMS = new JournalImpl(1024 * 1024,
                                              2,
                                              config.getJournalCompactMinFiles(),
                                              config.getJournalCompactPercentage(),
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
      createBindingsDir = config.isCreateBindingsDir();

      journalDir = config.getJournalDirectory();

      SequentialFileFactory bindingsFF = new NIOSequentialFileFactory(bindingsDir, criticalErrorListener);

      Journal localBindings = new JournalImpl(1024 * 1024,
                                              2,
                                              config.getJournalCompactMinFiles(),
                                              config.getJournalCompactPercentage(),
View Full Code Here
1451
1452
1453
1454
1455
1456
1457
1458
1459
1460
1461
   }

   public static void describeBindingJournal(final String bindingsDir) throws Exception
   {

      SequentialFileFactory bindingsFF = new NIOSequentialFileFactory(bindingsDir, null);

      JournalImpl bindings = new JournalImpl(1024 * 1024, 2, -1, 0, bindingsFF, "hornetq-bindings", "bindings", 1);

      describeJournal(bindingsFF, bindings);
   }
View Full Code Here
TOP

Related Classes of org.hornetq.core.journal.SequentialFileFactory

  • org.hornetq.core.paging.impl.PagingStoreFactoryNIO
  • org.hornetq.core.paging.impl.PagingStoreImpl
  • org.hornetq.core.paging.PrintPages
  • org.hornetq.core.persistence.impl.journal.DescribeJournal
  • org.hornetq.core.persistence.impl.journal.JournalStorageManager
  • org.hornetq.jms.persistence.impl.journal.JMSJournalStorageManagerImpl
  • org.hornetq.jms.persistence.impl.journal.XmlDataExporter
  • org.hornetq.tests.integration.client.HangConsumerTest
  • org.hornetq.tests.integration.journal.JournalPerfTuneTest
  • org.hornetq.tests.stress.journal.AddAndRemoveStressTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.