import javax.sip.header.SubscriptionStateHeader; //导入依赖的package包/类
public void run() {
    try {
        for (int i = 0; i < 1; i++) {

            Thread.sleep(1000);
            Request request = this.notifier.dialog.createRequest(Request.NOTIFY);
            SubscriptionStateHeader subscriptionState = headerFactory
                    .createSubscriptionStateHeader(SubscriptionStateHeader.ACTIVE);
            request.addHeader(subscriptionState);
            request.addHeader(eventHeader);

            // Lets mark our Contact
            ((SipURI)dialog.getLocalParty().getURI()).setParameter("id","not2");

            ClientTransaction ct = sipProvider.getNewClientTransaction(request);
            logger.info("NOTIFY Branch ID " +
                ((ViaHeader)request.getHeader(ViaHeader.NAME)).getParameter("branch"));
            this.notifier.dialog.sendRequest(ct);
            logger.info("Dialog " + dialog);
            logger.info("Dialog state after active NOTIFY: " + dialog.getState());
        }


    } catch (Throwable ex) {
        logger.info(ex.getMessage(), ex);
        TestHarness.fail("Failed MyEventSource.run(), because of " + ex.getMessage());
    }
}
 

import javax.sip.header.SubscriptionStateHeader; //导入依赖的package包/类
public synchronized void processNotify(RequestEvent requestEvent,
        ServerTransaction serverTransactionId) {
    LOG.debug("Notification received at Subscriber");
    SipProvider provider = (SipProvider) requestEvent.getSource();
    Request notify = requestEvent.getRequest();
    try {
        if (serverTransactionId == null) {
            LOG.info("ServerTransaction is null. Creating new Server transaction");
            serverTransactionId = provider.getNewServerTransaction(notify);
        }
        Dialog dialog = serverTransactionId.getDialog();

        if (dialog != subscriberDialog) {
            forkedDialog = dialog;
        }
        //Dispatch the response along the route
        dispatchExchange(notify.getContent());
        
        // Send back an success response
        Response response = sipSubscriber.getConfiguration().getMessageFactory().createResponse(200, notify);            
        response.addHeader(sipSubscriber.getConfiguration().getContactHeader());
        serverTransactionId.sendResponse(response);

        SubscriptionStateHeader subscriptionState = (SubscriptionStateHeader) notify
                .getHeader(SubscriptionStateHeader.NAME);

        // Subscription is terminated?
        if (subscriptionState.getState().equalsIgnoreCase(SubscriptionStateHeader.TERMINATED)) {
            LOG.info("Subscription state is terminated. Deleting the current dialog");
            dialog.delete();
        }
    } catch (Exception e) {
        LOG.error("Exception thrown during Notify processing in the SipSubscriptionListener.", e);
    }
}
 

import javax.sip.header.SubscriptionStateHeader; //导入依赖的package包/类
public synchronized void processNotify(RequestEvent requestEvent,
        ServerTransaction serverTransactionId) {
    SipProvider provider = (SipProvider) requestEvent.getSource();
    Request notify = requestEvent.getRequest();
    try {
        logger.info("subscriber:  got a notify count  " + this.count++);
        if (serverTransactionId == null) {
            logger.info("subscriber:  null TID.");
            serverTransactionId = provider.getNewServerTransaction(notify);
        }
        Dialog dialog = serverTransactionId.getDialog();
        logger.info("Dialog = " + dialog);

        if (dialog != null) {
            logger.info("Dialog State = " + dialog.getState());
        }

        Response response = messageFactory.createResponse(200, notify);
        // SHOULD add a Contact
        ContactHeader contact = (ContactHeader) contactHeader.clone();
        ((SipURI) contact.getAddress().getURI()).setParameter("id", "sub");
        response.addHeader(contact);
        logger.info("Transaction State = " + serverTransactionId.getState());
        serverTransactionId.sendResponse(response);
        if (dialog != null) {
            logger.info("Dialog State = " + dialog.getState());
        }
        SubscriptionStateHeader subscriptionState = (SubscriptionStateHeader) notify
                .getHeader(SubscriptionStateHeader.NAME);

        // Subscription is terminated?
        String state = subscriptionState.getState();
        if (state.equalsIgnoreCase(SubscriptionStateHeader.TERMINATED)) {
            dialog.delete();
        } else {
            logger.info("Subscriber: state now " + state);
        }
        this.notifySeen = true;

    } catch (Exception ex) {
        ex.printStackTrace();
        logger.error("Unexpected exception", ex);
        fail("Unexpected exception");

    }
}
 

import javax.sip.header.SubscriptionStateHeader; //导入依赖的package包/类
private void processNotify(RequestEvent requestEvent,
        ServerTransaction serverTransactionId) {
    SipProvider provider = (SipProvider) requestEvent.getSource();
    Request notify = requestEvent.getRequest();
    if ( notify.getMethod().equals("NOTIFY") ) try {
        logger.info("referer:  got a NOTIFY count  " + ++this.count + ":\n" + notify );
        if (serverTransactionId == null) {
            logger.info("referer:  null TID.");
            serverTransactionId = provider.getNewServerTransaction(notify);
        }
        Dialog dialog = serverTransactionId.getDialog();
        logger.info("Dialog = " + dialog);

        TestHarness.assertTrue("Dialog should not be null", dialog != null);
        logger.info("Dialog State = " + dialog.getState());

        Response response = messageFactory.createResponse(200, notify);
        // SHOULD add a Contact
        ContactHeader contact = (ContactHeader) contactHeader.clone();
        ((SipURI)contact.getAddress().getURI()).setParameter( "id", "sub" );
        response.addHeader( contact );
        logger.info("Transaction State = " + serverTransactionId.getState());
        serverTransactionId.sendResponse(response);
        logger.info("Dialog State = " + dialog.getState());
        SubscriptionStateHeader subscriptionState = (SubscriptionStateHeader) notify
                .getHeader(SubscriptionStateHeader.NAME);

        // Subscription is terminated?
        String state = subscriptionState.getState();
        if (state.equalsIgnoreCase(SubscriptionStateHeader.TERMINATED)) {
            dialog.delete();
        } else {
            logger.info("Referer: state now " + state);
        }
    } catch (Exception ex) {
        TestHarness.fail("Failed processing notify, because of " + ex);

    } else {
        TestHarness.fail( "Unexpected request type" );
    }
}
 

import javax.sip.header.SubscriptionStateHeader; //导入依赖的package包/类
private void sendNotify( int code, String reason )
        throws SipException, ParseException
    {
        /*
         * NOTIFY requests MUST contain a "Subscription-State" header with a
         * value of "active", "pending", or "terminated". The "active" value
         * indicates that the subscription has been accepted and has been
         * authorized (in most cases; see section 5.2.). The "pending" value
         * indicates that the subscription has been received, but that
         * policy information is insufficient to accept or deny the
         * subscription at this time. The "terminated" value indicates that
         * the subscription is not active.
         */

        Request notifyRequest = dialog.createRequest( "NOTIFY" );

        // Initial state is pending, second time we assume terminated (Expires==0)
        String state = SubscriptionStateHeader.PENDING;
        if (code>100 && code<200) {
            state = SubscriptionStateHeader.ACTIVE;
        } else if (code>=200) {
            state = SubscriptionStateHeader.TERMINATED;
        }

        SubscriptionStateHeader sstate = headerFactory.createSubscriptionStateHeader( state );
        if (state == SubscriptionStateHeader.TERMINATED) {
            sstate.setReasonCode("noresource");
        }
        notifyRequest.addHeader(sstate);
        notifyRequest.setHeader(referEvent);

        Address address = addressFactory.createAddress("Referee <sip:127.0.0.1>");
        ((SipURI)address.getURI()).setPort( mySipProvider.getListeningPoint(transport).getPort() );
        ((SipURI)address.getURI()).setTransportParam(transport);
        ContactHeader contactHeader = headerFactory.createContactHeader(address);
        notifyRequest.setHeader(contactHeader);
        // notifyRequest.setHeader(routeHeader);
        ClientTransaction ct2 = mySipProvider.getNewClientTransaction(notifyRequest);

        ContentTypeHeader ct = headerFactory.createContentTypeHeader("message","sipfrag");
        ct.setParameter( "version", "2.0" );

        notifyRequest.setContent( "SIP/2.0 " + code + ' ' + reason, ct );

        // Let the other side know that the tx is pending acceptance
        //
        dialog.sendRequest(ct2);
        logger.info("NOTIFY Branch ID " +
            ((ViaHeader)notifyRequest.getHeader(ViaHeader.NAME)).getParameter("branch"));
        logger.info("Dialog " + dialog);
        logger.info("Dialog state after NOTIFY: " + dialog.getState());
}
 

import javax.sip.header.SubscriptionStateHeader; //导入依赖的package包/类
private void sendNotification(EventHeader eventHeader, boolean isInitial, Object body) throws SipException, ParseException {
    /*
     * NOTIFY requests MUST contain a "Subscription-State" header with a
     * value of "active", "pending", or "terminated". The "active" value
     * indicates that the subscription has been accepted and has been
     * authorized (in most cases; see section 5.2.). The "pending" value
     * indicates that the subscription has been received, but that
     * policy information is insufficient to accept or deny the
     * subscription at this time. The "terminated" value indicates that
     * the subscription is not active.
     */
    
    Request notifyRequest = dialog.createRequest("NOTIFY");

    // Mark the contact header, to check that the remote contact is updated
    ((SipURI)sipPresenceAgent.getConfiguration().getContactHeader().getAddress().getURI()).setParameter(
            sipPresenceAgent.getConfiguration().getFromUser(), sipPresenceAgent.getConfiguration().getFromHost());

    SubscriptionStateHeader sstate;
    if (isInitial) {
        // Initial state is pending, second time we assume terminated (Expires==0)
        sstate = 
            sipPresenceAgent.getConfiguration().getHeaderFactory().createSubscriptionStateHeader(isInitial ? SubscriptionStateHeader.PENDING : SubscriptionStateHeader.TERMINATED);

        // Need a reason for terminated
        if (sstate.getState().equalsIgnoreCase("terminated")) {
            sstate.setReasonCode("deactivated");
        }
    } else {
        sstate = sipPresenceAgent.getConfiguration().getHeaderFactory().createSubscriptionStateHeader(SubscriptionStateHeader.ACTIVE);
    }

    notifyRequest.addHeader(sstate);
    notifyRequest.setHeader(eventHeader);
    notifyRequest.setHeader(sipPresenceAgent.getConfiguration().getContactHeader());
    notifyRequest.setContent(body, sipPresenceAgent.getConfiguration().getContentTypeHeader());
    LOG.debug("Sending the following NOTIFY request to Subscriber: {}", notifyRequest);
    
    ClientTransaction clientTransactionId = sipPresenceAgent.getProvider().getNewClientTransaction(notifyRequest);

    dialog.sendRequest(clientTransactionId);
}