Package org.hornetq.core.journal.impl

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

1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
   {

      SequentialFileFactory factory = new FakeSequentialFileFactory(512, false);
      JournalImpl impl = new JournalImpl(512 + 512 * 3, 20, 0, 0, factory, "hq", "hq", 1000);

      impl.start();

      impl.load(AlignedJournalImplTest.dummyLoader);

      impl.appendAddRecord(1l, (byte)0, new SimpleEncoding(100, (byte)'a'), false);
      impl.appendAddRecord(2l, (byte)0, new SimpleEncoding(100, (byte)'b'), false);
View Full Code Here
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
1288
      impl.appendAddRecord(4l, (byte)0, new SimpleEncoding(100, (byte)'b'), false);

      impl.stop();

      impl = new JournalImpl(512 + 1024 + 512, 20, 0, 0, factory, "hq", "hq", 1000);
      impl.start();
      impl.load(AlignedJournalImplTest.dummyLoader);

      // It looks silly, but this forceMoveNextFile is in place to replicate one
      // specific bug caught during development
      impl.forceMoveNextFile();
View Full Code Here
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
      impl.appendDeleteRecord(4l, false);

      impl.stop();

      impl = new JournalImpl(512 + 1024 + 512, 20, 0, 0, factory, "hq", "hq", 1000);
      impl.start();

      ArrayList<RecordInfo> info = new ArrayList<RecordInfo>();
      ArrayList<PreparedTransactionInfo> trans = new ArrayList<PreparedTransactionInfo>();

      impl.load(info, trans, null);
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
                                               100);

         List<RecordInfo> committedRecords = new ArrayList<RecordInfo>();
         List<PreparedTransactionInfo> preparedTransactions = new ArrayList<PreparedTransactionInfo>();

         journal.start();
         journal.load(committedRecords, preparedTransactions, null);

         Assert.assertEquals(0, committedRecords.size());
         Assert.assertEquals(0, preparedTransactions.size());
View Full Code Here
188
189
190
191
192
193
194
195
196
197
198
                                                    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
352
353
354
355
356
357
358
359
360
361
362
                                           bindingsJMS,
                                           "hornetq-jms",
                                           "jms",
                                           1);

      jmsJournal.start();

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

      ArrayList<PreparedTransactionInfo> list = new ArrayList<>();
View Full Code Here
194
195
196
197
198
199
200
201
202
203
204
   public void testSpeedTransactional() throws Exception
   {
      Journal journal = new JournalImpl(10 * 1024 * 1024, 10, 0, 0, getFileFactory(), "hornetq-data", "hq", 5000);

      journal.start();

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

      try
      {
View Full Code Here
257
258
259
260
261
262
263
264
265
266
267
      JournalImplTestUnit.log.debug("num Files=" + numFiles);

      Journal journal = new JournalImpl(10 * 1024 * 1024, numFiles, 0, 0, getFileFactory(), "hornetq-data", "hq", 5000);

      journal.start();

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

      JournalImplTestUnit.log.debug("Adding data");
      SimpleEncoding data = new SimpleEncoding(700, (byte)'j');
View Full Code Here
281
282
283
284
285
286
287
288
289
290
291
      journal.stop();

      journal = new JournalImpl(10 * 1024 * 1024, numFiles, 0, 0, getFileFactory(), "hornetq-data", "hq", 5000);

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

   }

View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
                             factory,
                             "hq",
                             "hq",
                             1000);

      impl.start();

      impl.load(AddAndRemoveStressTest.dummyLoader);

      for (long i = 1; i <= AddAndRemoveStressTest.NUMBER_OF_MESSAGES; i++)
      {
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.