/*
(non-Javadoc)

@see com.ibm.ws.sib.api.jmsra.JmsJcaActivationSpec#setDurableSubscriptionHome(java.lang.String)
197320
@Override
    public void setDurableSubscriptionHome(final String durableSubscriptionHome) {
        if (TraceComponent.isAnyTracingEnabled() && TRACE.isDebugEnabled()) {
            SibTr.debug(this, TRACE, "setDurableSubscriptionHome",
                        durableSubscriptionHome);
        }
        _durableSubscriptionHome = durableSubscriptionHome;
    }
1362258
@Trivial
    protected void setSslSupport(ServiceReference<ChannelFactoryProvider> ref) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) {
            Tr.entry(this, tc, "setSslSupport", new Object[] { ref.getProperty("type"), ref });
        }

        // If sslsupport is bound then set it to true 
        _isSSLEnabled = true;

        // bind can get called before unbind for new config/ modify.Hence the precaution
        if (_sslFactoryProvider.getReference() != null) { // existing chain is still there so destroy 
            if (_isChainStarted)
                performAction(destroyChainAction);
        }

        _sslFactoryProvider.setReference(ref);
        // we will only invoke createchain if 
        // 1) activate() is complete
        // this is because bind method get called first before activate and without activate we don't have any properties
        // 2) if useSSL is set in config 
        if (_isActivated && _isSSLChain) {
            //TODO: when executor service is used for performaction() make sure about sequence of destroy and create chain
            //Now currently its not threaded
            if (_isChainStarted)
                performAction(destroyChainAction);
            performAction(createChainAction);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) {
            Tr.exit(tc, "setSslSupport", _isSSLEnabled);
        }
    }
867673
public void createLocalDurableSubscription(
                                               ConsumerDispatcherState subState,
                                               TransactionCommon transaction)
                    throws
                    SIDurableSubscriptionAlreadyExistsException,
                    SIDiscriminatorSyntaxException,
                    SISelectorSyntaxException,
                    SIResourceException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(
                        tc,
                        "createLocalDurableSubscription",
                        new Object[] { subState, transaction });

        // Create new getCursor and consumer dispatchers to return to the calling method
        ConsumerDispatcher consumerDispatcher = null;

        /*
         * Lock the list of durable subscriptions to prevent others creating/using an
         * identical subscription
         */
        synchronized (_consumerDispatchersDurable)
        {
            // If there's already a consumer dispatcher with this client name, then the
            // create must fail according to the current core API semantics.
            consumerDispatcher = getDurableSubscriptionConsumerDispatcher(subState);

            if (consumerDispatcher != null)
            {
                if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                    SibTr.exit(
                               tc,
                               "createLocalDurableSubscription",
                               "Sub Already Exists - " + subState);

                throw new SIDurableSubscriptionAlreadyExistsException(
                                nls.getFormattedMessage(
                                                        "SUBSCRIPTION_ALREADY_EXISTS_ERROR_CWSIP0143",
                                                        new Object[] {
                                                                      subState.getSubscriberID(),
                                                                      _messageProcessor.getMessagingEngineName() },
                                                        null));
            }
            /* We did not find the consumerDispatcher so we create it */

            /*
             * If a transaction was not provided...
             * Create a new LocalTransaction to perform the creation of a durable subscription.
             * Operations will include the creation of the itemstream,the persisting of
             * the durable state and the attaching of the consumerpoint.
             */
            boolean tranProvided = true;
            LocalTransaction siTran = null;

            if (transaction == null)
            {
                tranProvided = false;
                siTran =
                                _baseDestinationHandler
                                                .getTransactionManager()
                                                .createLocalTransaction(false);
                transaction = siTran;
            }

            /*
             * Create the consumerDispatcher, note we do not require this to be done under
             * the localTransaction. If something goes wrong after this operation, the
             * consumerDispatcher will be lost but thats ok.
             */

            Transaction msTran = _messageProcessor.resolveAndEnlistMsgStoreTransaction(transaction);

            try
            {
                /*
                 * Create a reference stream to be used by the durable subscription's
                 * consumer dispatcher
                 */
                final DurableSubscriptionItemStream durableSubscriptionReferenceStream =
                                new DurableSubscriptionItemStream(
                                                subState,
                                                _baseDestinationHandler.getDestinationManager(),
                                                _pubsubMessageItemStream,
                                                msTran);

                /* Create the consumer dispatcher to represent the subscription */
                consumerDispatcher =
                                configureDurableSubscription(durableSubscriptionReferenceStream);
                consumerDispatcher.registerControlAdapterAsMBean();

                //Venu mock mock
                // No ProxyHandler .. so commenting our this 
                /*
                 * // 166833.2
                 * // Generate the subscribeEvent for this new subscription
                 * // to see if this needs to be forwarded to a Neighbouring ME.
                 * _messageProcessor.getProxyHandler().subscribeEvent(
                 * subState,
                 * msTran);
                 */
            } catch (OutOfCacheSpace e)
            {
                // No FFDC code needed
                SibTr.exception(tc, e);
                // Rollback the transaction
                if (!tranProvided)
                    _baseDestinationHandler.handleRollback(siTran);
                if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                    SibTr.exit(
                               tc,
                               "createLocalDurableSubscription",
                               "SIResourceException");
                throw new SIResourceException(
                                nls.getFormattedMessage(
                                                        "SUBSCRIPTION_CREATION_FAILED_CWSIP0033",
                                                        new Object[] {
                                                                      _baseDestinationHandler.getName(),
                                                                      subState.getSubscriberID(),
                                                                      e },
                                                        null),
                                e);

            } catch (MessageStoreException e)
            {
                // MessageStoreException shouldn't occur so FFDC.
                FFDCFilter.processException(
                                            e,
                                            "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.createLocalDurableSubscription",
                                            "1:1093:1.35.2.4",
                                            this);
                SibTr.exception(tc, e);
                // Rollback the transaction
                if (!tranProvided)
                    _baseDestinationHandler.handleRollback(siTran);

                /*
                 * The message store has thrown an exception, which leaves us stuck. Record an ffst,
                 * write a trace record and throw a SIResourceException to the caller.
                 */
                if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                    SibTr.exit(tc, "createLocalDurableSubscription", e);

                SibTr.error(
                            tc,
                            "INTERNAL_MESSAGING_ERROR_CWSIP0003",
                            new Object[] {
                                          "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.createLocalDurableSubscription",
                                          "1:1112:1.35.2.4",
                                          e,
                                          _baseDestinationHandler.getName() });

                throw new SIResourceException(
                                nls.getFormattedMessage(
                                                        "INTERNAL_MESSAGING_ERROR_CWSIP0003",
                                                        new Object[] {
                                                                      "com.ibm.ws.sib.processor.impl.destination.PubSubRealization",
                                                                      "1:1121:1.35.2.4",
                                                                      e,
                                                                      _baseDestinationHandler.getName() },
                                                        null),
                                e);
            } catch (SIDiscriminatorSyntaxException e)
            {
                // No FFDC code needed
                _baseDestinationHandler.handleRollback(siTran);
                if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                    SibTr.exit(tc, "createLocalDurableSubscription", e);
                throw e;
            } catch (SISelectorSyntaxException e)
            {
                // No FFDC code needed
                _baseDestinationHandler.handleRollback(siTran);
                if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                    SibTr.exit(tc, "createLocalDurableSubscription", e);
                throw e;
            }
            //Venu mock mock
            //commenting out as this exception became unreachable
            /*
             * catch (SIResourceException e)
             * {
             * // No FFDC code needed
             * _baseDestinationHandler.handleRollback(siTran);
             * if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
             * SibTr.exit(tc, "createLocalDurableSubscription", e);
             * throw e;
             * }
             */
            catch (RuntimeException e)
            {
                // FFDC
                FFDCFilter.processException(
                                            e,
                                            "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.createLocalDurableSubscription",
                                            "1:1153:1.35.2.4",
                                            this);

                if (siTran != null)
                    _baseDestinationHandler.handleRollback(siTran);
                if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                    SibTr.exit(tc, "createLocalDurableSubscription", e);
                throw e;
            }

            if (!tranProvided)
            {
                /*
                 * If no transaction was provided, this call must have been made from
                 * the core api (i.e. JMS). We can not provide transaction at runtime.
                 * Since we are creating via JMS, we need to attach the consumer
                 * as part of the create operation.
                 */
                try
                {

                    /* We have our own transaction so commit it here */
                    siTran.commit();

                } catch (SIException e)
                {
                    // MessageStoreException shouldn't occur so FFDC.
                    FFDCFilter.processException(
                                                e,
                                                "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.createLocalDurableSubscription",
                                                "1:1182:1.35.2.4",
                                                this);

                    SibTr.exception(tc, e);
                    SibTr.error(
                                tc,
                                "INTERNAL_MESSAGING_ERROR_CWSIP0003",
                                new Object[] {
                                              "com.ibm.ws.sib.processor.impl.destination.PubSubRealization",
                                              "1:1191:1.35.2.4",
                                              e,
                                              _baseDestinationHandler.getName() });

                    // Failed to attach consumer, rollback the creation of the durable sub
                    // and throw exception.
                    _baseDestinationHandler.handleRollback(siTran);

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

                    throw new SIResourceException(
                                    nls.getFormattedMessage(
                                                            "INTERNAL_MESSAGING_ERROR_CWSIP0003",
                                                            new Object[] {
                                                                          "com.ibm.ws.sib.processor.impl.destination.PubSubRealization",
                                                                          "1:1207:1.35.2.4",
                                                                          e,
                                                                          _baseDestinationHandler.getName() },
                                                            null),
                                    e);
                }
            }
            // Transaction was provided

        } // Release the durable subs lock

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "createLocalDurableSubscription");
    }
85841
@Override
    public void setTemporaryTopicNamePrefix(final String prefix)
                    throws JMSException {
        // defect 99056
        _properties.put(JmsraConstants.TEMP_TOPIC_NAME_PREFIX, prefix);
        if ((prefix != null) && (prefix.length() > 12)) {

            final JMSException exception = new JMSException(NLS
                            .getFormattedMessage(("DESTINATION_PREFIX_LONG_CWSJR1029"),
                                                 new Object[] { prefix }, null));
            if (TraceComponent.isAnyTracingEnabled() && TRACE.isEntryEnabled()) {
                SibTr.exception(this, TRACE, exception);
            }

            throw exception;
        }

    }
538828
public void setDescription(final String DESCRIPTION) {
        if (null == description) {
            _description = DESCRIPTION;
            fireTileEvent(VISIBILITY_EVENT);
            fireTileEvent(REDRAW_EVENT);
        } else {
            description.set(DESCRIPTION);
        }
    }
431638
public void setDurableHome(String val)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setDurableHome", val);
        durableHome = val;
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setDurableHome");
    }
342067
public void setUserDefinedURLFrame(String description, String value)
	{
		try
		{
			byte[] b = new byte[description.length() + value.length() + 2];
			int bytesCopied = 0;
			b[bytesCopied++] = 0;
			System.arraycopy(description.getBytes(ENC_TYPE), 0, b, bytesCopied, description.length());
			bytesCopied += description.length();
			b[bytesCopied++] = 0;
			System.arraycopy(value.getBytes(), 0, b, bytesCopied, value.length());
			bytesCopied += value.length();

			updateFrameData(ID3v2Frames.USER_DEFINED_URL, b);
		}
		catch (UnsupportedEncodingException e)
		{
			e.printStackTrace();
		}
	}
289053
public void setMatchspaceSub(ControllableProxySubscription sub)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "setMatchspaceSub", sub);
    
    _controllableProxySubscription = sub;
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.exit(tc, "setMatchspaceSub");
  }
820937
public void attachDurableFromRemote(ControlCreateStream request)
                    throws
                    SIDestinationLockedException,
                    SIDurableSubscriptionMismatchException,
                    SIDurableSubscriptionNotFoundException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "attachDurableFromRemote", request);

        String subName = request.getDurableSubName();
        SIBUuid8 sender = request.getGuaranteedSourceMessagingEngineUUID();
        String destName =
                        _baseDestinationHandler.constructPseudoDurableDestName(
                                                                               request.getGuaranteedTargetMessagingEngineUUID().toString(),
                                                                               subName);

        // Instantiate selection criteria
        SelectionCriteria criteria =
                        _messageProcessor.getSelectionCriteriaFactory().createSelectionCriteria(
                                                                                                request.getDurableDiscriminator(),
                                                                                                request.getDurableSelector(),
                                                                                                SelectorDomain.getSelectorDomain(request.getDurableSelectorDomain()));

        //create a state object representing a subscription
        ConsumerDispatcherState subState =
                        new ConsumerDispatcherState(
                                        request.getDurableSubName(),
                                        request.getGuaranteedTargetDestinationDefinitionUUID(),
                                        criteria,
                                        request.isNoLocal(),
                                        _messageProcessor.getMessagingEngineName(),
                                        null,
                                        null);

        //defect 259036
        subState.setIsCloned(request.isCloned());
        subState.setTopicSpaceName(_baseDestinationHandler.getDefinition().getName());
        subState.setTopicSpaceBusName(_baseDestinationHandler.getBus());

        String user = request.getSecurityUserid();
        // Retrieve SIBServerSubject flag from the message.
        boolean isSIBServerSubject = request.isSecurityUseridSentBySystem();
        // Set the security id into the CD state
        subState.setUser(user, isSIBServerSubject);

        // If the AOH already exists (e.g. new connection request, or
        // resend of a previous request), then check if the request
        // matches the CD and, if so, delegate to the existing AOH.
        if (_pubSubRemoteSupport.locateExistingAOH(request,
                                                   sender,
                                                   destName,
                                                   subState) == null)
        {

            // Create a LocalConsumerPoint and a ConsumerDispatcherState and try to attach
            // locally.  Synchronize against the consumerDispatcherTable to resolve any
            // races with other concurrent attachers.
            synchronized (_consumerDispatchersDurable)
            {
                // Create the CDS based on the existing CDS, or throw an exception
                // if the subscription is unknown.
                ConsumerDispatcher cd =
                                (ConsumerDispatcher) _consumerDispatchersDurable.get(subName);
                if (cd == null)
                {
                    // No dice, throw the exception
                    SIDurableSubscriptionNotFoundException e =
                                    new SIDurableSubscriptionNotFoundException(
                                                    nls.getFormattedMessage(
                                                                            "SUBSCRIPTION_DOESNT_EXIST_ERROR_CWSIP0146",
                                                                            new Object[] {
                                                                                          subName,
                                                                                          _messageProcessor.getMessagingEngineName() },
                                                                            null));
                    SibTr.exception(tc, e);
                    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                        SibTr.exit(
                                   tc,
                                   "attachDurableFromRemote",
                                   "Subscription does not exist");
                    throw e;
                }
                else if (cd.getConsumerDispatcherState().getTargetDestination() != null)
                {
                    // Subscription was an internal one so reject the attach
                    SIDurableSubscriptionMismatchException e =
                                    new SIDurableSubscriptionMismatchException(
                                                    nls.getFormattedMessage(
                                                                            "INTERNAL_SUBSCRIPTION_ACCESS_DISALLOWED_CWSIP0147",
                                                                            new Object[] {
                                                                                          subName,
                                                                                          _messageProcessor.getMessagingEngineName() },
                                                                            null));
                    SibTr.exception(tc, e);
                    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                        SibTr.exit(
                                   tc,
                                   "attachDurableFromRemote",
                                   "Attaching to internal subscriptions is not allowed");
                    throw e;
                }

                // Copy noLocal and isCloned
                subState.setNoLocal(cd.getConsumerDispatcherState().isNoLocal());
                subState.setIsCloned(cd.getConsumerDispatcherState().isCloned());

                // Check cardinality next
                if (cd.hasConsumersAttached() && !subState.isCloned())
                {
                    Exception e =
                                    new SIDestinationLockedException(
                                                    nls.getFormattedMessage(
                                                                            "SUBSCRIPTION_IN_USE_ERROR_CWSIP0152",
                                                                            new Object[] {
                                                                                          subState.getSubscriberID(),
                                                                                          _messageProcessor.getMessagingEngineName() },
                                                                            null));
                    SibTr.exception(tc, e);
                    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                        SibTr.exit(
                                   tc,
                                   "attachDurableFromRemote",
                                   "Consumers already attached");
                    throw (SIDestinationLockedException) e;
                }

                // Attach to the consumerDispatcher if it is EXACTLY the same
                if (!cd.getConsumerDispatcherState().isReady()
                    || !cd.getConsumerDispatcherState().equals(subState))
                {
                    SIDurableSubscriptionMismatchException e =
                                    new SIDurableSubscriptionMismatchException(
                                                    nls.getFormattedMessage(
                                                                            "SUBSCRIPTION_ALREADY_EXISTS_ERROR_CWSIP0143",
                                                                            new Object[] {
                                                                                          subState.getSubscriberID(),
                                                                                          _messageProcessor.getMessagingEngineName() },
                                                                            null));
                    SibTr.exception(tc, e);
                    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                        SibTr.exit(tc, "attachDurableFromRemote", subState);
                    throw e;
                }

                // Ok, all that worked so create the AOH and forward the request.
                // This should cause attachment to occur.
                DestinationDefinition pseudoDest = null;
                AnycastOutputHandler pseudoHandler = null;

                try
                {
                    // Create the pseudo destination ID and hack up a definition for it
                    // NOTE: have to create the destination first since we need it's ID
                    // for the container stream below.
                    pseudoDest =
                                    _messageProcessor.createDestinationDefinition(
                                                                                  DestinationType.TOPICSPACE,
                                                                                  destName);

                    //defect 259036: if cloned then we are NOT receive
                    //exclusive
                    pseudoDest.setReceiveExclusive(!subState.isCloned());

                    // Create the stream next
                    AOContainerItemStream aostream =
                                    new AOContainerItemStream(pseudoDest.getUUID(), subName);
                    LocalTransaction siTran =
                                    _baseDestinationHandler.
                                                    getTransactionManager().
                                                    createLocalTransaction(true);
                    _baseDestinationHandler.addItemStream(aostream, (Transaction) siTran);
                    siTran.commit();

                    // TODO - should be using something better than System.currentTimeMillis() for the dmeVersion.
                    pseudoHandler =
                                    new AnycastOutputHandler(
                                                    pseudoDest.getName(),
                                                    pseudoDest.getUUID(),
                                                    pseudoDest.isReceiveExclusive(),
                                                    null,
                                                    cd,
                                                    aostream,
                                                    _messageProcessor,
                                                    _destinationManager.getAsyncUpdateThread(),
                                                    _destinationManager.getPersistLockThread(),
                                                    System.currentTimeMillis(),
                                                    false);

                    // Store the destination in our map and make sure the DestinationManager
                    // knows about it for future messages.
                    _pubSubRemoteSupport.
                                    storePseudoDestination(pseudoHandler,
                                                           destName,
                                                           pseudoDest);

                    // Finally, deliver the message to the aoh
                    pseudoHandler.handleControlMessage(
                                                       sender,
                                                       request);
                } catch (Exception e)
                {
                    // Exception shouldn't occur so FFDC.
                    FFDCFilter.processException(
                                                e,
                                                "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.attachDurableFromRemote",
                                                "1:3304:1.35.2.4",
                                                this);
                    SibTr.exception(tc, e);

                    // Then cleanup anything we managed to create
                    if (pseudoDest != null)
                    {
                        _pubSubRemoteSupport.
                                        cleanupPseudoDestination(destName, pseudoDest);
                    }

                    //TODO: does this get rid of the AOContainerStream as well?
                    if (pseudoHandler != null)
                        pseudoHandler.close();

                    // And finally throw an SIErrorException so that DurableOutputHandler sends something
                    // back to the caller.
                    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                        SibTr.exit(tc, "attachDurableFromRemote", "SIErrorException");
                    SIErrorException x =
                                    new SIErrorException(
                                                    nls.getFormattedMessage(
                                                                            "INTERNAL_MESSAGING_ERROR_CWSIP0002",
                                                                            new Object[] {
                                                                                          "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.attachDurableFromRemote",
                                                                                          "1:3329:1.35.2.4",
                                                                                          e },
                                                                            null));
                    FFDCFilter.processException(
                                                e,
                                                "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.attachDurableFromRemote",
                                                "1:3335:1.35.2.4",
                                                this);

                    SibTr.exception(tc, e);

                    SibTr.error(
                                tc,
                                "INTERNAL_MESSAGING_ERROR_CWSIP0002",
                                new Object[] {
                                              "com.ibm.ws.sib.processor.impl.destination.PubSubRealization.attachDurableFromRemote",
                                              "1:3345:1.35.2.4",
                                              e });
                    throw x;
                }
            } // synchronized (consumerDispatchersDurable)
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "attachDurableFromRemote");
    }
1030265
final void setDerivedJmsFields() {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setDerivedJmsFields");

        if (getHdr2().getChoiceField(JsHdr2Access.JMSDELIVERYMODE) == JsHdr2Access.IS_JMSDELIVERYMODE_EMPTY) {
            setJmsDeliveryMode(getDerivedJmsDeliveryMode());
        }

        if (getHdr2().getChoiceField(JsHdr2Access.JMSEXPIRATION) == JsHdr2Access.IS_JMSEXPIRATION_EMPTY) {
            setJmsExpiration(getDerivedJmsExpiration());
        }

        if (getHdr2().getChoiceField(JsHdr2Access.JMSDELIVERYTIME) == JsHdr2Access.IS_JMSDELIVERYTIME_EMPTY) {
            setJmsDeliveryTime(getDerivedJmsDeliveryTime());
        }

        if (getHdr2().getChoiceField(JsHdr2Access.JMSTYPE) == JsHdr2Access.IS_JMSTYPE_EMPTY) {
            setJmsType(getDerivedJmsType());
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setDerivedJmsFields");
    }
795979
public void setSubscriptionIDFilter(String subscriptionId)
  {
    if (tc.isEntryEnabled())
      SibTr.entry(tc, "setSubscriptionIDFilter", subscriptionId);

    this._subscriptionId = subscriptionId;
    this._destination = null;
    this._consumerDispatcherState = null;
    
    if (tc.isEntryEnabled())
      SibTr.exit(tc, "setSubscriptionIDFilter");
  }
1291804
public void setRoutingDestination(JsDestinationAddress value) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setRoutingDestination", value);
        if (value != null) {
            getHdr2().setField(JsHdr2Access.ROUTINGDESTINATION_VALUE_NAME, value.getDestinationName());
            if (value.getME() != null) {
                getHdr2().setField(JsHdr2Access.ROUTINGDESTINATION_VALUE_MEID, value.getME().toByteArray());
            }
            else {
                getHdr2().setField(JsHdr2Access.ROUTINGDESTINATION_VALUE_MEID, null);
            }
            getHdr2().setField(JsHdr2Access.ROUTINGDESTINATION_VALUE_BUSNAME, value.getBusName());
        }
        else {
            getHdr2().setChoiceField(JsHdr2Access.ROUTINGDESTINATION, JsHdr2Access.IS_ROUTINGDESTINATION_EMPTY);
        }
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setRoutingDestination");
    }
1364784
@Override
    public ConsumableKey attachToDurableSubscription(
                                                     LocalConsumerPoint consumerPoint,
                                                     ConsumerDispatcherState subState)
                    throws SIDurableSubscriptionMismatchException, SIDurableSubscriptionNotFoundException, SIDestinationLockedException, SISelectorSyntaxException, SIDiscriminatorSyntaxException, SINotPossibleInCurrentConfigurationException, SIResourceException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(
                        tc,
                        "attachToDurableSubscription",
                        new Object[] { consumerPoint, subState });

        ConsumableKey result =
                        _pubSubRealization.attachToDurableSubscription(
                                                                       consumerPoint,
                                                                       subState);

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "attachToDurableSubscription", result);

        return result;
    }
1246738
@Reference(service = WsLocationAdmin.class,
               policy = ReferencePolicy.DYNAMIC,
               cardinality = ReferenceCardinality.MANDATORY)
    protected void setLocationService(WsLocationAdmin locationService) {
        this.locationService = locationService;
        if (restJMXAddressWorkareaFile == null) {
            restJMXAddressWorkareaFile = createJMXWorkAreaResource(locationService);
        }
        if (restJMXAddressStateFile == null) {
            restJMXAddressStateFile = createJMXStateResource(locationService);
        }
    }
971456
@SuppressWarnings("WeakerAccess")
  public UpdateAppProfileRequest setDescription(@Nonnull String description) {
    Preconditions.checkNotNull(description);

    proto.getAppProfileBuilder().setDescription(description);
    updateFieldMask(com.google.bigtable.admin.v2.AppProfile.DESCRIPTION_FIELD_NUMBER);
    return this;
  }
104355
public void setDescription(String value) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "setDescription", value);
        _description = value;
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "setDescription");
    }
431885
public void setDescription(java.util.Collection<StringFilter> description) {
        if (description == null) {
            this.description = null;
            return;
        }

        this.description = new java.util.ArrayList<StringFilter>(description);
    }