Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  package test.load.multidialog;
  
  import javax.sip.*;
  import javax.sip.header.*;
  
  import java.util.*;

Concurrent calls test. The client creates 20 concurrent dialogs on the server. The server replies to each one.

Author(s):
M. Ranganathan
 
 
 public class Shootist implements SipListener {
 
     private static SipProvider tcpProvider;
 
     private static SipProvider udpProvider;
 
     private static AddressFactory addressFactory;
 
     private static MessageFactory messageFactory;
 
     private static HeaderFactory headerFactory;
 
     private static SipStack sipStack;
 
     private ContactHeader contactHeader;
 
     private ListeningPoint tcpListeningPoint;
 
     private ListeningPoint udpListeningPoint;
 
     /* move variables as class variables from init() */
     private SipURI requestURI;
 
     private CSeqHeader cSeqHeader;
 
     private FromHeader fromHeader;
 
     private ToHeader toHeader;
 
 
     private MaxForwardsHeader maxForwards;
 
     private Shootist listener;
 
     private SipProvider sipProvider;
 
     private Address fromNameAddress;
 
 
     private int terminatedCount;
 
     private int confirmationCount;
     // If you want to try TCP transport change the following to
     // String transport = "tcp";
     String transport = "udp";
 
 
     /* remote peer host */
     static String peerHostPort = "127.0.0.1:5070";
 
     static String localHost = "127.0.0.1";
 
     protected static final String usageString = "java "
             + "examples.multi.Shootist \n"
             + ">>>> is your class path set to the root?";
 
     private static void usage() {
         ..println();
         System.exit(0);
 
     }
 
     public void processRequest(RequestEvent requestReceivedEvent) {
         Request request = requestReceivedEvent.getRequest();
         ServerTransaction serverTransactionId = requestReceivedEvent
                 .getServerTransaction();
 
         // We are the UAC so the only request we get is the BYE.
         if (request.getMethod().equals(.))
             processBye(requestserverTransactionId);
 
     }
 
     public void processBye(Request request,
             ServerTransaction serverTransactionId) {
         try {
             //System.out.println("shootist:  got a bye .");
             if (serverTransactionId == null) {
                 //System.out.println("shootist:  null TID.");
                 return;
             }
            //System.out.println("Dialog State = " + dialog.getState());
            Response response = .createResponse(200, request);
            serverTransactionId.sendResponse(response);
            //System.out.println("shootist:  Sending OK.");
            //System.out.println("Dialog State = " + dialog.getState());
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(0);
        }
    }
    public void processResponse(ResponseEvent responseReceivedEvent) {
        //System.out.println("Got a response");
        Response response = (ResponseresponseReceivedEvent.getResponse();
        Transaction tid = responseReceivedEvent.getClientTransaction();
        try {
            if (response.getStatusCode() == .
                    && ((CSeqHeaderresponse.getHeader(.))
                            .getMethod().equals(.)) {
                Dialog dialog = responseReceivedEvent.getDialog();
                CSeqHeader cseq = (CSeqHeaderresponse.getHeader(.);
                Request ackRequest = dialog.createAck(cseq.getSeqNumber());
                //System.out.println("Sending ACK");
                dialog.sendAck(ackRequest);
                ..println("Dialog Confirmed: Count = " + ++this." dialogID = " +
                        dialog.getDialogId() + " dialogState = " + dialog.getState() );
                if ( tid == null..println("null txID");
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(0);
        }
    }
    public void processTimeout(javax.sip.TimeoutEvent timeoutEvent) {
        //System.out.println("Transaction Time out");
    }
    public void init() {
        SipFactory sipFactory = null;
         = null;
        sipFactory = SipFactory.getInstance();
        sipFactory.setPathName("gov.nist");
        Properties properties = new Properties();
        /* remote peer host */
        String peerHostPort = "127.0.0.1:5070";
        String localHost = "127.0.0.1";
        properties.setProperty("javax.sip.OUTBOUND_PROXY"peerHostPort + "/"
                + );
        properties.setProperty("javax.sip.STACK_NAME""shootist");
        // The following properties are specific to nist-sip
        // and are not necessarily part of any other jain-sip
        // implementation.
        // You can set a max message size for tcp transport to
        // guard against denial of service attack.
        properties
                .setProperty("gov.nist.javax.sip.MAX_MESSAGE_SIZE""1048576");
        properties.setProperty("gov.nist.javax.sip.DEBUG_LOG",
                "shootistdebug.txt");
        properties.setProperty("gov.nist.javax.sip.SERVER_LOG",
                "shootistlog.txt");
        // Drop the client connection after we are done with the transaction.
        properties.setProperty("gov.nist.javax.sip.CACHE_CLIENT_CONNECTIONS",
                "false");
        // Set to 0 in your production code for max speed.
        // 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");
        try {
            // Create SipStack object
             = sipFactory.createSipStack(properties);
            ..println("createSipStack " + );
        } catch (PeerUnavailableException e) {
            // could not find
            // gov.nist.jain.protocol.ip.sip.SipStackImpl
            // in the classpath
            e.printStackTrace();
            ..println(e.getMessage());
            System.exit(0);
        }
        try {
             = sipFactory.createHeaderFactory();
             = sipFactory.createAddressFactory();
             = sipFactory.createMessageFactory();
            /* udp ListeningPoint */
             = .createListeningPoint(localHost, 5060,
                    "udp");
             = this;
            .addSipListener();
            /* tcp ListeningPoint */
             = .createListeningPoint(localHost, 5060,
                    "tcp");
            .addSipListener();
             = .equalsIgnoreCase("udp") ? 
                    : ;
            String fromName = "BigGuy";
            String fromSipAddress = "here.com";
            String fromDisplayName = "The Master Blaster";
            String toSipAddress = "there.com";
            String toUser = "LittleGuy";
            String toDisplayName = "The Little Blister";
            // create >From Header
            SipURI fromAddress = .createSipURI(fromName,
                    fromSipAddress);
             = .createAddress(fromAddress);
            .setDisplayName(fromDisplayName);
            // create To Header
            SipURI toAddress = 
                    .createSipURI(toUsertoSipAddress);
            Address toNameAddress = .createAddress(toAddress);
            toNameAddress.setDisplayName(toDisplayName);
             = .createToHeader(toNameAddressnull);
            // create Request URI
             = .createSipURI(toUserpeerHostPort);
            // Create ContentTypeHeader
                    "application""sdp");
            // Create a new MaxForwardsHeader
             = .createMaxForwardsHeader(70);
            // Create contact headers
            String host = localHost;
            SipURI contactUrl = .createSipURI(fromNamehost);
            contactUrl.setPort(.getPort());
            // Create the contact name address.
            SipURI contactURI = .createSipURI(fromNamehost);
            contactURI.setPort(.getListeningPoint()
                    .getPort());
            Address contactAddress = .createAddress(contactURI);
            // Add the contact address.
            contactAddress.setDisplayName(fromName);
             = .createContactHeader(contactAddress);
        } catch (Exception ex) {
            ..println(ex.getMessage());
            ex.printStackTrace();
            usage();
        }
    }
    /* extract something about Request as a seperated function from init() */
    void sendInviteRequest(int cmdSeq) {
        ..println("====Send INVITE at times: " + cmdSeq);
        try {
             = .createCSeqHeader(1L, .);
            // Create a new CallId header
            CallIdHeader callIdHeader = .getNewCallId();
            int fromTag = 1000 + cmdSeq;
                    new Integer(fromTag).toString());
            String sdpData = "v=0\r\n"
                    + "o=4855 13760799956958020 13760799956958020"
                    + " IN IP4  129.6.55.78\r\n" + "s=mysession session\r\n"
                    + "p=+46 8 52018010\r\n" + "c=IN IP4  129.6.55.78\r\n"
                    + "t=0 0\r\n" + "m=audio 6022 RTP/AVP 0 4 18\r\n"
                    + "a=rtpmap:0 PCMU/8000\r\n" + "a=rtpmap:4 G723/8000\r\n"
                    + "a=rtpmap:18 G729A/8000\r\n" + "a=ptime:20\r\n";
            //Create ViaHeaders
            ArrayList viaHeaders = new ArrayList();
                    .getPort(), null);
            // add via headers
            viaHeaders.add(viaHeader);
            Request request = .createRequest(,
                    .callIdHeader,
                    viaHeaders);
            request.setHeader();
            request.setContent(sdpData);
            // Create the client transaction.
            ClientTransaction inviteTid = 
                    .getNewClientTransaction(request);
            ..println("inviteTid = " + inviteTid + " sipDialog = " + inviteTid.getDialog());
            // send the request out.
            inviteTid.sendRequest();
        } catch (Exception ex) {
            ..println("Fail to sendInviteRequest with SipException:\n"
                    + ex.getMessage());
        }
        return;
    }
    public static void main(String args[]) throws Exception {
        ..println("\n***localHost=<" +  + ">, peerHostPort=<"
                +  + ">.");
        int loops = 500;
        int cmdSeq = 1;
        Shootist shootist = new Shootist();
        shootist.init();
        /* simply send multiple INVITEs, no multi-thread */
        for (int i = 0; i < loopsi++) {
            Thread.sleep(10);
            shootist.sendInviteRequest(cmdSeq++);
        }
    }
    public void processIOException(IOExceptionEvent exceptionEvent) {
        ..println("An IO Exception occured!");
    }
    public void processTransactionTerminated(
            TransactionTerminatedEvent transactionTerminatedEvent) {
        // System.out.println("TransactionTerminated event notification");
    }
    public void processDialogTerminated(
            DialogTerminatedEvent dialogTerminatedEvent) {
        this. ++;
        ..println("DialogTerminatedEvent notification " + this. +
                " dialog ID = "dialogTerminatedEvent.getDialog().getDialogId());
    }
New to GrepCode? Check out our FAQ X