List of removeMessage() Examples

Examples of removeMessage()

com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()
org.apache.activemq.broker.jmx.QueueViewMBean.removeMessage()
Removes a message from the queue. If the message has already been dispatched to another consumer, the message cannot be deleted and this method will return false. @param messageId @return true if the message was found and could be successfully deleted. @throws Exception
org.apache.activemq.store.MessageStore.removeMessage()
Removes a message from the message store. @param context @param ack the ack request that cause the message to be removed. Itconatins the identity which contains the messageID of the message that needs to be removed. @throws IOException
org.eclipse.ui.forms.IMessageManager.removeMessage()
Removes the general message with the provided key. Does nothing if message for the key does not exist. @param key the key of the message to remove
org.exolab.jms.persistence.PersistenceAdapter.removeMessage()
Remove the message with the specified identity from the database @param connection - the connection to use @param id the identity of the message to remove @throws PersistenceException
org.hornetq.api.core.management.QueueControl.removeMessage()
Removes the message corresponding to the specified message ID. @return {@code true} if the message was removed, {@code false} else
org.hornetq.api.jms.management.JMSQueueControl.removeMessage()
Removes the message corresponding to the specified message ID. @return {@code true} if the message was removed, {@code false} else
org.jboss.soa.esb.services.persistence.MessageStore.removeMessage()
Removes a message from the store by URI. @param uid the unique message id @param classification the classification of the message @return int response from the SQL delete command @throws MessageStoreException
org.openbravo.base.secureApp.VariablesSecureApp.removeMessage()
Removes the error object for the specified tab from the session data. This needs to be done in order for the message not to appear every time the tab is reloaded. @param AD_Tab_ID String with the primary key (ID) of the tab as entered within the AD_TAB database table. @see #setMessage(String,OBError) @see #getMessage(String)

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

        SysMessageID sysMsgID = SysMessageID.get(msgID);


                    PacketReference pr = Destination.get(sysMsgID);


        if (pr != null)  {
            d.removeMessage(sysMsgID, RemoveReason.REMOVED_OTHER);
        } else  {
      /*
                        errMsg= rb.getString(rb.X_MSG_NOT_FOUND, msgID);
      */
                        errMsg= "Could not locate message "

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

                            r1 =s.ackMessage(intid, sysid, id, remoteNotified, true);
                            if (r1 != null) {
                                if (fi.FAULT_INJECTION) {
                                    fi.checkFaultAndExit(FaultInjection.FAULT_TXN_COMMIT_1_7, null, 2, false);
                                }
                                dst.removeMessage(ref.getSysMessageID(),
                                    RemoveReason.ACKNOWLEDGED);
                            } else {
                                s = Session.getSession(intid);
                            }
                        }

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

                            // to retrieve the message and acknowledge it
                            // with the stored UID
                            try {
                                if (ref.acknowledged(intid, sid, 
                                    true, true, id, remoteNotified, true)) {
                                    dst.removeMessage(ref.getSysMessageID(),
                                        RemoveReason.ACKNOWLEDGED);
                                }
                            } catch (BrokerException ex) {
                                // XXX improve internal error
                                logger.log(Logger.WARNING,"Internal error", ex);

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

            }
            PacketReference ref = Destination.get(sysid);
            if (ref == null) continue;
            DestinationUID duid = ref.getDestinationUID();
            Destination d = Destination.getDestination(duid);
            d.removeMessage(sysid, RemoveReason.ROLLBACK);
        }


        // remove from our active connection list
        if (conlist != null) {
            conlist.remove(id);

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

                    "BrokerConsumers.forwardMessageToRemote(): "+ref+", ignore removed consumer: "+consumer);
                    }
                    try {
                        if (ref.acknowledged(uid, sid, !uid.isDupsOK(), false)) {
                            Destination d=Destination.getDestination(ref.getDestinationUID());
                            d.removeMessage(ref.getSysMessageID(), RemoveReason.ACKNOWLEDGED);
                        }
                    } catch (Exception e) {
                        logger.logStack(Logger.WARNING,
                        "Unable to cleanup message "+ref.getSysMessageID()+" for closed consumer "+uid, e);
                    }

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

                com.sun.messaging.jmq.jmsserver.core.ConsumerUID uid = value.getConsumerUID();
                if (sid== null || sid == uid) {
                    try {
                        if (ref.acknowledged(uid, sid, !uid.isDupsOK(), false)) {
                            Destination d=Destination.getDestination(ref.getDestinationUID());
                            d.removeMessage(ref.getSysMessageID(), RemoveReason.ACKNOWLEDGED);
                        }
                    } catch (Exception e) {
                        logger.logStack(Logger.WARNING,
                        "Unable to cleanup message "+ref.getSysMessageID()+logstrop, e);
                    }

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

                        fi.checkFaultAndExit(
                           FaultInjection.FAULT_MSG_REMOTE_ACK_HOME_C_TXNCOMMIT_1_7,
                           null, 2, false);
                    }
                    Destination d=Destination.getDestination(ref.getDestinationUID());
                    d.removeMessage(ref.getSysMessageID(),
                      RemoveReason.ACKNOWLEDGED);
                }
            } catch (Exception ex) {
                logger.logStack(Logger.WARNING, 
                       "Unable to process acknowledgement:["+id+","+uid+"]", ex);

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

            Destination d = null;
            itr = cleanupDests.iterator();
            while (itr.hasNext()) {
                try {
                    d = (Destination)itr.next();
                    d.removeMessage(ref.getSysMessageID(), null);
                } catch (Throwable e) {
                    Object[] args = { ref.getSysMessageID(), 
                                      (sender == null ? "":sender), 
                                      d, targetVector.toString(), e.toString() };
                    String emsg = Globals.getBrokerResources().getKString(

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()

      dstLoadedSet.add(dst); // Keep track of what has been loaded
    }


    logger.log(Logger.FORCE, Globals.getBrokerResources().getKString(
                   BrokerResources.I_RM_MSG_ON_REPLAY_MSG_REMOVAL, mid, dst));
        dst.removeMessage(mid, RemoveReason.REMOVED_OTHER);


    if (msgStore.containsMessage(did, mid)) {
      msgStore.removeMessage(did, mid, false);
    }

View Full Code Here

Examples of com.sun.messaging.jmq.jmsserver.core.Destination.removeMessage()


      SysMessageID sysMsgID = SysMessageID.get(messageID);
      PacketReference pr = Destination.get(sysMsgID);


      if (pr != null)  {
                d.removeMessage(sysMsgID, RemoveReason.REMOVED_OTHER);
          logger.log(Logger.INFO, "Deleted from destination "
      + destinationName
      + " message with ID: " 
      + messageID);
            } else  {

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.