Examples of ClientMessage

de.creepsmash.common.messages.client.ClientMessage
Message from client to server. @author andreas
org.apache.cayenne.remote.ClientMessage
A tag interface representing a message sent by a remote client to Cayenne service. @since 1.2
org.hornetq.api.core.client.ClientMessage
A ClientMessage represents a message sent and/or received by HornetQ. @author Tim Fox @author Clebert Suconic
xnap.plugin.nap.net.msg.client.ClientMessage

Examples of org.hornetq.api.core.client.ClientMessage

      session.createQueue(address, queue, null, false);
      session.createQueue(otherAddress, otherQueue, null, false);
      ClientProducer producer = session.createProducer(address);


      // send on queue
      ClientMessage matchingMessage = session.createMessage(false);
      matchingMessage.putLongProperty(key, matchingValue);
      producer.send(matchingMessage);
      ClientMessage unmatchingMessage = session.createMessage(false);
      unmatchingMessage.putLongProperty(key, unmatchingValue);
      producer.send(unmatchingMessage);


      QueueControl queueControl = createManagementControl(address, queue);
      Assert.assertEquals(2, queueControl.getMessageCount());


      // moved matching messages to otherQueue
      int movedMatchedMessagesCount = queueControl.moveMessages(key + " =" + matchingValue, otherQueue.toString());
      Assert.assertEquals(1, movedMatchedMessagesCount);
      Assert.assertEquals(1, queueControl.getMessageCount());


      // consume the unmatched message from queue
      ClientConsumer consumer = session.createConsumer(queue);
      ClientMessage m = consumer.receive(500);
      Assert.assertNotNull(m);
      Assert.assertEquals(unmatchingValue, m.getObjectProperty(key));


      // consume the matched message from otherQueue
      ClientConsumer otherConsumer = session.createConsumer(otherQueue);
      m = otherConsumer.receive(500);
      Assert.assertNotNull(m);
      Assert.assertEquals(matchingValue, m.getObjectProperty(key));


      m.acknowledge();


      consumer.close();
      session.deleteQueue(queue);
      otherConsumer.close();
      session.deleteQueue(otherQueue);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage


      session.createQueue(address, queue, null, false);
      ClientProducer producer = session.createProducer(address);


      // send on queue
      ClientMessage matchingMessage = session.createMessage(false);
      matchingMessage.putLongProperty(key, matchingValue);
      producer.send(matchingMessage);
      ClientMessage unmatchingMessage = session.createMessage(false);
      unmatchingMessage.putLongProperty(key, unmatchingValue);
      producer.send(unmatchingMessage);


      QueueControl queueControl = createManagementControl(address, queue);
      Assert.assertEquals(2, queueControl.getMessageCount());


      // removed matching messages to otherQueue
      int removedMatchedMessagesCount = queueControl.removeMessages(key + " =" + matchingValue);
      Assert.assertEquals(1, removedMatchedMessagesCount);
      Assert.assertEquals(1, queueControl.getMessageCount());


      // consume the unmatched message from queue
      ClientConsumer consumer = session.createConsumer(queue);
      ClientMessage m = consumer.receive(500);
      Assert.assertNotNull(m);
      Assert.assertEquals(unmatchingValue, m.getObjectProperty(key));


      m.acknowledge();


      // check there is no other message to consume:
      m = consumer.receiveImmediate();
      Assert.assertNull(m);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage


      session.createQueue(address, queue, null, false);
      ClientProducer producer = session.createProducer(address);


      // send on queue
      ClientMessage matchingMessage = session.createMessage(false);
      matchingMessage.putLongProperty(key, matchingValue);
      producer.send(matchingMessage);
      ClientMessage unmatchingMessage = session.createMessage(false);
      unmatchingMessage.putLongProperty(key, unmatchingValue);
      producer.send(unmatchingMessage);


      QueueControl queueControl = createManagementControl(address, queue);
      Assert.assertEquals(2, queueControl.getMessageCount());


      // removed matching messages to otherQueue
      int removedMatchedMessagesCount = queueControl.removeMessages(5, key + " =" + matchingValue);
      Assert.assertEquals(1, removedMatchedMessagesCount);
      Assert.assertEquals(1, queueControl.getMessageCount());


      // consume the unmatched message from queue
      ClientConsumer consumer = session.createConsumer(queue);
      ClientMessage m = consumer.receive(500);
      Assert.assertNotNull(m);
      Assert.assertEquals(unmatchingValue, m.getObjectProperty(key));


      m.acknowledge();


      // check there is no other message to consume:
      m = consumer.receiveImmediate();
      Assert.assertNull(m);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage

      // send messages on queue


      for (int i = 0 ; i < 100; i++)
      {


         ClientMessage msg = session.createMessage(false);
         msg.putIntProperty("count", i);
         producer.send(msg);
      }


      ClientConsumer cons = session.createConsumer(queue);
      session.start();
      LinkedList<ClientMessage> msgs = new LinkedList<ClientMessage>();
      for (int i = 0; i < 50; i++)
      {
         ClientMessage msg = cons.receive(1000);
         msgs.add(msg);
      }


      QueueControl queueControl = createManagementControl(address, queue);
      Assert.assertEquals(100, queueControl.getMessageCount());

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage


      session.createQueue(address, queue, null, false);
      ClientProducer producer = session.createProducer(address);


      // send on queue
      ClientMessage matchingMessage = session.createMessage(false);
      matchingMessage.putLongProperty(key, matchingValue);
      ClientMessage unmatchingMessage = session.createMessage(false);
      unmatchingMessage.putLongProperty(key, unmatchingValue);
      producer.send(matchingMessage);
      producer.send(unmatchingMessage);
      producer.send(matchingMessage);


      QueueControl queueControl = createManagementControl(address, queue);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage

      ClientProducer producer = session.createProducer(address);


      // send on queue
      for (int i = 0 ; i < 100; i++)
      {
         ClientMessage msg = session.createMessage(false);
         msg.putStringProperty(key, SimpleString.toSimpleString(matchingValue));
         producer.send(msg);
      }


      for (int i = 0 ; i < 10; i++)
      {
         ClientMessage msg = session.createMessage(false);
         msg.putStringProperty(key, SimpleString.toSimpleString(nonMatchingValue));
         producer.send(msg);
      }


      // this is just to guarantee a round trip and avoid in transit messages, so they are all accounted for
      session.commit();

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage


      session.createQueue(address, queue, null, false);
      ClientProducer producer = session.createProducer(address);


      // send on queue
      ClientMessage matchingMessage = session.createMessage(false);
      matchingMessage.putLongProperty(key, matchingValue);
      producer.send(matchingMessage);
      ClientMessage unmatchingMessage = session.createMessage(false);
      unmatchingMessage.putLongProperty(key, unmatchingValue);
      producer.send(unmatchingMessage);


      QueueControl queueControl = createManagementControl(address, queue);
      Assert.assertEquals(2, queueControl.getMessageCount());


      int expiredMessagesCount = queueControl.expireMessages(key + " =" + matchingValue);
      Assert.assertEquals(1, expiredMessagesCount);
      Assert.assertEquals(1, queueControl.getMessageCount());


      // consume the unmatched message from queue
      ClientConsumer consumer = session.createConsumer(queue);
      ClientMessage m = consumer.receive(500);
      Assert.assertNotNull(m);
      Assert.assertEquals(unmatchingValue, m.getObjectProperty(key));


      m.acknowledge();


      // check there is no other message to consume:
      m = consumer.receiveImmediate();
      Assert.assertNull(m);

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage

      SimpleString queue = RandomUtil.randomSimpleString();


      session.createQueue(address, queue, null, false);
      ClientProducer producer = session.createProducer(address);


      ClientMessage message = session.createMessage(false);
      message.setPriority(originalPriority);
      producer.send(message);


      QueueControl queueControl = createManagementControl(address, queue);
      Assert.assertEquals(1, queueControl.getMessageCount());


      // the message IDs are set on the server
      Map<String, Object>[] messages = queueControl.listMessages(null);
      Assert.assertEquals(1, messages.length);
      long messageID = (Long)messages[0].get("messageID");


      boolean priorityChanged = queueControl.changeMessagePriority(messageID, newPriority);
      Assert.assertTrue(priorityChanged);


      ClientConsumer consumer = session.createConsumer(queue);
      ClientMessage m = consumer.receive(500);
      Assert.assertNotNull(m);
      Assert.assertEquals(newPriority, m.getPriority());


      consumer.close();
      session.deleteQueue(queue);
   }

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage

      SimpleString queue = RandomUtil.randomSimpleString();


      session.createQueue(address, queue, null, false);
      ClientProducer producer = session.createProducer(address);


      ClientMessage message = session.createMessage(false);
      producer.send(message);


      QueueControl queueControl = createManagementControl(address, queue);
      Assert.assertEquals(1, queueControl.getMessageCount());


      // the message IDs are set on the server
      Map<String, Object>[] messages = queueControl.listMessages(null);
      Assert.assertEquals(1, messages.length);
      long messageID = (Long)messages[0].get("messageID");


      try
      {
         queueControl.changeMessagePriority(messageID, invalidPriority);
         Assert.fail("operation fails when priority value is < 0 or > 9");
      }
      catch (Exception e)
      {
      }


      ClientConsumer consumer = session.createConsumer(queue);
      ClientMessage m = consumer.receive(500);
      Assert.assertNotNull(m);
      Assert.assertTrue(invalidPriority != m.getPriority());


      consumer.close();
      session.deleteQueue(queue);
   }

View Full Code Here

Examples of org.hornetq.api.core.client.ClientMessage


      ClientProducer prod1 = session.createProducer("q1");


      for (int i = 0; i < 10; i++)
      {
         ClientMessage msg = session.createMessage(true);


         msg.putStringProperty(org.hornetq.api.core.Message.HDR_DUPLICATE_DETECTION_ID, new SimpleString("dupl-" + i));


         prod1.send(msg);
      }


      session.commit();


      ClientConsumer consumer = session.createConsumer("q1", true);
      session.start();


      assertNotNull(consumer.receive(5000));
      consumer.close();


      QueueControl q1Control = ManagementControlHelper.createQueueControl(new SimpleString("q1"),
                                                                          new SimpleString("q1"),
                                                                          mbeanServer);


      QueueControl q2Control = ManagementControlHelper.createQueueControl(new SimpleString("q2"),
                                                                          new SimpleString("q2"),
                                                                          mbeanServer);


      assertEquals(10, q1Control.moveMessages(null, "q2"));


      consumer = session.createConsumer("q2", true);


      assertNotNull(consumer.receive(500));


      consumer.close();


      q2Control.moveMessages(null, "q1", false);


      session.start();
      consumer = session.createConsumer("q1");


      for (int i = 0; i < 10; i++)
      {
         ClientMessage msg = consumer.receive(5000);
         System.out.println("msg = " + msg);
         assertNotNull(msg);
         msg.acknowledge();
      }


      consumer.close();


      session.deleteQueue("q1");

View Full Code Here

0 1 2 3 4 5

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.