/* (non-Javadoc)
@see com.ibm.ws.sib.processor.impl.interfaces.DestinationHandler#getMaxFailedDeliveries()
490511
public long getBlockedRetryInterval()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "getBlockedRetryInterval"); 
    
    if (_blockedRetryInterval < 0)
      _blockedRetryInterval = definition.getBlockedRetryTimeout();
    
    // If BlockedRetryInterval is unset on the destination, retrieve the ME-wide value
    if (_blockedRetryInterval < 0)
      _blockedRetryInterval = messageProcessor.getCustomProperties().get_blocked_retry_timeout();
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "getBlockedRetryInterval", Long.valueOf(_blockedRetryInterval));
    
    return _blockedRetryInterval;
  }
334801
@Override
    public boolean onFailedToRecycleView(RecyclerView.ViewHolder holder) {
        if (mVerbose) Log.v(TAG, "onFailedToRecycleView: " + holder.getItemViewType());
        return mOnBindViewHolderListener.onFailedToRecycleView(holder, holder.getAdapterPosition()) || super.onFailedToRecycleView(holder);
    }
1320782
public SIMPIterator getTransmitMessagesIterator(int maxMsgs)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "getTransmitMessagesIterator");
    
    // TODO : Method needs to throw SIMPRuntimInvalid to admin
    
    SIMPIterator returnIterator = null;
 
    Iterator<TickRange> messagesOnStream =
      _sourceStream.getAllMessageItemsOnStream(true).iterator();
    
     //now build a collection of TransmitMessageControllable
    Collection<SIMPTransmitMessageControllable> transmitMessages = 
      new LinkedList<SIMPTransmitMessageControllable>();
    
    boolean allMsgs = 
      (maxMsgs == SIMPConstants.SIMPCONTROL_RETURN_ALL_MESSAGES); 
    
    int index = 0;
    while((allMsgs || (index < maxMsgs)) && messagesOnStream.hasNext())
    {
      try
      {
        TickRange tr = messagesOnStream.next();
        if(tr.value == null)
          transmitMessages.add(new LinkTransmitMessageControl(tr.itemStreamIndex, _sourceStream, _downControl));  
        else
          transmitMessages.add(new LinkTransmitMessageControl(((SIMPMessage)tr.value), _sourceStream));  
         
        index++;
      }
      catch (SIResourceException e)
      {
        // No FFDC code needed  
        SibTr.exception(tc, e);      
      }
    }
    returnIterator = 
      new TransmitMessageControllableIterator(transmitMessages.iterator());
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.exit(tc, "getTransmitMessagesIterator", returnIterator);      
    return returnIterator;
  }
81929
public java.util.List<SendMessageBatchResultEntry> getSuccessful() {
        if (successful == null) {
            successful = new com.amazonaws.internal.SdkInternalList<SendMessageBatchResultEntry>();
        }
        return successful;
    }
1306944
function getCompletedTargets($maxResults) {
		$projects = $this->getProjects ();
		$tickets = array ();
		$i = 0;
		foreach ( $projects as $project ) {
			$tickets [$i ++] = $project->ticket;
		}
		
		$getCompletedTargetsByProjectsRequest = new getCompletedTargetsByProjects ();
		
		$getCompletedTargetsByProjectsRequest->projectTickets = $tickets;
		$getCompletedTargetsByProjectsRequest->maxResults = $maxResults;
		
		$completedTargets = $this->targetService->getCompletedTargetsByProjects ( $getCompletedTargetsByProjectsRequest )->return;
		
		return $this->_convertTargetsToInternal ( $completedTargets );
	}
23075
static byte[] marshall(final DevFailed devFailed) throws DevFailed {
        XLOGGER.entry();
        final CDROutputStream os = new CDROutputStream();
        try {
            DevErrorListHelper.write(os, devFailed.errors);
            XLOGGER.exit();
            return cppAlignment(os.getBufferCopy());
        } finally {
            os.close();
        }
    }
421780
public Set<Address> getDestination(MessageID messageID) {
        MessageInfo messageInfo = sentMessages.get(messageID);
        Set<Address> destination;
        if (messageInfo != null) {
            destination = new HashSet<>(messageInfo.destinations);
        } else {
            destination = Collections.emptySet();
        }
        return destination;
    }
287229
public function getExecutionsByDelivery(core_kernel_classes_Resource $compiled)
    {
        $query = $this->getQueryBuilder()
            ->select("*")
            ->from(self::TABLE_NAME)
            ->where(self::COLUMN_DELIVERY_ID . " = :deliveryId")
            ->setParameter("deliveryId", $compiled->getUri())
        ;

        return array_map(function($row) {
            return $this->parseQueryResult($row);
        }, $query->execute()->fetchAll());
    }
321794
public List<String> receiveTextMessages(int maxSize) {
        List<String> messages = new ArrayList<>();
        try {
            while (messages.size() <= maxSize){
                TextMessage message = (TextMessage) consumer.receive(timeout);
                if (message == null) {
                    return messages;
                }else {
                    messages.add(message.getText());
                }
            }
        } catch (JMSException e) {
            throw new AsyncException(e);
        }
        return messages;
    }
632951
public java.util.List<FailedScheduledUpdateGroupActionRequest> getFailedScheduledUpdateGroupActions() {
        if (failedScheduledUpdateGroupActions == null) {
            failedScheduledUpdateGroupActions = new com.amazonaws.internal.SdkInternalList<FailedScheduledUpdateGroupActionRequest>();
        }
        return failedScheduledUpdateGroupActions;
    }
44154
public java.util.List<FailedCreateWorkspaceRequest> getFailedRequests() {
        if (failedRequests == null) {
            failedRequests = new com.amazonaws.internal.SdkInternalList<FailedCreateWorkspaceRequest>();
        }
        return failedRequests;
    }
250501
protected static List<String> listDeliveryStreams() {
        ListDeliveryStreamsRequest listDeliveryStreamsRequest = new ListDeliveryStreamsRequest();
        ListDeliveryStreamsResult listDeliveryStreamsResult =
                firehoseClient.listDeliveryStreams(listDeliveryStreamsRequest);
        List<String> deliveryStreamNames = listDeliveryStreamsResult.getDeliveryStreamNames();
        while (listDeliveryStreamsResult.isHasMoreDeliveryStreams()) {
            if (deliveryStreamNames.size() > 0) {
                listDeliveryStreamsRequest.setExclusiveStartDeliveryStreamName(deliveryStreamNames.get(deliveryStreamNames.size() - 1));
            }

            listDeliveryStreamsResult = firehoseClient.listDeliveryStreams(listDeliveryStreamsRequest);
            deliveryStreamNames.addAll(listDeliveryStreamsResult.getDeliveryStreamNames());

        }
        return deliveryStreamNames;
    }
1283713
public java.util.List<? extends com.google.rpc.QuotaFailure.ViolationOrBuilder> 
      getViolationsOrBuilderList() {
    return violations_;
  }
1165211
protected int getMaxMessageLength(Dsn dsn) {
        return Util.parseInteger(
            Lookup.lookup(MAX_MESSAGE_LENGTH_OPTION, dsn), JsonMarshaller.DEFAULT_MAX_MESSAGE_LENGTH);
    }
1270403
public List<String> getSubscriptionList() throws SIResourceException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "getSubscriptionList");
        List<String> subscriptions = null;

        // Build up a list of subscriptions on the destination
        try
        {
            NonLockingCursor cursor =
                            _pubsubMessageItemStream.newNonLockingReferenceStreamCursor(
                                            new ClassEqualsFilter(
                                                            SubscriptionItemStream.class,
                                                            DurableSubscriptionItemStream.class));
            SubscriptionItemStream subscription =
                            (SubscriptionItemStream) cursor.next();

            while (subscription != null)
            {
                if (subscriptions == null)
                {
                    subscriptions = new LinkedList<String>();
                }
                subscriptions.add(
                                subscription
                                                .getConsumerDispatcher()
                                                .getConsumerDispatcherState()
                                                .getSubscriberID());
                subscription = (SubscriptionItemStream) cursor.next();
            }

            cursor.finished();
        } catch (MessageStoreException e)
        {
            FFDCFilter.processException(
                                        e,
                                        "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.getSubscriptionList",
                                        "1:2579:1.35.2.4",
                                        this);

            SibTr.exception(tc, e);
            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                SibTr.exit(tc, "getSubscriptionList", "SIResourceException");
            throw new SIResourceException(e);
        }
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "getSubscriptionList", subscriptions);
        return subscriptions;
    }
778500
public java.util.List<FailedRemediationBatch> getFailedBatches() {
        if (failedBatches == null) {
            failedBatches = new com.amazonaws.internal.SdkInternalList<FailedRemediationBatch>();
        }
        return failedBatches;
    }
319234
@Override
    public List<Pair<Long, String>> getLastNRegisteredInstances() {
        List<Pair<Long, String>> list = new ArrayList<Pair<Long, String>>();

        synchronized (recentRegisteredQueue) {
            for (Pair<Long, String> aRecentRegisteredQueue : recentRegisteredQueue) {
                list.add(aRecentRegisteredQueue);
            }
        }
        Collections.reverse(list);
        return list;
    }