Package org.jboss.messaging.core.plugin

Examples of org.jboss.messaging.core.plugin.IDManager.start()

108
109
110
111
112
113
114
115
116
117
118
                  sc.getPersistenceManagerSQLProperties(),
                  true, true, true, false, 100);
      pm.start();
     
      IDManager idm = new IDManager("TRANSACTION_ID", 10, pm);
      idm.start();
     
      TransactionRepository tr = new TransactionRepository(pm, new SimpleMessageStore(), idm);
      tr.start();
     
      Transaction tx = tr.createTransaction();
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
   }
  
   public void test1() throws Exception
   {
      IDManager idm = new IDManager("test_counter", 1000, pm);
      idm.start();
     
      int blockSize = 37;
           
      long nextLow = Long.MIN_VALUE;
     
View Full Code Here
112
113
114
115
116
117
118
119
120
121
122
   }
  
   public void test2() throws Exception
   {
      IDManager idm = new IDManager("test_counter2", 100, pm);
      idm.start();
        
      for (int i = 0; i < 1000; i++)
      {
         long id = idm.getID();
        
View Full Code Here
1310
1311
1312
1313
1314
1315
1316
1317
1318
1319
1320
      doSetup(batch, useBinaryStream, trailingByte, 100);

      Channel channel = new SimpleChannel(0, ms);
     
      IDManager idm = new IDManager("TRANSACTION_ID", 10, pm);
      idm.start();
     
      TransactionRepository txRep = new TransactionRepository(pm, ms, idm);
      txRep.start();

      log.debug("transaction log started");
View Full Code Here
1421
1422
1423
1424
1425
1426
1427
1428
1429
1430
1431
      doSetup(batch, useBinaryStream, trailingByte, 100);

      Channel channel = new SimpleChannel(0, ms);
     
      IDManager idm = new IDManager("TRANSACTION_ID", 10, pm);
      idm.start();
     
      TransactionRepository txRep = new TransactionRepository(pm, ms, idm);
      txRep.start();
      Message[] messages = createMessages(10);    
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.