/* (non-Javadoc)
@see com.ibm.ws.sib.processor.runtime.SIMPLocalSubscriptionControllable#getSubscriberID()
348248
public String getSubscriberID()
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "getSubscriberID");

    String subId = consumerDispatcherState.getSubscriberID();
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())             
      SibTr.exit(tc, "getSubscriberID", subId);
    return subId;
  }
709991
public Subscription reactivateSubscription(final Subscription subscription) {
        return doPUT(Subscription.SUBSCRIPTION_RESOURCE + "/" + subscription.getUuid() + "/reactivate",
                     subscription, Subscription.class);
    }
466560
public List<Object> getSubscribers(final Class<?> eventType, final String eventId) {
        final List<Object> eventSubs = new ArrayList<>();

        synchronized (registeredSubMap) {
            for (Map.Entry<Object, List<SubIdentifier>> entry : registeredSubMap.entrySet()) {
                for (SubIdentifier sub : entry.getValue()) {
                    if (sub.isMyEvent(eventType, eventId)) {
                        eventSubs.add(entry.getKey());

                        break;
                    }
                }
            }
        }

        return eventSubs;
    }
935706
public Observable<DeploymentLocationsInner> getSubscriptionDeploymentLocationsAsync() {
        return getSubscriptionDeploymentLocationsWithServiceResponseAsync().map(new Func1<ServiceResponse<DeploymentLocationsInner>, DeploymentLocationsInner>() {
            @Override
            public DeploymentLocationsInner call(ServiceResponse<DeploymentLocationsInner> response) {
                return response.body();
            }
        });
    }
425590
public function setRepositorySubscription(bool $subscribed = false, bool $ignored = false): array
    {
        return $this->getApi()->request($this->getApi()->sprintf('/repos/:owner/:repo/subscription?:args',
            $this->getActivity()->getOwner(), $this->getActivity()->getRepo(), http_build_query([
                'subscribed' => $subscribed,
                'ignored'    => $ignored
            ])), Request::METHOD_PUT);
    }
363299
final String getMESubUserId()
  {
	if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
	{
	  SibTr.entry(tc, "getMESubUserId");
	  SibTr.exit(tc, "getMESubUserId", _meSubUserId);
	}

	return _meSubUserId;
  }
494793
static function countWithSubscriberID( $subscriberID, $languageID =false , $enabled = false )
    {
        $cond = array();
        $cond['subscriber_id'] = $subscriberID;
        if ( $enabled !== false )
        {
            $cond['enabled'] = $enabled;
        }
        if ( $languageID !== false )
        {
            $cond['language_id'] = $languageID;
        }
        $count = eZPersistentObject::count( self::definition(), $cond );
        return $count;
    }
397337
private SubscriptionMessage createSubscriptionMessage()
  {
    if (tc.isEntryEnabled())
      SibTr.entry(tc, "createSubscriptionMessage");

    ControlMessageFactory factory = null;
    SubscriptionMessage subscriptionMessage = null;

    try
    {
      factory = MessageProcessor.getControlMessageFactory();
      subscriptionMessage = factory.createNewSubscriptionMessage();
    }
    catch (Exception e)
    {
      FFDCFilter.processException(
        e,
        "com.ibm.ws.sib.processor.proxyhandler.SubscriptionMessageHandler.createSubscriptionMessage",
        "1:162:1.34",
        this);
        
      SibTr.exception(tc, e);
    }

    if (tc.isEntryEnabled())
      SibTr.exit(tc, "createSubscriptionMessage", subscriptionMessage);

    return subscriptionMessage;
  }
1082933
public Integer getSRID() {
      Integer srid = null;
      if (getParameters().length > 1 && getParameters()[1] != null) {
         srid = Integer.valueOf(getParameters()[1].toString());
      }
      return srid;
   }
805684
public SIMPLocalSubscriptionControllable getLocalSubscriptionControlByName(String subscriptionName) throws SIMPException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "getLocalSubscriptionControlByName", subscriptionName);
    
    assertMessageHandlerNotCorrupt();
    
    //since subscription name is guaranteed to be unique on the ME, we get the
    //ME wide map of subscriptions
    HashMap durableSubs = messageProcessor.getDestinationManager().getDurableSubscriptionsTable();
    //get a ConsumerDispatcher for the subscription
    ConsumerDispatcher cd = (ConsumerDispatcher)durableSubs.get(subscriptionName);
    SIMPLocalSubscriptionControllable controlAdapter = null;
    if(cd!=null)
    {
      controlAdapter = (SIMPLocalSubscriptionControllable)cd.getControlAdapter();
    }
    // If the sub is null, throw an exception
    if (controlAdapter == null)
    {
      SIMPControllableNotFoundException exception = 
        new SIMPControllableNotFoundException(
            nls.getFormattedMessage(
              "SUBSCRIPTION_NOT_FOUND_ERROR_CWSIP0271",
              new Object[]{subscriptionName},
              null)); 
      
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
        SibTr.exit(
          tc,
          "getLocalSubscriptionControlByName",
          exception);
          
      throw exception;
    }
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.exit(tc, "getLocalSubscriptionControlByName", controlAdapter);
    return controlAdapter;
  }
1279056
public Set<Method> subscriptionsOn(Object subscriber) {
        SubscriptionMethodFilter filter = new SubscriptionMethodFilter();
        Class<?> subscriberClass = subscriber.getClass();
        List<Method> methods = Arrays.asList(subscriberClass.getMethods());
        Set<Method> subscriptions = new HashSet<Method>();
        for (Method method : methods) {
            if (filter.accepts(method)) {
                subscriptions.add(method);
            }
        }
        return subscriptions;
    }
581871
public static <T> ObservableTransformer<T,T> doOnSubscribeFx(Consumer<Disposable> subscribe) {
        return obs -> obs.doOnSubscribe((d -> runOnFx(d,subscribe)));
    }
1284703
@Override
    protected boolean reSubscribe(EventChannelStruct channelStruct, EventCallBackStruct eventCallBackStruct) {
        //  ToDo
        boolean done = false;
        try {
            ApiUtil.printTrace("====================================================\n" +
                                "   Try to resubscribe " + eventCallBackStruct.channel_name);
            DevVarLongStringArray   lsa =
                ZMQutils.getEventSubscriptionInfoFromAdmDevice(
                        channelStruct.adm_device_proxy,
                        eventCallBackStruct.device.name(),
                        eventCallBackStruct.attr_name, eventCallBackStruct.event_name);

            //  Update the heartbeat time
            String  admDeviceName = channelStruct.adm_device_proxy.name();  //.toLowerCase();
            //  Since Tango 8.1, heartbeat is sent in lower case.
            if (channelStruct.getTangoRelease()>=810)
                admDeviceName = admDeviceName.toLowerCase();
            push_structured_event_heartbeat(admDeviceName);
            channelStruct.heartbeat_skipped = false;
            channelStruct.last_subscribed = System.currentTimeMillis();
            channelStruct.setTangoRelease(lsa.lvalue[0]);
            channelStruct.setIdlVersion(lsa.lvalue[1]);
            eventCallBackStruct.last_subscribed = channelStruct.last_subscribed;
            done = true;
        }
        catch(DevFailed e) {
            /* */
        }
        return done;
    }
1020088
public SIMPIterator getLocalSubscriptionIterator() throws SIMPException
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.entry(tc, "getLocalSubscriptionIterator");
      
    assertMessageHandlerNotCorrupt();  
    SubscriptionTypeFilter filter = new SubscriptionTypeFilter();
    filter.LOCAL = Boolean.TRUE;
    SIMPIterator itr = new ControllableIterator(getSubscriptionIndex().iterator(filter));
    
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) 
      SibTr.exit(tc, "getLocalSubscriptionIterator", itr);
    return itr;
  }
686227
@Override
    public List getSubscriptionList()
                    throws
                    SIResourceException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "getSubscriptionList");

        List subscriptions = _pubSubRealization.getSubscriptionList();

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "getSubscriptionList", subscriptions);
        return subscriptions;
    }
874912
public RowIdWrapper getCurrentRowIdWrapper() {
		UIContext uic = UIContextHolder.getCurrent();
		if (uic instanceof SubUIContext) {
			int index = ((SubUIContext) uic).getRowIndex();
			RowIdWrapper wrapper = table.getRepeater().getBeanList().get(index);
			return wrapper;
		}
		return null;
	}
347390
public Observable<Page<UserSubscriptionQuotaInner>> listAsync() {
        return listWithServiceResponseAsync().map(new Func1<ServiceResponse<List<UserSubscriptionQuotaInner>>, Page<UserSubscriptionQuotaInner>>() {
            @Override
            public Page<UserSubscriptionQuotaInner> call(ServiceResponse<List<UserSubscriptionQuotaInner>> response) {
                PageImpl1<UserSubscriptionQuotaInner> page = new PageImpl1<>();
                page.setItems(response.body());
                return page;
            }
        });
    }