Examples of org.hornetq.api.core.client.ClientSession.commit()

Class org.hornetq.api.core.client.ClientSession

Examples of org.hornetq.api.core.client.ClientSession.commit()

org.hornetq.api.core.client.ClientSession.commit()
Commits the current transaction. @throws HornetQException if an exception occurs while committing the transaction

                     msg.putIntProperty("count", i);
                     producer.send(msg);


                     if (i % 100 == 0 && i != 0)
                     {
                        sessionProducer.commit();
                        // Thread.sleep(500);
                     }
                  }


                  sessionProducer.commit();

View Full Code Here

                        sessionProducer.commit();
                        // Thread.sleep(500);
                     }
                  }


                  sessionProducer.commit();


                  System.out.println("Producer gone");


               }
               catch (Throwable e)

View Full Code Here

            assertNotNull(msg);
            assertEquals(i, msg.getIntProperty("count").intValue());
            msg.acknowledge();
            if (i > 0 && i % 10 == 0)
            {
               session.commit();
            }
         }
         session.commit();


         session.close();

View Full Code Here

            if (i > 0 && i % 10 == 0)
            {
               session.commit();
            }
         }
         session.commit();


         session.close();


         producerThread.join();

View Full Code Here


                     if (i == 1000)
                     {
                        // The session is not TX, but we do this just to perform a round trip to the server
                        // and make sure there are no pending messages
                        sessionProducer.commit();


                        assertTrue(server.getPagingManager().getPageStore(ADDRESS).isPaging());
                        ready.countDown();
                     }
                  }

View Full Code Here

                        assertTrue(server.getPagingManager().getPageStore(ADDRESS).isPaging());
                        ready.countDown();
                     }
                  }


                  sessionProducer.commit();


                  log.info("Producer gone");


               }
               catch (Throwable e)

View Full Code Here

            message.putIntProperty(new SimpleString("id"), i);


            producer.send(message);
         }


         session.commit();


         session.close();


         locator.close();

View Full Code Here

            message.putIntProperty(new SimpleString("id"), i);


            producer.send(message);
            if (i % messagesPerTX == 0)
            {
               session.commit();
            }
         }
         session.commit();
         session.close();
      }

View Full Code Here

            if (i % messagesPerTX == 0)
            {
               session.commit();
            }
         }
         session.commit();
         session.close();
      }
      finally
      {
         try

View Full Code Here

            message.putStringProperty("id", "str-" + i);


            producer.send(message);
            if ((i + 1) % messagesPerTX == 0)
            {
               session.commit();
            }
         }
         session.commit();


         session.start();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.