Adds a msgId to the list of uninitialised msg references
494316
public void addUnrestoredMsgId(long msgId)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "addUnrestoredMsgId", new Long(msgId));

    unrestoredMsgIds.add(new Long(msgId));

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "addUnrestoredMsgId");
  }
938311
public ImmutableList<SoyMsgPart> getSoyMsgParts(
      long msgId, ImmutableList<SoyMsgPart> defaultMsgParts) {
    ImmutableList<SoyMsgPart> msgParts = msgBundle.getMsgParts(msgId);
    if (msgParts.isEmpty()) {
      return defaultMsgParts;
    }
    return msgParts;
  }
1017577
private static void appendAltIDs(StringBuilder logMsg, String[] altIDs) {
        logMsg.append(", altIDs: ");
        if (altIDs == null) {
            logMsg.append("null");
        } else {
            for (String altID : altIDs) {
                logMsg.append("'").append(altID).append("'");
            }
        }
    }
677284
public void addMessage(final boolean encode, final String msg, final Serializable... args) {
		MessageModel model = getOrCreateComponentModel();
		model.messages.add(new Duplet<>(I18nUtilities.asMessage(msg, args), encode));
		// Potential for leaking memory here
		MemoryUtil.checkSize(model.messages.size(), this.getClass().getSimpleName());
	}
965972
private void addBestEffortMessage(SIMPMessage msgItem) throws SIResourceException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "addBestEffortMessage", new Object[] { msgItem });
    
    // Get the JsMessage as we need to update the Guaranteed fields
    JsMessage jsMsg = msgItem.getMessage();
 
    long tick = this.messageProcessor.nextTick();

    //Set a unique id in the message if explicitly told to or
    //if one has not already been set
    if(msgItem.getRequiresNewId()  ||  jsMsg.getSystemMessageId()==null)
    {
      jsMsg.setSystemMessageSourceUuid(this.messageProcessor.getMessagingEngineUuid());
      jsMsg.setSystemMessageValue(tick);
      msgItem.setRequiresNewId(false);
    }

    jsMsg.setGuaranteedValueEndTick(tick);
    jsMsg.setGuaranteedValueValueTick(tick);
    jsMsg.setGuaranteedValueRequestedOnly(false);

    // Keep MFP happy
    jsMsg.setGuaranteedValueStartTick(-1);
    jsMsg.setGuaranteedValueCompletedPrefix(-1);

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "addBestEffortMessage");
  }
1232254
@Override
    protected void write(List<Message> msgList) throws IOException {
        for (Message msg : msgList) {
            writer.writeTo(msg);

            String routingKey = normalizeRoutingKey(msg);

            DynamicCounter.increment(
                    MonitorConfig.builder("writtenMessages")
                            .withTag(TagKey.DATA_SOURCE, routingKey)
                            .build());
            ++writtenMessages;
            DynamicCounter.increment(
                    MonitorConfig.builder("writtenBytes")
                            .withTag(TagKey.DATA_SOURCE, routingKey)
                            .build(), msg.getPayload().length);
            writtenBytes += msg.getPayload().length;

            messageWrittenInRotation = true;
        }

        writer.sync();

        throughput.increment(msgList.size());
    }
637782
def populate_instance(msg, inst):
    
    return _to_inst(msg, type(inst).__name__, type(inst).__name__, inst)
77270
public static void i(String msg, Throwable tr) {
    assertInitialization();
    sLogger.i(msg, tr);
  }
1211760
def msgid
      begin
        if @scanner.scan(/msgid/)
          skip_whitespace
          text = message_line
          add_result(:msgid, text)
          message_multiline(:msgid) if text.empty?
          if msgid_plural
            msgstr_plural
          else
            msgstr
          end
        else
          err_msg = "Message without msgid is not allowed."
          err_msg += "The Line started unexpectedly with #{@scanner.peek(10).inspect}."
          raise PoSyntaxError, err_msg
        end
      rescue PoSyntaxError => pe
        raise PoSyntaxError, "Syntax error in msgid\n" + pe.message, pe.backtrace
      end

    end
1238750
public void init(BaseMessageManager manager, String strQueueName, String strQueueType)
    {
        m_manager = manager;
        m_strQueueName = strQueueName;
        m_strQueueType = strQueueType;
        
        if (m_manager != null)
            m_manager.addMessageQueue(this);
    }
1353604
public final void initDefault() {
    try {
      this.messages = null;
      this.messages = ResourceBundle.getBundle("Messages");
    } catch (Exception e) {
      this.logger.error(null, SrvI18n.class,
        " when loading msgs for default locale ", e);
    }
    if (messages != null) {
      this.messagesMap.put(Locale.getDefault().getLanguage(), this.messages);
      this.logger.info(null, SrvI18n.class,
        "Added messages for default locale: " + Locale.getDefault());
    } else {
      //If there is no MessagesBundle[current-locale].properties
      this.logger.error(null, SrvI18n.class,
        "There is no messages for current locale: " + Locale.getDefault());
    }
  }
1333158
def hlr_create(self, msisdn, reference):
        """"""
        return HLR().load(self.request('hlr', 'POST', {'msisdn': msisdn, 'reference': reference}))
1008590
def msgid_plural
      begin
        if @scanner.scan(/msgid_plural/)
          skip_whitespace
          text = message_line
          add_result(:msgid_plural, text)
          message_multiline(:msgid_plural) if text.empty?
          true
        else
          false
        end
      rescue PoSyntaxError => pe
        raise PoSyntaxError, "Syntax error in msgid\n" + pe.message, pe.backtrace
      end
    end
361042
def iter_init_append(self) :
        ""
        iter = self.AppendIter(None)
        dbus.dbus_message_iter_init_append(self._dbobj, iter._dbobj)
        return \
            iter
123482
public static synchronized void initializeDefaults(String serverName, boolean useMsgs) {
        allUseMsgs = useMsgs;
        cacheServerName = serverName;
        addBundleRepository(Utils.getInstallDir().getAbsolutePath(), ExtensionConstants.CORE_EXTENSION);
        addBundleRepository(new File(Utils.getUserDir(), "/extension/").getAbsolutePath(), ExtensionConstants.USER_EXTENSION);
    }
391854
def _AddMessageMethods(message_descriptor, cls):
  """"""
  _AddListFieldsMethod(message_descriptor, cls)
  _AddHasFieldMethod(message_descriptor, cls)
  _AddClearFieldMethod(message_descriptor, cls)
  if message_descriptor.is_extendable:
    _AddClearExtensionMethod(cls)
    _AddHasExtensionMethod(cls)
  _AddEqualsMethod(message_descriptor, cls)
  _AddStrMethod(message_descriptor, cls)
  _AddReprMethod(message_descriptor, cls)
  _AddUnicodeMethod(message_descriptor, cls)
  _AddByteSizeMethod(message_descriptor, cls)
  _AddSerializeToStringMethod(message_descriptor, cls)
  _AddSerializePartialToStringMethod(message_descriptor, cls)
  _AddMergeFromStringMethod(message_descriptor, cls)
  _AddIsInitializedMethod(message_descriptor, cls)
  _AddMergeFromMethod(cls)
  _AddWhichOneofMethod(message_descriptor, cls)
  _AddReduceMethod(cls)
  # Adds methods which do not depend on cls.
  cls.Clear = _Clear
  cls.DiscardUnknownFields = _DiscardUnknownFields
  cls._SetListener = _SetListener
2981
private void handleMsgIdCall(FunctionNode fn, MsgFallbackGroupNode msgNode) {
    ExprNode msgIdNode;
    long primaryMsgId = MsgUtils.computeMsgIdForDualFormat(msgNode.getChild(0));
    if (msgNode.numChildren() == 1) {
      // easy peasy
      msgIdNode = createMsgIdNode(primaryMsgId, fn.getSourceLocation());
    } else {
      long fallbackMsgId = MsgUtils.computeMsgIdForDualFormat(msgNode.getChild(1));
      ConditionalOpNode condOpNode = new ConditionalOpNode(fn.getSourceLocation());
      FunctionNode isPrimaryMsgInUse =
          new FunctionNode(
              Identifier.create(
                  BuiltinFunction.IS_PRIMARY_MSG_IN_USE.getName(), fn.getSourceLocation()),
              BuiltinFunction.IS_PRIMARY_MSG_IN_USE,
              fn.getSourceLocation());
      // We add the varRef, and the 2 message ids to the funcitonnode as arguments so they are
      // trivial to access in the backends.  This is a little hacky however since we never generate
      // code for these things.
      // We could formalize the hack by providing a way to stash arbitrary data in the FunctionNode
      // and then just pack this up in a non-AST datastructure.
      isPrimaryMsgInUse.addChild(fn.getChild(0).copy(new CopyState()));
      isPrimaryMsgInUse.addChild(new IntegerNode(primaryMsgId, fn.getSourceLocation()));
      isPrimaryMsgInUse.addChild(new IntegerNode(fallbackMsgId, fn.getSourceLocation()));
      condOpNode.addChild(isPrimaryMsgInUse);
      condOpNode.addChild(createMsgIdNode(primaryMsgId, fn.getSourceLocation()));
      condOpNode.addChild(createMsgIdNode(fallbackMsgId, fn.getSourceLocation()));
      msgIdNode = condOpNode;
    }
    // We need to generate a record literal
    // This map literal has 2 keys: 'id' and 'msg'
    RecordLiteralNode recordLiteral =
        new RecordLiteralNode(
            Identifier.create("record", fn.getSourceLocation()),
            ImmutableList.of(
                Identifier.create("id", fn.getSourceLocation()),
                Identifier.create("msg", fn.getSourceLocation())),
            fn.getSourceLocation());
    recordLiteral.addChildren(ImmutableList.of(msgIdNode, fn.getChild(0).copy(new CopyState())));
    fn.getParent().replaceChild(fn, recordLiteral);
  }