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;
    }
public List < String > getSubscriptionList ( ) throws SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "getSubscriptionList" ) ; List < String > subscriptions = null ; 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 ; }
/*
(non-Javadoc)

@see com.ibm.ws.sib.processor.impl.interfaces.DestinationHandler#getSubscriptionList()