Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
      package examples.tls;
  
  import javax.sip.*;
  import javax.sip.header.*;
  
 import java.util.*;

This class is a UAC template. Shootist is the guy that shoots and shootme is the guy that gets shot.

Author(s):
Daniel Martinez
 
 
 public class Shootme implements SipListener {
 
     private static AddressFactory addressFactory;
     private static MessageFactory messageFactory;
     private static HeaderFactory headerFactory;
     private static SipStack sipStack;
     private static final String myAddress = "127.0.0.1";
     private static final int myPort    = 5071;
 
     protected ServerTransaction inviteTid;
 
     Dialog dialog;
 
     class ApplicationData {
         protected int ackCount;
     }
 
     protected static final String usageString =
         "java "
             + "examples.shootistTLS.Shootist \n"
             + ">>>> is your class path set to the root?";
 
     private static void usage() {
         ..println();
         System.exit(0);
 
     }
 
     public void processRequest(RequestEvent requestEvent) {
         Request request = requestEvent.getRequest();
         ServerTransaction serverTransactionId =
             requestEvent.getServerTransaction();
 
         ..println(
             "\n\nRequest "
                 + request.getMethod()
                 + " received at "
                 + .getStackName()
                 + " with server transaction id "
                 + serverTransactionId);
 
         if (request.getMethod().equals(.)) {
             processInvite(requestEventserverTransactionId);
         } else if (request.getMethod().equals(.)) {
             processAck(requestEventserverTransactionId);
         } else if (request.getMethod().equals(.)) {
             processBye(requestEventserverTransactionId);
         }
 
     }

    
Process the ACK request. Send the bye and complete the call flow.
 
     public void processAck(
         RequestEvent requestEvent,
         ServerTransaction serverTransaction) {
         SipProvider sipProvider = (SipProviderrequestEvent.getSource();
         try {
             ..println("shootme: got an ACK "
                 + requestEvent.getRequest());
             int ackCount =
                 ((ApplicationData ) .getApplicationData()).;
             if (ackCount == 1) {
                 = .getDialog();
                Request byeRequest = .createRequest(.);
                ClientTransaction tr =
                 sipProvider.getNewClientTransaction(byeRequest);
                ..println("shootme: got an ACK -- sending bye! ");
                .sendRequest(tr);
                ..println("Dialog State = " + .getState());
             } else ((ApplicationData.getApplicationData()). ++;
         } catch (Exception ex) {
             ex.printStackTrace();
             System.exit(0);
         }
     }

    
Process the invite request.
 
     public void processInvite(
         RequestEvent requestEvent,
        ServerTransaction serverTransaction) {
        SipProvider sipProvider = (SipProviderrequestEvent.getSource();
        Request request = requestEvent.getRequest();
        ..println("Got an INVITE  " + request);
        try {
            ..println("shootme: got an Invite sending OK");
            //System.out.println("shootme:  " + request);
            Response response = .createResponse(180, request);
            ToHeader toHeader = (ToHeaderresponse.getHeader(.);
            toHeader.setTag("4321"); // Application is supposed to set.
            Address address =
                .createAddress("Shootme <sip:" + ":" +  
                + ";transport=tls>" );
            ContactHeader contactHeader =
                .createContactHeader(address);
            response.addHeader(contactHeader);
            ServerTransaction st = requestEvent.getServerTransaction();
            if (st == null) {
                st = sipProvider.getNewServerTransaction(request);
                    if (st.getDialog().getApplicationData() == null) {
                    st.getDialog().setApplicationData(new ApplicationData());
                }
                } else {
                ..println("This is a RE INVITE ");
                if (st.getDialog() != ) {
                   ..println("Whoopsa Daisy Dialog Mismatch");
                   System.exit(0);
                }
            }
            // Thread.sleep(5000);
            ..println("got a server tranasaction " + st);
            byte[] content = request.getRawContent();
            if (content != null) {
                ContentTypeHeader contentTypeHeader =
                .createContentTypeHeader("application""sdp");
                ..println("response = " + response);
                response.setContent(contentcontentTypeHeader);
            }
             = st.getDialog();
            if ( != null) {
                ..println("Dialog " + );
                ..println("Dialog state " + .getState());
            }
            st.sendResponse(response);
            TransactionExt stExt = ( TransactionExt)st  ;
            Certificate[] certs = stExt.getPeerCertificates();
            ..println("Certs = " + certs);
            
            for (Certificate certcerts ) {
                ..println("Cert = " + cert);
            }
  
            response = .createResponse(200, request);
            toHeader = (ToHeaderresponse.getHeader(.);
            toHeader.setTag("4321"); // Application is supposed to set.
            response.addHeader(contactHeader);
            st.sendResponse(response);
            this. = st;
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(0);
        }
    }

    
Process the bye request.
    public void processBye(
        RequestEvent requestEvent,
        ServerTransaction serverTransactionId) {
        // SipProvider sipProvider = (SipProvider) requestEvent.getSource();
        Request request = requestEvent.getRequest();
        try {
            ..println("shootme:  got a bye sending OK.");
            Response response =
                .createResponse(200, requestnullnull);
            serverTransactionId.sendResponse(response);
            ..println("Dialog State is " + serverTransactionId.getDialog().getState());
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(0);
        }
    }
    public void processResponse(ResponseEvent responseReceivedEvent) {
        ..println("Got a response");
        Response response = (ResponseresponseReceivedEvent.getResponse();
        Transaction tid = responseReceivedEvent.getClientTransaction();
        ..println(
            "Response received with client transaction id "
                + tid
                + ":\n"
                + response);
        try {
            if (response.getStatusCode() == .
                && ((CSeqHeaderresponse.getHeader(.))
                    .getMethod()
                    .equals(
                    .)) {
                if (tid != this.) {
                    new Exception().printStackTrace();
                    System.exit(0);
                }
                Dialog dialog = tid.getDialog();
                // Save the tags for the dialog here.
                Request request = tid.getRequest();
                dialog.sendAck(request);
            }
            Dialog dialog = tid.getDialog();
            ..println("Dalog State = " + dialog.getState());
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(0);
        }
    }
    public void processTimeout(javax.sip.TimeoutEvent timeoutEvent) {
        Transaction transaction;
        if (timeoutEvent.isServerTransaction()) {
            transaction = timeoutEvent.getServerTransaction();
        } else {
            transaction = timeoutEvent.getClientTransaction();
        }
        ..println("state = " + transaction.getState());
        ..println("dialog = " + transaction.getDialog());
        ..println(
            "dialogState = " + transaction.getDialog().getState());
        ..println("Transaction Time out");
    }
    public void init() {
        SipFactory sipFactory = null;
         = null;
        sipFactory = SipFactory.getInstance();
        sipFactory.setPathName("gov.nist");
        Properties properties = new Properties();
        properties.setProperty("javax.sip.STACK_NAME""shootme");
        // You need  16 for logging traces. 32 for debug + traces.
        // Your code will limp at 32 but it is best for debugging.
        properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL""32");
        properties.setProperty(
            "gov.nist.javax.sip.DEBUG_LOG",
            "shootmedebug.txt");
        properties.setProperty(
            "gov.nist.javax.sip.SERVER_LOG",
            "shootmelog.txt");
        // Guard against starvation.
        properties.setProperty(
            "gov.nist.javax.sip.READ_TIMEOUT""1000");
  
        try {
            // Create SipStack object
             = sipFactory.createSipStack(properties);
            ..println("sipStack = " + );
        } catch (PeerUnavailableException e) {
            // could not find
            // gov.nist.jain.protocol.ip.sip.SipStackImpl
            // in the classpath
            e.printStackTrace();
            ..println(e.getMessage());
            if (e.getCause() != null)
                e.getCause().printStackTrace();
            System.exit(0);
        }
        try {
             = sipFactory.createHeaderFactory();
             = sipFactory.createAddressFactory();
             = sipFactory.createMessageFactory();
            ListeningPoint lpTLS = .createListeningPoint("127.0.0.1""tls");
            Shootme listener = this;
            SipProvider sipProvider = .createSipProvider(lpTLS);
            ..println("tls provider " + sipProvider);
            sipProvider.addSipListener(listener);
        } catch (Exception ex) {
            ..println(ex.getMessage());
            ex.printStackTrace();
            usage();
        }
    }
    public static void main(String args[]) {
        new Shootme().init();
    }
    public void processIOException(IOExceptionEvent exceptionEvent) {
        ..println("IOException occured while retransmitting requests:" + exceptionEvent);
    }
    public void processTransactionTerminated(TransactionTerminatedEvent transactionTerminatedEvent) {
        ..println("Transaction Terminated event: " + transactionTerminatedEvent );
    }
    public void processDialogTerminated(DialogTerminatedEvent dialogTerminatedEvent) {
        ..println("Dialog Terminated event: " + dialogTerminatedEvent);
    }
New to GrepCode? Check out our FAQ X