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

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

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

org.hornetq.api.core.client.ClientSession.createMessage()
Creates a ClientMessage. @param durable whether the created message is durable or not @return a ClientMessage

         sessionNonTX.start();


         for (int i = 0; i < 50; i++)
         {
            System.out.println("Sending " + i);
            ClientMessage message = sessionNonTX.createMessage(true);
            message.getBodyBuffer().writeBytes(body);
            message.putIntProperty(new SimpleString("id"), i);
            message.putStringProperty(new SimpleString("tst"), new SimpleString("i=" + i));


            producerTransacted.send(message);

View Full Code Here

            if (i % 2 == 0)
            {
               System.out.println("Sending 20 msgs to make it page");
               for (int j = 0; j < 20; j++)
               {
                  ClientMessage msgSend = sessionNonTX.createMessage(true);
                  msgSend.putStringProperty(new SimpleString("tst"), new SimpleString("i=" + i + ", j=" + j));
                  msgSend.getBodyBuffer().writeBytes(new byte[10 * 1024]);
                  producerNonTransacted.send(msgSend);
               }
               assertTrue(server.getPostOffice().getPagingManager().getPageStore(PagingTest.ADDRESS).isPaging());

View Full Code Here

                  sessionProducer = sf.createSession(false, false);
                  ClientProducer producer = sessionProducer.createProducer(ADDRESS);


                  for (int i = 0; i < numberOfMessages; i++)
                  {
                     ClientMessage msg = sessionProducer.createMessage(true);
                     msg.getBodyBuffer().writeBytes(body);
                     msg.putIntProperty("count", i);
                     producer.send(msg);


                     if (i % 100 == 0 && i != 0)

View Full Code Here

                  sessionProducer = sf.createSession(true, true);
                  ClientProducer producer = sessionProducer.createProducer(ADDRESS);


                  for (int i = 0; i < numberOfMessages; i++)
                  {
                     ClientMessage msg = sessionProducer.createMessage(true);
                     msg.getBodyBuffer().writeBytes(body);
                     msg.putIntProperty("count", i);
                     producer.send(msg);


                     if (i == 1000)

View Full Code Here


         long scheduledTime = System.currentTimeMillis() + 5000;


         for (int i = 0; i < numberOfMessages; i++)
         {
            message = session.createMessage(true);


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


            TestSupportPageStore store = (TestSupportPageStore)server.getPostOffice()

View Full Code Here


         ClientMessage message = null;


         for (int i = 0; i < numberOfMessages; i++)
         {
            message = session.createMessage(true);


            HornetQBuffer bodyLocal = message.getBodyBuffer();


            for (int j = 1; j <= numberOfIntegers; j++)
            {

View Full Code Here


         ClientMessage message = null;


         for (int i = 0; i < numberOfMessages; i++)
         {
            message = session.createMessage(true);


            HornetQBuffer bodyLocal = message.getBodyBuffer();


            for (int j = 1; j <= numberOfIntegers; j++)
            {

View Full Code Here

            bb.put(getSamplebyte(j));
         }


         for (int i = 0; i < numberOfMessages; i++)
         {
            message = session.createMessage(true);


            HornetQBuffer bodyLocal = message.getBodyBuffer();


            bodyLocal.writeBytes(body);

View Full Code Here

            bb.put(getSamplebyte(j));
         }


         for (int i = 0; i < numberOfMessages; i++)
         {
            message = session.createMessage(true);


            HornetQBuffer bodyLocal = message.getBodyBuffer();


            bodyLocal.writeBytes(body);

View Full Code Here


         byte[] body = new byte[messageSize];


         for (int i = 0; i < numberOfMessages; i++)
         {
            message = session.createMessage(persistentMessages);


            HornetQBuffer bodyLocal = message.getBodyBuffer();


            bodyLocal.writeBytes(body);

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.