private SIMPMessage retrieveMsgLocked() throws SIResourceException
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "retrieveMsgLocked", new Object[] { this });

        SIMPMessage msg = null;

        // Look in the Cd's ItenStream for the next available message
        try
        {

            msg = _consumerKey.getMessageLocked();

            if (msg != null)
                msg.eventLocked();
        } catch (MessageStoreException e)
        {
            // MessageStoreException shouldn't occur so FFDC.
            FFDCFilter.processException(
                                        e,
                                        "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint.retrieveMsgLocked",
                                        "1:2101:1.22.5.1",
                                        this);

            SibTr.exception(tc, e);
            SibTr.error(tc, "INTERNAL_MESSAGING_ERROR_CWSIP0002",
                        new Object[] {
                                      "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint",
                                      "1:2108:1.22.5.1",
                                      SIMPUtils.getStackTrace(e) });

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

            throw new SIResourceException(
                            nls.getFormattedMessage(
                                                    "INTERNAL_MESSAGING_ERROR_CWSIP0002",
                                                    new Object[] {
                                                                  "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint",
                                                                  "1:2119:1.22.5.1",
                                                                  e },
                                                    null),
                            e);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "retrieveMsgLocked", msg);
        //return the locked message

        return msg;
    }
private SIMPMessage retrieveMsgLocked ( ) throws SIResourceException { if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . entry ( tc , "retrieveMsgLocked" , new Object [ ] { this } ) ; SIMPMessage msg = null ; try { msg = _consumerKey . getMessageLocked ( ) ; if ( msg != null ) msg . eventLocked ( ) ; } catch ( MessageStoreException e ) { FFDCFilter . processException ( e , "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint.retrieveMsgLocked" , "1:2101:1.22.5.1" , this ) ; SibTr . exception ( tc , e ) ; SibTr . error ( tc , "INTERNAL_MESSAGING_ERROR_CWSIP0002" , new Object [ ] { "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint" , "1:2108:1.22.5.1" , SIMPUtils . getStackTrace ( e ) } ) ; if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "retrieveMsgLocked" , e ) ; throw new SIResourceException ( nls . getFormattedMessage ( "INTERNAL_MESSAGING_ERROR_CWSIP0002" , new Object [ ] { "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint" , "1:2119:1.22.5.1" , e } , null ) , e ) ; } if ( TraceComponent . isAnyTracingEnabled ( ) && tc . isEntryEnabled ( ) ) SibTr . exit ( tc , "retrieveMsgLocked" , msg ) ; return msg ; }
Attempt to retrieve a message from the CD's itemStream in a locked state.

@return A locked message