Package org.hornetq.core.journal.impl

Examples of org.hornetq.core.journal.impl.JournalImpl.start()

165
166
167
168
169
170
171
172
173
174
175
                                                       messagesFF,
                                                       journalName,
                                                       exension,
                                                       1);

         messagesJournal.start();

         messagesJournal.loadInternalOnly();


         for (long tx : txsToRollback)
View Full Code Here
353
354
355
356
357
358
359
360
361
362
363
                                           bindingsJMS,
                                           "hornetq-jms",
                                           "jms",
                                           1);

      jmsJournal.start();

      List<RecordInfo> data = new ArrayList<>();

      ArrayList<PreparedTransactionInfo> list = new ArrayList<>();
View Full Code Here
254
255
256
257
258
259
260
261
262
263
264
         messagesFF,
         "hornetq-data",
         "hq",
         1);

      messagesJournal.start();

      ArrayList<RecordInfo> records = new ArrayList<RecordInfo>();
      ArrayList<PreparedTransactionInfo> txs = new ArrayList<PreparedTransactionInfo>();

      messagesJournal.load(records, txs, null, false);
View Full Code Here
304
305
306
307
308
309
310
311
312
313
314
                                            1);
     
     
      final AtomicInteger updates = new AtomicInteger();
     
      journal.start();
      journal.load(new LoaderCallback()
      {
        
         public void failedTransaction(long transactionID, List<RecordInfo> records, List<RecordInfo> recordsToDelete)
         {
View Full Code Here
650
651
652
653
654
655
656
657
658
659
660
                                           "hq",
                                           1);
         final List<RecordInfo> committedRecords = new LinkedList<RecordInfo>();
         final List<PreparedTransactionInfo> preparedTransactions = new LinkedList<PreparedTransactionInfo>();
        
         messagesJournal.start();
        
         messagesJournal.load(committedRecords, preparedTransactions, null, false);
        
         return new Pair<List<RecordInfo>, List<PreparedTransactionInfo>>(committedRecords, preparedTransactions);
      }
View Full Code Here
778
779
780
781
782
783
784
785
786
787
788
                                                    0,
                                                    messagesFF,
                                                    "hornetq-data",
                                                    "hq",
                                                    1);
      messagesJournal.start();
     
     
      final List<RecordInfo> committedRecords = new LinkedList<RecordInfo>();
      final List<PreparedTransactionInfo> preparedTransactions = new LinkedList<PreparedTransactionInfo>();
     
View Full Code Here
1665
1666
1667
1668
1669
1670
1671
1672
1673
1674
1675
                                        0,
                                        new NIOSequentialFileFactory(getJournalDir()),
                                        "hornetq-data",
                                        "hq",
                                        1);
      jrn.start();
      jrn.load(records, list, null);

      // Delete everything from the journal
      for (RecordInfo info : records)
      {
View Full Code Here
52
53
54
55
56
57
58
59
60
61
62
   public void testSequence() throws Exception
   {
      NIOSequentialFileFactory factory = new NIOSequentialFileFactory(getTestDir());
      Journal journal = new JournalImpl(10 * 1024, 2, 0, 0, factory, "test-data", "tst", 1);

      journal.start();

      journal.load(new ArrayList<RecordInfo>(), new ArrayList<PreparedTransactionInfo>(), null);

      BatchingIDGenerator batch = new BatchingIDGenerator(0, 1000, journal);
      long id1 = batch.generateID();
View Full Code Here
273
274
275
276
277
278
279
280
281
282
283
                                            100);

      ArrayList<RecordInfo> records = new ArrayList<RecordInfo>();
      ArrayList<PreparedTransactionInfo> transactions = new ArrayList<PreparedTransactionInfo>();

      journal.start();
      journal.load(records, transactions, null);

      System.out.println("===============================================");
      System.out.println("Journal records at the end:");
View Full Code Here
241
242
243
244
245
246
247
248
249
250
251
                                                    messagesFF,
                                                    "hornetq-data",
                                                    "hq",
                                                    1);

      messagesJournal.start();

      ArrayList<RecordInfo> records = new ArrayList<RecordInfo>();
      ArrayList<PreparedTransactionInfo> txs = new ArrayList<PreparedTransactionInfo>();

      messagesJournal.load(records, txs, null, false);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.