Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package examples.noautodialog;
  
  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. This illustrates how to go about when you want explicit control over creation of dialogs.

Author(s):
M. Ranganathan
 
 
 public class Shootme implements SipListener {
 
     private static AddressFactory addressFactory;
 
     private static MessageFactory messageFactory;
 
     private static HeaderFactory headerFactory;
 
     private static SipStack sipStack;
 
     // To run on two machines change these to suit.
     public static final String myAddress = "127.0.0.1";
 
     private static final int myPort = 5070;
 
     protected ServerTransaction inviteTid;
 
     protected ClientTransaction clientTid;
 
 
     protected static final String usageString = "java "
             + "examples.shootist.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.
 
     public void processAck(RequestEvent requestEvent,
             ServerTransaction serverTransaction) {
         SipProvider sipProvider = (SipProviderrequestEvent.getSource();
         try {
             ..println("shootme: got an ACK "
                     + requestEvent.getRequest());
 
         } 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 180 and 200");
             //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:"
                     +  + ":" +  + ">");
             ContactHeader contactHeader = 
                     .createContactHeader(address);
            response.addHeader(contactHeader);
            ServerTransaction st = requestEvent.getServerTransaction();
            if (st == null) {
                st = sipProvider.getNewServerTransaction(request);
                ..println("Server transaction created!" + request);
                ..println("Dialog = " + st.getDialog());
            }
            // Thread.sleep(5000);
            ..println("got a server tranasaction " + st);
            byte[] content = request.getRawContent();
            if (content != null) {
                ..println(" content = " + new String(content));
                ContentTypeHeader contentTypeHeader = 
                        .createContentTypeHeader("application""sdp");
                ..println("response = " + response);
                response.setContent(contentcontentTypeHeader);
            }
            Dialog dialog = st.getDialog();
            ..println("Dialog " + dialog);
        dialog = sipProvider.getNewDialog(st);
            ..println("Dialog " + st.getDialog());
        if ( dialog != st.getDialog() ) {
        throw new RuntimeException("Dialog mismatch ");
        }
            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 = (SipProviderrequestEvent.getSource();
        Request request = requestEvent.getRequest();
        try {
            ..println("shootme:  got a bye sending OK.");
            Response response = .createResponse(200, request);
            if ( serverTransactionId == null     ) {
                ..println("Note that we can create a new tx here!");
                serverTransactionId = sipProvider.getNewServerTransaction(request);
                ..println("Creating new server transaction for bye "
                + serverTransactionId);
            }
            // Fire and forget.
            serverTransactionId.sendResponse(response);
        ..println("We are not creating a dialog for this.");
            ..println("Dialog is "
                    + serverTransactionId.getDialog());
        } 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();
        CSeqHeader cseq = (CSeqHeaderresponse.getHeader(.);
        ..println("Response received with client transaction id "
                + tid + ":\n" + response);
        try {
            if (response.getStatusCode() == .
                    && ((CSeqHeaderresponse.getHeader(.))
                            .getMethod().equals(.)) {
                Dialog dialog = tid.getDialog();
                Request ackRequest = dialog.createAckcseq.getSeqNumber() );
                dialog.sendAck(ackRequest);
            }
            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");
        // Note that this turns off automatic dialog creation. This
        // mode of operaton is good for proxy servers.
        properties.setProperty("javax.sip.AUTOMATIC_DIALOG_SUPPORT""off");
        // 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");
        // properties.setProperty("gov.nist.javax.sip.MAX_MESSAGE_SIZE",
        // "4096");
        properties.setProperty("gov.nist.javax.sip.CACHE_SERVER_CONNECTIONS",
                "false");
        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 lp = .createListeningPoint(,5070, "udp");
            ListeningPoint lp1 = .createListeningPoint(,5070, "tcp");
            Shootme listener = this;
            SipProvider sipProvider = .createSipProvider(lp);
            ..println("udp provider " + sipProvider);
            sipProvider.addSipListener(listener);
            sipProvider = .createSipProvider(lp1);
            ..println("tcp provider " + sipProvider);
            sipProvider.addSipListener(listener);
        } catch (Exception ex) {
            ..println(ex.getMessage());
            ex.printStackTrace();
            usage();
        }
    }
    public static void main(String args[]) {
        new Shootme().init();
    }
    /*
     * (non-Javadoc)
     *
     * @see javax.sip.SipListener#processIOException(javax.sip.IOExceptionEvent)
     */
    public void processIOException(IOExceptionEvent exceptionEvent) {
        ..println("An IO Exception was detected : "
                + exceptionEvent.getHost());
    }
    /*
     * (non-Javadoc)
     *
     * @see javax.sip.SipListener#processTransactionTerminated(javax.sip.TransactionTerminatedEvent)
     */
    public void processTransactionTerminated(
            TransactionTerminatedEvent transactionTerminatedEvent) {
        ..println("Tx terminated event ");
    }
    /*
     * (non-Javadoc)
     *
     * @see javax.sip.SipListener#processDialogTerminated(javax.sip.DialogTerminatedEvent)
     */
    public void processDialogTerminated(
            DialogTerminatedEvent dialogTerminatedEvent) {
        ..println("Dialog terminated event detected ");
    }
New to GrepCode? Check out our FAQ X