Examples of org.mokai.persist.MessageStore.saveOrUpdate()

org.mokai.persist.MessageStore.saveOrUpdate()
If the message is not persisted, it saves the messages, otherwise it updates the record. @param message the {@link Message} we want to save or update. @throws StoreException if something goes wrong. @throws RejectedException if the message store refuses to save orupdate the message.

    logCollectionSize(messages.size()); // log the size of the collection
    for (Message message : messages) {
      // update the message and send it
      message.setStatus(Message.STATUS_RETRYING);
      message.setModificationTime(new Date());
      messageStore.saveOrUpdate(message);


      if (message.getDirection().equals(Direction.TO_CONNECTIONS)) {
        producer.sendBody(UriConstants.CONNECTIONS_ROUTER, ExchangePattern.InOnly, message);
      } else if (message.getDirection().equals(Direction.TO_APPLICATIONS)) {
        producer.sendBody(UriConstants.APPLICATIONS_ROUTER, ExchangePattern.InOnly, message);

View Full Code Here

      MessageStore messageStore = resourceRegistry.getResource(MessageStore.class);


      boolean insert = message.getId() == null;


      long startTime = new Date().getTime();
      messageStore.saveOrUpdate(message);
      long endTime = new Date().getTime();


      if (insert) {
        log.trace("insert message with id " + message.getId() + " took " + (endTime - startTime) + " milis");
      } else {

View Full Code Here

      message.setProperty("text", "This is the test");
      message.setProperty("sequenceNumber", 1);
      message.setProperty("messageId", "12000");
      message.setProperty("commandStatus", 0);


      messageStore.saveOrUpdate(message);


      DeliverSm deliverSm = new DeliverSm();
      deliverSm.setEsmClass(SmppConstants.ESM_CLASS_MT_SMSC_DELIVERY_RECEIPT);
      deliverSm.setDestAddress(new Address((byte) 0, (byte) 0, "3002175604"));
      deliverSm.setSourceAddress(new Address((byte) 0, (byte) 0, "3542"));

View Full Code Here

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.