Retrieve the message from the non-persistent ItemStream
422374
public MessageItem retrieveMessageFromItemStream(long msgStoreID)
                    throws SIResourceException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "retrieveMessageFromItemStream", new Long(msgStoreID));

        MessageItem msgItem = null;
        try
        {
            msgItem = (MessageItem) _pubsubMessageItemStream.findById(msgStoreID);
        } catch (MessageStoreException e)
        {
            // FFDC
            FFDCFilter.processException(
                                        e,
                                        "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.retrieveMessageFromItemStream",
                                        "1:3797:1.35.2.4",
                                        this);

            SibTr.exception(tc, e);

            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                SibTr.exit(tc, "retrieveMessageFromItemStream", e);

            throw new SIResourceException(e);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "retrieveMessageFromItemStream", msgItem);

        return msgItem;
    }
231210
private String getNestedMessage(Throwable e) {
        String localMsg = e.getMessage();
        if (Utils.isEmpty(localMsg)) {
            localMsg = e.getClass().getSimpleName();
        }
        Throwable embeddedException = e.getCause();
        if (embeddedException == null) {
            return localMsg;
        }
        return localMsg + ": " + getNestedMessage(embeddedException);
    }
1177322
public static String getMessage(Throwable t) {

        String message = t.getLocalizedMessage();
        if (message == null) {
            message = t.getMessage();
        }
        if (message == null) {
            message = t.getClass().getName();
        }
        return message;
    }
653398
def retrieve_broadcast_message(self, txid):
        """"""
        rawtx = self.retrieve_tx(txid)
        return self.get_broadcast_message(rawtx)
790650
@Override
    public List<DataSlice> getPersistentData() throws PersistentDataEncodingException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "getPersistentData");

        //Late store of the currentMEArrivalTimestamp.  If the message is never stored
        //in the message store, then there's no point taking the hit of storing the
        //timestamp in the message
        if (!arrivalTimeStored)
        {
            msg.setCurrentMEArrivalTimestamp(currentMEArrivalTimeStamp);
            arrivalTimeStored = true;
        }
        if (producerConnectionUuid != null)
        {
            //see defect 278038
            //Late store of the currentMEArrivalTimestamp.  If the message is never stored
            //in the message store, then there's no point taking the hit
            msg.setConnectionUuid(producerConnectionUuid);
        }

        List<DataSlice> data = null;

        try
        {
            // Prevent any concurrent JsMessage property changes that may cause
            // a serialization error
            synchronized (messageSyncUpdateLock)
            {
                //get the message's data in a list of DataSlice objects
                data = msg.flatten(getOwningMessageStore());
            }
        } catch (MessageEncodeFailedException e)
        {
            FFDCFilter.processException(
                                        e,
                                        "com.ibm.ws.sib.processor.impl.store.items.MessageItem.getPersistentData",
                                        "1:861:1.244.1.40",
                                        this);

            SibTr.exception(tc, e);
            SibTr.error(tc, "MESSAGE_CORRUPT_ERROR_CWSIP0262",
                        new Object[] {
                        SIMPUtils.getStackTrace(e)
                        });

            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                SibTr.exit(this, tc, "getPersistentData", e);

            throw new PersistentDataEncodingException(
                            nls.getFormattedMessage(
                                                    "MESSAGE_CORRUPT_ERROR_CWSIP0262",
                                                    new Object[] {
                                                    e },
                                                    null),
                            e);
        } catch (MessageStoreException e)
        {
            // No FFDC code needed
            // We dont generate an FFDC here as this is sometimes acceptable behaviour - d542075

            SibTr.exception(tc, e);

            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                SibTr.exit(this, tc, "getPersistentData", e);

            throw new PersistentDataEncodingException(e);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "getPersistentData");

        return data;
    }
568528
def _fetch_messages(self):
        
        try:
            [_, msg] = self.socket.recv_multipart(flags=zmq.NOBLOCK)
            if Global.CONFIG_MANAGER.tracing_mode:
                Global.LOGGER.debug("fetched a new message")

            self.fetched = self.fetched + 1
            obj = pickle.loads(msg)
            self._deliver_message(obj)
            return obj
        except zmq.error.Again:
            return None
        except Exception as new_exception:
            Global.LOGGER.error(new_exception)
            raise new_exception
878967
public String getMessage(Context context) {
        if (customMessage != null) {
            return customMessage;
        }
        return context.getResources().getString(message);
    }
894669
def message(self, message, item, extra):
        """"""
        if item is not None:
            message += ": " + ascii(item)
        if extra is not None:
            message += " (" + str(extra) + ")"
        return message
110866
def get_messages_from_stream(data):
    
    messages = []
    iterator = HEADER_RE.finditer(data)
    last_pos = 0
    for match in iterator:
        pos = match.span()[0]
        header = read_machine_header(data[pos:])
        h_len = __get_machine_header_length(header)
        cur_last_pos = pos + h_len + header['meta_len'] + header['data_len']

        if cur_last_pos > len(data):
            break

        header, meta, bin_data = parse_message(data[pos:])
        messages.append({'header': header, 'meta': meta, 'data': bin_data})

        last_pos = cur_last_pos

    data = data[last_pos:]
    return messages, data
1337722
def Get(self):
    """"""
    try:
      value, reg_type = winreg.QueryValueEx(_GetServiceKey(), "Transaction")
    except OSError:
      return

    if reg_type != winreg.REG_BINARY:
      return

    try:
      return rdf_flows.GrrMessage.FromSerializedString(value)
    except message.Error:
      return
1274490
async def get_message(self, ignore_subscribe_messages=False, timeout=0):
        
        response = await self.parse_response(block=False, timeout=timeout)
        if response:
            return self.handle_message(response, ignore_subscribe_messages)
        return None
914182
def _getMessage(session, txid):
    """"""

    while True:
        if txid in session.messages:
            msg = session.messages[txid]
            del session.messages[txid]
            return msg
        else:
            try:
                # apparently any timeout at all allows the thread to be
                # stopped but none make it unstoppable with ctrl+c
                nextMessage = session.queue.get(timeout=100)
            except queue.Empty:
                continue
            if 'txid' in nextMessage:
                session.messages[nextMessage['txid']] = nextMessage
            else:
                logger.info("message with no txid: %s" % nextMessage)
1293174
@Override
    public final Serializable getSystemContextItem(String name) throws IOException, ClassNotFoundException {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "getSystemContextItem", name);

        Serializable item = null;

        if (name != null) {

            /* Try getting the property from the Map */
            if (mayHaveSystemContext()) {
                item = (Serializable) getSystemContextMap().get(name);
            }

            /* If the item is null (i.e. no such property) just return it. */
            /* If the item was a String, Boolean or Number it isn't serialized so */
            /* we already have the item to return. */
            if ((item == null)
                || item instanceof String
                || item instanceof Number
                || item instanceof Boolean) {
            }

            /* Otherwise, it is a byte array of some sort & needs some work done. */
            else {
                item = restoreMapObject((byte[]) item);
            }

        }
        else {
            throw new IllegalArgumentException("null");
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "getSystemContextItem", item);
        return item;
    }
501210
private ResourceBundleHolder loadMessageBundle(Method m) throws ClassNotFoundException {
        Class c = m.getDeclaringClass();
        Class<?> msg = c.getClassLoader().loadClass(c.getName().substring(0, c.getName().lastIndexOf(".")) + ".Messages");
        return ResourceBundleHolder.get(msg);
    }
470897
@Override
    public final List<DataSlice> readDataFromPersistence() throws SevereMessageStoreException
    {
        List<DataSlice> dataSlices;
        // lazy restoration only needed if the item was stored.  There is
        // no point trying to restore if there is no data.
        PersistentMessageStore pm = getMessageStoreImpl().getPersistentMessageStore();
        try
        {
            dataSlices = pm.readDataOnly(getTuple());
        } catch (PersistenceException pe)
        {
            com.ibm.ws.ffdc.FFDCFilter.processException(pe, "com.ibm.ws.sib.msgstore.cache.links.AbstractItemLink.readDataFromPersistence", "1:3271:1.241", this);
            throw new SevereMessageStoreException(pe);
        }

        return dataSlices;
    }
780119
public void getPersistentData(ObjectOutputStream oos)
  {
    if (tc.isEntryEnabled())
      SibTr.entry(tc, "getPersistentData", oos);

    super.getPersistentData(oos);
    
    try
    {
      HashMap hm = new HashMap();

      if (durableSubName != null)
        hm.put("durableSubName", durableSubName);
      
      oos.writeObject(hm);
    }
    catch (IOException e)
    {
      // FFDC
      FFDCFilter.processException(
        e,
        "com.ibm.ws.sib.processor.impl.store.itemstreams.PtoPReceiveMsgsItemStream.getPersistentData",
        "1:301:1.26.1.2",
        this);
        
      SibTr.exception(tc, e);
      if (tc.isEntryEnabled()) SibTr.exit(tc, "getPersistentData", "SIErrorException");
      
      throw new SIErrorException(
       nls.getFormattedMessage(
        "INTERNAL_MESSAGING_ERROR_CWSIP0003",
        new Object[] {
          "com.ibm.ws.sib.processor.impl.store.itemstreams.PtoPMessageItemStream",
          "1:312:1.26.1.2",
          e,
          getDestinationHandler().getName()},
        null),
        e);
    }

    if (tc.isEntryEnabled())
      SibTr.exit(tc, "getPersistentData");
  }
783163
public final void eventWatermarkBreached() throws SevereMessageStoreException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "eventWatermarkBreached");

        ItemStream itemStream = (ItemStream)getItem();
        if (null != itemStream)
        {
            if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) SibTr.debug(this, tc, "notifying eventWatermarkBreached: "+itemStream);

            itemStream.eventWatermarkBreached();

            if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) SibTr.debug(this, tc, "notified eventWatermarkBreached: "+itemStream);
        }
        else
        {
            if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) SibTr.debug(this, tc, "no itemStream to notify");
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(this, tc, "eventWatermarkBreached");
    }