/* (non-Javadoc)
@see com.ibm.ws.sib.processor.runtime.SIMPMessageHandlerControllable#isTemporary()
193970
public boolean isTemporary()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "isTemporary");    
    boolean isTemporary = _foreignBus.isTemporary();
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.exit(tc, "isTemporary", new Boolean(isTemporary));      
    return isTemporary;
  }
213743
@Override
    public Query setParameter(Parameter<Calendar> paramParameter, Calendar paramCalendar, TemporalType paramTemporalType)
    {
        throw new UnsupportedOperationException("setParameter is unsupported by Kundera");
    }
177426
@Override
    public void setMessageControlClassification(String classification)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setMessageControlClassification", classification);
        JsMessage localMsg = getJSMessage(true);

        // Cannot set this parameter on a Control message
        if (localMsg.isApiMessage())
        {
            if (localMsg instanceof JsApiMessage)
            {
                ((JsApiMessage) localMsg).setMessageControlClassification(classification);
                messageControlClassification = classification;
            }
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "setMessageControlClassification");
    }
135435
public void assertValidControllable() throws SIMPControllableNotFoundException
  {
    TickRange range = getTickRange();
    if(range.type != TickRange.Uncommitted && range.type != TickRange.Value)
    {
      SIMPControllableNotFoundException finalE =
        new SIMPControllableNotFoundException(
          nls.getFormattedMessage(
            "INTERNAL_MESSAGING_ERROR_CWSIP0005",
            new Object[] {"TransmitMessage.assertValidControllable",
                "1:346:1.42",
                          new Long(_tick)},
            null));
  
      SibTr.exception(tc, finalE);
      throw finalE;
    }
  }
1075662
public function isTemporal()
    {
        return in_array($this->type, [
            PropelTypes::TIMESTAMP,
            PropelTypes::DATE,
            PropelTypes::TIME,
            PropelTypes::BU_DATE,
            PropelTypes::BU_TIMESTAMP,
        ]);
    }
26333
public void assertValidControllable() throws SIMPControllableNotFoundException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "checkValidControllable");
    
    if(referenceItemStream == null || !referenceItemStream.isInStore())
    {
      SIMPControllableNotFoundException finalE =
        new SIMPControllableNotFoundException(
          nls.getFormattedMessage(
            "INTERNAL_MESSAGING_ERROR_CWSIP0005",
            new Object[] {"LocalSubscriptionControl.assertValidControllable",
                          "1:448:1.36",
                          referenceItemStream},
            null));
            
      SibTr.exception(tc, finalE);
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exception(tc, finalE);
      throw finalE; 
    }
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "checkValidControllable");
  }
1193237
public final void checkTemporaryDestinationScope( Destination destination ) throws JMSException
    {
    	if (destination instanceof LocalQueue)
    	{
    		LocalQueue localQueue = (LocalQueue)destination; 
	        if (localQueue.isTemporary() && !connection.isRegisteredTemporaryQueue(localQueue.getQueueName()))
	       		throw new IllegalStateException("Temporary queue does not belong to session's connection.");
    	}
    	else
    	if (destination instanceof LocalTopic)
    	{	
    		LocalTopic localTopic = (LocalTopic)destination; 
	        if (localTopic.isTemporary() && !connection.isRegisteredTemporaryTopic(localTopic.getTopicName()))
	       		throw new IllegalStateException("Temporary topic does not belong to session's connection.");
    	}
    	else
    		throw new FFMQException("Unexpected destination type : "+destination,"INTERNAL_ERROR");
    }
706913
public void setEnabled(boolean isEnabled) {
        mCardNumberEditText.setEnabled(isEnabled);
        mExpiryDateEditText.setEnabled(isEnabled);
        mCvcNumberEditText.setEnabled(isEnabled);
    }
719643
protected void removeTemporaryDestination(JmsTemporaryDestinationInternal tempDest) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "removeTemporaryDestination", System.identityHashCode(tempDest));

        synchronized (temporaryDestinations) { // synchronize against addTemporaryDestination
            temporaryDestinations.remove(tempDest);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "removeTemporaryDestination");
    }
446600
public void isTyping(@NonNull final String conversationId, @Nullable Callback<ComapiResult<Void>> callback) {
        adapter.adapt(isTyping(conversationId, true), callback);
    }
85666
@Override
    public void registerForEvents(SIMPMessage msg)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "registerForEvents", msg);

        msg.registerMessageEventListener(MessageEvents.EXPIRY_NOTIFICATION, this);
        msg.registerMessageEventListener(
                                         MessageEvents.REFERENCES_DROPPED_TO_ZERO,
                                         this);

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "registerForEvents");
    }
1131261
@Override
    public synchronized boolean hasCapability(final String capability) throws MessagingException {
        return capability != null
                && (capability.toLowerCase().startsWith("IMAP4") || capability.toLowerCase().startsWith("IDLE") || capability.toLowerCase()
                        .startsWith("ID"));
    }
588341
public SIMPMessageProcessorControllable getMessageProcessor()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
    {
      SibTr.entry(tc, "getMessageProcessor");
      SibTr.exit(tc, "getMessageProcessor"); 
    }
    return (SIMPMessageProcessorControllable)messageProcessor.getControlAdapter();
  }
1127406
public SIMPIterator getQueuedMessageIterator() 
  throws SIMPRuntimeOperationFailedException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "getQueuedMessageIterator");

    List<ControlAdapter> messages = new ArrayList<ControlAdapter>();
    
    NonLockingCursor cursor = null;
    try
    {
      cursor = itemStream.newNonLockingItemCursor(null);
      cursor.allowUnavailableItems();
      MessageItem item = (MessageItem)cursor.next();
      while(item != null)
      {
        // force the arrival time to be written to the jsMessage  
        item.forceCurrentMEArrivalTimeToJsMessage();
        
        // It's possible to get a null adapter back 
        ControlAdapter cAdapter = item.getControlAdapter();
        if(cAdapter != null)
          messages.add(cAdapter);
        
        item = (MessageItem)cursor.next();      
      }      
    }
    catch (MessageStoreException e)
    {
      FFDCFilter.processException(
          e,
          "com.ibm.ws.sib.processor.runtime.LocalQueuePoint.getQueuedMessageIterator",
          "1:264:1.58", 
          this);
      SibTr.exception(tc, e);
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
        SibTr.exit(tc, "getQueuedMessageIterator", e);
      throw new SIMPRuntimeOperationFailedException(e);
    }
    finally
    {
      if (cursor != null)
        cursor.finished();
    }

    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "getQueuedMessageIterator");
      
    return new BasicSIMPIterator(messages.iterator());    
  }
371075
public boolean invokeEndpoint(final MessageEndpoint endpoint,
            final SIBusMessage message, final AbstractConsumerSession session,
            final SITransaction transaction, String debugMEName)
            throws ResourceAdapterInternalException {

        final String methodName = "invokeEndpoint";
        if (TRACE.isEntryEnabled()) {
            SibTr.entry(this, TRACE, methodName, new Object[] { endpoint,
                    message, session, transaction });
        }

        // Check that endpoint is a SibRaMessageListener
        if (!(endpoint instanceof SibRaMessageListener)) {

            throw new ResourceAdapterInternalException(NLS.getFormattedMessage(
                    ("UNEXPECTED_ENDPOINT_CWSIV0850"), new Object[] { endpoint,
                            SibRaMessageListener.class }, null));

        }

        final SibRaMessageListener listener = (SibRaMessageListener) endpoint;

        // Wrap session before passing to MDB
        final SibRaAbstractConsumerSession wrappedSession = new SibRaAbstractConsumerSession(
                session);

        boolean success;
        try {

            // Deliver message
            listener.onMessage(message, wrappedSession, transaction);
            success = true;

        } catch (final Throwable exc) {

            // Failed to deliver message
            FFDCFilter.processException(exc, CLASS_NAME + "." + methodName,
                    FFDC_PROBE_1, this);
            if (TRACE.isEventEnabled()) {
                SibTr.exception(this, TRACE, exc);
            }
            success = false;
            // If the throwable is a ThreadDeath then we want to rethrow the
            // exception to make sure that the thread dies correctly
            if (exc instanceof ThreadDeath)
            {
              // we cast to a threaddeath so we don't have to declare the throwable
              throw (ThreadDeath)exc;
            }

        } finally {

            // Stop an MDB that has cached the session reusing it
            wrappedSession.outOfScope();

        }

        if (TRACE.isEntryEnabled()) {
            SibTr.exit(this, TRACE, methodName, Boolean.valueOf(success));
        }
        return success;

    }
666849
@Override
  public <T> Completes<Optional<T>> maybeActorOf(Class<T> protocol, Address address) {
    final T typed = internalActorOf(protocol, address);
    final Optional<T> maybe = typed == null ? Optional.empty() : Optional.of(typed);
    return completes().with(maybe);
  }
18052
@Override
    public void notifyRCDReceiveExclusiveChange(boolean isReceiveExclusive)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "notifyRCDReceiveExclusiveChange", new Object[] { Boolean.valueOf(isReceiveExclusive) });

        // Only do this for ptp as it does not seem to make sense for p/s
        if (!isPubSub())
        {
            //if this is a RMQ destination then there is no RCD to
            //worry about, so we only need be concerned with the case of a JS
            //q point.
            if (_ptoPRealization != null)
            {
                _ptoPRealization.getRemoteSupport().
                                notifyRCDReceiveExclusiveChange(isReceiveExclusive);
            }

        }
        else
        {
            // sanity check
            // log error
            SIErrorException e =
                            new SIErrorException(
                                            nls.getFormattedMessage(
                                                                    "INTERNAL_MESSAGING_ERROR_CWSIP0001",
                                                                    new Object[] {
                                                                                  "com.ibm.ws.sib.processor.impl.BaseDestinationHandler",
                                                                                  "1:1458:1.700.3.45" },
                                                                    null));
            FFDCFilter.processException(
                                        e,
                                        "com.ibm.ws.sib.processor.impl.BaseDestinationHandler.notifyRCDReceiveExclusiveChange",
                                        "1:1463:1.700.3.45",
                                        this);
            SibTr.exception(tc, e);

            SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0001",
                        new Object[] {
                                      "com.ibm.ws.sib.processor.impl.BaseDestinationHandler",
                                      "1:1470:1.700.3.45" });

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

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