Hi,
I'm writing a SIP messaging klient and i am having problem with connecting the client to my SIP-server (OpenSER)
javax.sip.InvalidArgumentException: 300:123qwe@192.168.1.99: 300:123qwe@192.168.1.99
at gov.nist.javax.sip.SipStackImpl.createListeningPoint(SipStackImpl.java:645)
at sipTrade.createProvider(sip.java:274)
at sipTrade.main(sip.java:299)
Caused by: java.net.UnknownHostException: 300:123qwe@192.168.1.99: 300:123qwe@192.168.1.99
at java.net.InetAddress.getAllByName0(Unknown Source)
at java.net.InetAddress.getAllByName0(Unknown Source)
at java.net.InetAddress.getAllByName(Unknown Source)
at java.net.InetAddress.getByName(Unknown Source)
at gov.nist.javax.sip.SipStackImpl.createListeningPoint(SipStackImpl.java:625)
... 2 more
import java.io.*;
import javax.sip.*;
import javax.sip.address.*;
import javax.sip.header.*;
import javax.sip.message.*;
import java.util.*;
/**
*
*
*
*/
public class sip implements SipListener {
private static AddressFactory addressFactory;
private static MessageFactory messageFactory;
private static HeaderFactory headerFactory;
private static SipStack sipStack;
private int port;
protected SipProvider udpProvider;
protected Dialog dialog;
protected int notifyCount = 0;
protected final String serverIP = "300:123qwe@192.168.1.99";
class MyEventSource implements Runnable {
private sipTrade st;
private EventHeader eventHeader;
public MyEventSource(sipTrade notifier, EventHeader eventHeader ) {
this.st = notifier;
this.eventHeader = eventHeader;
}
public void run() {
try {
for (int i = 0; i < 100; i++) {
Thread.sleep(100);
Request request = this.st.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 = udpProvider.getNewClientTransaction(request);
System.out.println("NOTIFY Branch ID "+((ViaHeader)request.getHeader(ViaHeader.NAME)).getParameter("branch"));
this.st.dialog.sendRequest(ct);
System.out.println("Dialog " + dialog);
System.out.println("Dialog state after active NOTIFY: " + dialog.getState());
synchronized (sipTrade.this) {
notifyCount ++;
}
}
} catch (Throwable e) {
e.printStackTrace();
}
}
}
private static void usage() {
System.exit(0);
}
public void processRequest(RequestEvent requestEvent) {
Request request = requestEvent.getRequest();
ServerTransaction serverTransactionId = requestEvent.getServerTransaction();
System.out.println("\n\nRequest " + request.getMethod()+" received at " + sipStack.getStackName()+" with server transaction id " + serverTransactionId+" and dialog id "+requestEvent.getDialog());
if (request.getMethod().equals(Request.SUBSCRIBE)) {
processSubscribe(requestEvent, serverTransactionId);
}
}
/**
* Process the invite request.
*/
public void processSubscribe(RequestEvent requestEvent,
ServerTransaction serverTransaction) {
SipProvider sipProvider = (SipProvider) requestEvent.getSource();
Request request = requestEvent.getRequest();
try {
System.out.println("notifier: got an Subscribe sending OK");
System.out.println("notifier: " + request);
System.out.println("notifier : dialog = " + requestEvent.getDialog());
EventHeader eventHeader = (EventHeader) request.getHeader(EventHeader.NAME);
if ( eventHeader == null) {
System.out.println("Cannot find event header.... dropping request.");
return;
}
// Always create a ServerTransaction, best as early as possible in the code
Response response = null;
ServerTransaction st = requestEvent.getServerTransaction();
if (st == null) {
st = sipProvider.getNewServerTransaction(request);
}
// Check if it is an initial SUBSCRIBE or a refresh / unsubscribe
boolean isInitial = requestEvent.getDialog() == null;
if ( isInitial ) {
// need random tags to test forking
String toTag = Integer.toHexString( (int) (Math.random() * Integer.MAX_VALUE) );
response = messageFactory.createResponse(202, request);
ToHeader toHeader = (ToHeader) response.getHeader(ToHeader.NAME);
// Sanity check: to header should not ahve a tag. Else the dialog
// should have matched
if (toHeader.getTag()!=null) {
System.err.println( "####ERROR: To-tag!=null but no dialog match! My dialog=" + dialog.getState() );
}
toHeader.setTag(toTag); // Application is supposed to set.
this.dialog = st.getDialog();
// subscribe dialogs do not terminate on bye.
this.dialog.terminateOnBye(false);
if (dialog != null) {
System.out.println("Dialog " + dialog);
System.out.println("Dialog state " + dialog.getState());
}
} else {
response = messageFactory.createResponse(200, request);
}
// Both 2xx response need a Contact
Address address = addressFactory.createAddress("xTrade <sip:127.0.0.1>");
((SipURI)address.getURI()).setPort( udpProvider.getListeningPoint("udp").getPort() );
ContactHeader contactHeader = headerFactory.createContactHeader(address);
response.addHeader(contactHeader);
// Expires header is mandatory in 2xx responses to SUBSCRIBE
ExpiresHeader expires = (ExpiresHeader) request.getHeader( ExpiresHeader.NAME );
if (expires==null) {
expires = headerFactory.createExpiresHeader(30); // rather short
}
response.addHeader( expires );
st.sendResponse(response);
/*
* 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)contactHeader.getAddress().getURI()).setParameter("id","not");
// Initial state is pending, second time we assume terminated (Expires==0)
SubscriptionStateHeader sstate = headerFactory.createSubscriptionStateHeader(
isInitial ? SubscriptionStateHeader.PENDING : SubscriptionStateHeader.TERMINATED );
// Need a reason for terminated
if ( sstate.getState().equalsIgnoreCase("terminated") ) {
sstate.setReasonCode( "deactivated" );
}
notifyRequest.addHeader(sstate);
notifyRequest.setHeader(eventHeader);
notifyRequest.setHeader(contactHeader);
// notifyRequest.setHeader(routeHeader);
ClientTransaction ct = udpProvider.getNewClientTransaction(notifyRequest);
// Let the other side know that the tx is pending acceptance
//
dialog.sendRequest(ct);
System.out.println("NOTIFY Branch ID " +
((ViaHeader)request.getHeader(ViaHeader.NAME)).getParameter("branch"));
System.out.println("Dialog " + dialog);
System.out.println("Dialog state after pending NOTIFY: " + dialog.getState());
if (isInitial) {
Thread myEventSource = new Thread(new MyEventSource(this,eventHeader));
myEventSource.start();
}
} catch (Throwable ex) {
ex.printStackTrace();
// System.exit(0);
}
}
public synchronized void processResponse(ResponseEvent responseReceivedEvent) {
Response response = (Response) responseReceivedEvent.getResponse();
Transaction tid = responseReceivedEvent.getClientTransaction();
if ( response.getStatusCode() != 200 ) {
this.notifyCount --;
} else {
System.out.println("Notify Count = " + this.notifyCount);
}
}
public void processTimeout(javax.sip.TimeoutEvent timeoutEvent) {
Transaction transaction;
if (timeoutEvent.isServerTransaction()) {
transaction = timeoutEvent.getServerTransaction();
} else {
transaction = timeoutEvent.getClientTransaction();
}
System.out.println("state = " + transaction.getState());
System.out.println("dialog = " + transaction.getDialog());
System.out.println("dialogState = "
+ transaction.getDialog().getState());
System.out.println("Transaction Time out");
}
private static void initFactories ( int port ) throws Exception {
SipFactory sipFactory = SipFactory.getInstance();
sipFactory.setPathName("gov.nist");
Properties properties = new Properties();
properties.setProperty("javax.sip.STACK_NAME", "notifier" + port );
// 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",
"notifierdebug_"+port+".txt");
properties.setProperty("gov.nist.javax.sip.SERVER_LOG",
"notifierlog_"+port+".txt");
try {
// Create SipStack object
sipStack = sipFactory.createSipStack(properties);
System.out.println("sipStack = " + sipStack);
} catch (PeerUnavailableException e) {
// could not find
// gov.nist.jain.protocol.ip.sip.SipStackImpl
// in the classpath
e.printStackTrace();
System.err.println(e.getMessage());
if (e.getCause() != null)
e.getCause().printStackTrace();
System.exit(0);
}
try {
headerFactory = sipFactory.createHeaderFactory();
addressFactory = sipFactory.createAddressFactory();
messageFactory = sipFactory.createMessageFactory();
} catch (Exception ex) {
ex.printStackTrace();
System.exit(0);
}
}
public void createProvider() {
try {
ListeningPoint lp = sipStack.createListeningPoint(this.serverIP, this.port, "udp");
this.udpProvider = sipStack.createSipProvider(lp);
System.out.println("udp provider " + udpProvider);
} catch (Exception ex) {
System.out.println((ex.getMessage()));
ex.printStackTrace();
usage();
}
}
public sipTrade( int port ) {
this.port = port;
}
public sipTrade(){
}
public static void main(String args[]) throws Exception {
int port = args.length > 0 ? Integer.parseInt(args[0]) : 5060;
initFactories( port );
sipTrade notifier = new sipTrade( port );
notifier.createProvider( );
notifier.udpProvider.addSipListener(notifier);
//sipTrade st = new sipTrade();
//st.Send2xTrade("198202050897", "testdata");
//st.getXTmsg(0);
}
public void processIOException(IOExceptionEvent exceptionEvent) {
}
public void processTransactionTerminated(
TransactionTerminatedEvent transactionTerminatedEvent) {
}
public void processDialogTerminated(
DialogTerminatedEvent dialogTerminatedEvent) {
// TODO Auto-generated method stub
}
/*
* Xtrade connection - DATA IN
*/
public void Send2xTrade(String data, String info) {
try{
IServer is = ServerFactory.createObject(ip);
is.logOn(clientName_in, SessionType.LogOnRxTx);
is.sendMsg(contract_in,MsgPriority.Def, data.getBytes(), info);
is.logOff();
}
catch (Exception e){
e.printStackTrace();
System.err.println(e.getMessage());
}
}
public void getXTmsg(int xtMsgAck){
IMsg msg; // A single xTrade message
MsgInfo msgInfo = null; // Message information
byte[] theData;
try {
IServer is = ServerFactory.createObject(ip);
is.logOn(clientName_out, SessionType.LogOnRxTx);
msg = is.createNextRxMsg(contract_out);
FileOutputStream myStream = new FileOutputStream("rx" + msg.getHandle() + ".msg"); // Create the stream
msg.getData(myStream);
myStream.close();
if(msgInfo.getAcknowledge() == false){
msg.setReceived();
}
else if(msgInfo.getAcknowledge() == true && xtMsgAck == 0){
msg.setReceived();
msg.setAck();
}
else if(msgInfo.getAcknowledge() == true && xtMsgAck == 1){
msg.setReceived();
msg.setNack();
}
is.logOff();
}catch (XTException e){
}
catch(Exception e){
}
}
}