This method will set the initial request number for this conversation.

@param initialRequestNumber
174988
public void setInitialRequestNumber(int initialRequestNumber)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setInitialRequestNumber", Integer.valueOf(initialRequestNumber));
        this.requestNumber = initialRequestNumber;
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setInitialRequestNumber");
    }
116180
public final void initColumnNumber(int columnNumber)
    {
        if (columnNumber <= 0) throw new IllegalArgumentException(String.valueOf(columnNumber));
        if (this.columnNumber > 0) throw new IllegalStateException();
        this.columnNumber = columnNumber;
    }
708817
@Override
  public final void initialize(final PhoneNumberValueRest pconstraintAnnotation) {
    message = pconstraintAnnotation.message();
    fieldPhoneNumber = pconstraintAnnotation.fieldPhoneNumber();
    fieldCountryCode = pconstraintAnnotation.fieldCountryCode();
    allowDin5008 = pconstraintAnnotation.allowDin5008();
    allowE123 = pconstraintAnnotation.allowE123();
    allowUri = pconstraintAnnotation.allowUri();
    allowMs = pconstraintAnnotation.allowMs();
    allowCommon = pconstraintAnnotation.allowCommon();
  }
396546
void addRequest(final InstanceType instanceType, final int numberOfInstances) {

		Integer numberOfRemainingInstances = this.pendingRequests.get(instanceType);
		if (numberOfRemainingInstances == null) {
			numberOfRemainingInstances = Integer.valueOf(numberOfInstances);
		} else {
			numberOfRemainingInstances = Integer.valueOf(numberOfRemainingInstances.intValue() + numberOfInstances);
		}

		this.pendingRequests.put(instanceType, numberOfRemainingInstances);
	}
1112519
public void initForNextResponse(IResponse resp) {
        if (com.ibm.ejs.ras.TraceComponent.isAnyTracingEnabled()&&logger.isLoggable (Level.FINE))  //306998.15
            logger.entering(CLASS_NAME,"initForNextResponse", "resp = " + resp + " ["+this+"]");

        if (resp == null) {
            _rawOut.init(null);
            _bufferedWriter.clean();
            if (com.ibm.ejs.ras.TraceComponent.isAnyTracingEnabled()&&logger.isLoggable (Level.FINE))  //306998.15
                logger.exiting(CLASS_NAME,"initForNextResponse");
            return;
        }

        // reset the state before initializing it again and before calling setCommonHeaders.
        resetState();

        resp.setStatusCode(200);
        resp.setReason(REASON_OK);
        _statusCode = 200;

        // _responseContext.set(new SRTServletResponseContext());
        this._response = resp;
        
        setCommonHeaders();
        
        try
        {
            _rawOut.init(_response.getOutputStream());
        }
        catch (IOException e) {
            logger.logp(Level.SEVERE, CLASS_NAME,"initForNextResponse", "error.initializing.output.stream", e);  /*@283348.1*/
        }
        // LIBERTY _bufferedOut.reset();
        _bufferedWriter.reset();
        // LIBERTY _responseBuffer = null;
        // PK53885 start
        _bufferSize = DEFAULT_BUFFER_SIZE;       
        this._bufferedOut = createOutputStream(DEFAULT_BUFFER_SIZE); // LIBERTY
        if(this._bufferedOut instanceof WCOutputStream){
            (((WCOutputStream) this._bufferedOut).getOutput()).setObserver(this);
         }
        _encoding = null;
        _gotOutputStream = false;
        _gotWriter = false;
        this._pwriter = null;

        // Pk53885 end

        if (com.ibm.ejs.ras.TraceComponent.isAnyTracingEnabled()&&logger.isLoggable (Level.FINE))  //306998.15
            logger.exiting(CLASS_NAME,"initForNextResponse");

    }
71993
public MediaHttpUploader setInitiationRequestMethod(String initiationRequestMethod) {
    Preconditions.checkArgument(initiationRequestMethod.equals(HttpMethods.POST)
        || initiationRequestMethod.equals(HttpMethods.PUT)
        || initiationRequestMethod.equals(HttpMethods.PATCH));
    this.initiationRequestMethod = initiationRequestMethod;
    return this;
  }
431570
@Trivial
    void initForRepeatingTask(boolean isFixedRate, long initialDelay, long interval) {
        this.initialDelay = initialDelay;
        this.interval = interval;
        this.isFixedRate = isFixedRate;
    }
101765
@Override
    public void flush(int requestNumber) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "flush", "" + requestNumber);

        try {
            // Make sure it is stopped before we activate it
            if (mainConsumer.isStarted())
                getConsumerSession().stop();
            getConsumerSession().activateAsynchConsumer(true);
            if (mainConsumer.isStarted())
                getConsumerSession().start(false);

            short jfapPriority = JFapChannelConstants.getJFAPPriority(Integer.valueOf(mainConsumer.getLowestPriority())); // d172528
            if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
                SibTr.debug(this, tc, "Sending with JFAP priority of " + jfapPriority); // d172528

            try {
                getConversation().send(poolManager.allocate(),
                                       JFapChannelConstants.SEG_FLUSH_SESS_R,
                                       requestNumber,
                                       jfapPriority,
                                       true,
                                       ThrottlingPolicy.BLOCK_THREAD,
                                       null);
            } catch (SIException e) {
                FFDCFilter.processException(e,
                                            CLASS_NAME + ".flush",
                                            CommsConstants.CATASYNCHCONSUMER_FLUSH_01,
                                            this);

                if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
                    SibTr.debug(tc, e.getMessage(), e);

                SibTr.error(tc, "COMMUNICATION_ERROR_SICO2017", e);
            }
        } catch (SIException e) {
            //No FFDC code needed
            //Only FFDC if we haven't received a meTerminated event.
            if (!((ConversationState) getConversation().getAttachment()).hasMETerminated()) {
                FFDCFilter.processException(e,
                                            CLASS_NAME + ".flush",
                                            CommsConstants.CATASYNCHCONSUMER_FLUSH_02,
                                            this);
            }

            if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
                SibTr.debug(this, tc, e.getMessage(), e);

            StaticCATHelper.sendExceptionToClient(e,
                                                  CommsConstants.CATASYNCHCONSUMER_FLUSH_02,
                                                  getConversation(), requestNumber);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "flush");
    }
481019
public void setPhoneNumber(String number) {
		String phoneNumber = number;
		if(number.startsWith("+")) {			
			phoneNumber = phoneNumber.substring(1);
		}
		try {
			basePhoneNumber(phoneNumber);		
			telUrl.setPhoneNumber(phoneNumber);
		} catch (ParseException ex) {
			logger.error("Error setting phone number " + number);
			throw new java.lang.IllegalArgumentException("phone number " + number + " is invalid", ex);
		}
	}
1051051
public void setRemotePort(String pRemotePort) {
        try {
            remotePort = Integer.parseInt(pRemotePort);
        }
        catch (NumberFormatException e) {
            log("RemotePort must be a number!", e);
        }
    }
749254
@Override
  protected void initRequest()
  {
    super.initRequest();

    _uri.clear();
    _host.clear();
    _headerSize = 0;

    _remoteHost.clear();
    _remoteAddr.clear();
    _serverName.clear();
    _serverPort.clear();
    _remotePort.clear();

    _clientCert.clear();
    
    // _isSecure = getConnection().isSecure();
  }
90383
public final void initLineNumber(int lineNumber)
    {
        if (lineNumber <= 0) throw new IllegalArgumentException(String.valueOf(lineNumber));
        if (this.lineNumber > 0) throw new IllegalStateException();
        this.lineNumber = lineNumber;
    }
103338
public void setRequestingMeUuid(SIBUuid8 value) {
    if (value != null)
      jmo.setField(TrmFirstContactAccess.BODY_MELINKREQUEST_REQUESTINGMEUUID, value.toByteArray());
    else
      jmo.setField(TrmFirstContactAccess.BODY_MELINKREQUEST_REQUESTINGMEUUID, null);
  }
44768
public static void rcvXAStart(CommsByteBuffer request, Conversation conversation,
                                 int requestNumber, boolean allocatedFromBufferPool,
                                 boolean partOfExchange)
   {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(tc, "rcvXAStart",
                                           new Object[]
                                           {
                                              request,
                                              conversation,
                                              ""+requestNumber,
                                              ""+allocatedFromBufferPool,
                                              ""+partOfExchange
                                            });

      ConversationState convState = (ConversationState) conversation.getAttachment();

      try
      {
         int clientTransactionId = request.getInt();

         CATConnection catConn = (CATConnection) convState.getObject(convState.getConnectionObjectId());
         SICoreConnection connection = catConn.getSICoreConnection();

         ServerLinkLevelState linkState = (ServerLinkLevelState) conversation.getLinkLevelAttachment();
         SIXAResource xaResource = (SIXAResource)linkState.getTransactionTable().get(clientTransactionId, true);
         if (xaResource == null)
         {
            try {
                  xaResource = connection.getSIXAResource();
            }
            catch (SIConnectionUnavailableException e)
            {
               //No FFDC code needed
               //Only FFDC if we haven't received a meTerminated event.
               if(!convState.hasMETerminated())
               {
                  FFDCFilter.processException(e, CLASS_NAME + ".rcvXAStart",
                                              CommsConstants.STATICCATXATRANSACTION_XASTART_04);
               }

               // This should never happen.  We are running inside the
               // application server - so we should always be able to
               // contact a messaging engine.  Get very upset about this

               if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) SibTr.exception(tc, e);
               throw new SIErrorException(e);
            }
            catch (SIResourceException e)
            {
               FFDCFilter.processException(e,
                     CLASS_NAME + ".rcvXAStart",
                     CommsConstants.STATICCATXATRANSACTION_XASTART_05);
               if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) SibTr.exception(tc, e);
               throw new XAException(XAException.XAER_RMERR);
            }
         }

         if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled())
         {
            SibTr.debug(tc, "XAResource Object ID", clientTransactionId);
         }

         if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) SibTr.debug(tc, "Getting Xid");
         Xid xid = request.getXid();
         if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) SibTr.debug(tc, "Completed:", xid);

         int flags = request.getInt();
         if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) SibTr.debug(tc, "Flags: ", flags);

         // Now call the method on the XA resource
         xaResource.start(xid, flags);

         linkState.getTransactionTable().addGlobalTransactionBranch(clientTransactionId,
                                                                    conversation.getId(),
                                                                    xaResource,
                                                                    (XidProxy) xid,
                                                                    false);

         try
         {
            conversation.send(poolManager.allocate(),
                              JFapChannelConstants.SEG_XASTART_R,
                              requestNumber,
                              JFapChannelConstants.PRIORITY_MEDIUM,
                              true,
                              ThrottlingPolicy.BLOCK_THREAD,
                              null);
         }
         catch (SIException e)
         {
            FFDCFilter.processException(e,
                                        CLASS_NAME + ".rcvXAStart",
                                        CommsConstants.STATICCATXATRANSACTION_XASTART_01);

            SibTr.error(tc, "COMMUNICATION_ERROR_SICO2027", e);
         }
      }
      catch (XAException e)
      {
         FFDCFilter.processException(e,
                                     CLASS_NAME + ".rcvXAStart",
                                     CommsConstants.STATICCATXATRANSACTION_XASTART_02);

         if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) SibTr.debug(tc, "XAException - RC: " + e.errorCode, e);

         StaticCATHelper.sendExceptionToClient(e,
                                               CommsConstants.STATICCATXATRANSACTION_XASTART_02,
                                               conversation, requestNumber);
      }

      request.release(allocatedFromBufferPool);

      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(tc, "rcvXAStart");
   }
55215
public void setNumber(String number) {
        try {
            String iso = null;
            if (mSelectedCountry != null) {
                iso = mSelectedCountry.getIso();
            }
            Phonenumber.PhoneNumber phoneNumber = mPhoneUtil.parse(number, iso);
			
            int countryIdx = mCountries.indexOfIso(mPhoneUtil.getRegionCodeForNumber(phoneNumber));
			mSelectedCountry = mCountries.get(countryIdx);		
            mCountrySpinner.setSelection(countryIdx);
			
			
            mPhoneEdit.setText(mPhoneUtil.format(phoneNumber, PhoneNumberUtil.PhoneNumberFormat.NATIONAL));
        } catch (NumberParseException ignored) {
        }
    }
779038
public void initFunctionData(int parametersCount) {
    params = new CallParameter[parametersCount];
    for (int i = 0; i < parametersCount; i++) {
      params[i] = new CallParameter();
      if (i > 0) {
        params[i].setInput(true);
      }
    }
    // the query was in the form {?=call function()}, so the first parameter is always output
    params[0].setOutput(true);
  }
1037742
public void request(int numMessages) {
        if (subscription == null) {
            deferredInitialMessageRequest += numMessages;
            return;
        }
        deframer.request(numMessages);
        requestHttpFrame();
    }