Examples of org.cipango.diameter.api.DiameterServletRequest

org.cipango.diameter.api.DiameterServletRequest
Represents Diameter request. When receiving an incoming Diameter request the container creates a DiameterServletRequest and passes it to the handling DiameterListener. For outgoing, locally initiated requests, applications call {@linkplain DiameterFactory#createRequest(SipApplicationSession,ApplicationId,DiameterCommand,String) DiameterFactory.createRequest} to obtain a DiameterServletRequest that can then bemodified and sent.


      @Override
      public void doHandle(DiameterMessage message) throws Throwable
      {
        DiameterServletAnswer uda;
        DiameterServletRequest request = (DiameterServletRequest) message;


        assertEquals(true, message.isRequest());
        assertEquals(Sh.UDR, request.getCommand());
        assertEquals(request.getApplicationId(), Sh.SH_APPLICATION_ID.getId());
        assertEquals(request.getDestinationHost(), "server");
        uda = request.createAnswer(Common.DIAMETER_SUCCESS);
        uda.send();
      }
      
    };
    _server.setHandler(serverHandler);

View Full Code Here


      @Override
      public void doHandle(DiameterMessage message) throws Throwable
      {
        DiameterServletAnswer uda;
        DiameterServletRequest request = (DiameterServletRequest) message;


        assertEquals(true, message.isRequest());
        assertEquals(Sh.UDR, request.getCommand());
        assertEquals(request.getApplicationId(), Sh.SH_APPLICATION_ID.getId());
        assertEquals(request.getDestinationHost(), "server");
        uda = request.createAnswer(Common.DIAMETER_SUCCESS);
        uda.send();
      }
      
    };
    _server.setHandler(serverHandler);
    _server.start();
    
    TestDiameterHandler clientHandler = new TestDiameterHandler()
    {
      
      @Override
      public void doHandle(DiameterMessage message) throws Throwable
      {
        DiameterServletAnswer uda = (DiameterServletAnswer) message;
  
        assertFalse(message.isRequest());
        assertEquals(Sh.UDA, uda.getCommand());
        assertEquals(uda.getApplicationId(), Sh.SH_APPLICATION_ID.getId());


      }
    };
    _client.setHandler(clientHandler);
    _client.start();
    
    waitPeerOpened();
    


    DiameterFactory clientFactory = createFactory(_client);
    DiameterServletRequest udr = clientFactory.createRequest(null, Sh.SH_APPLICATION_ID, Sh.UDR, "server");
    
    udr.add(Common.DESTINATION_HOST, "server");
    udr.getAVPs().add(Sh.DATA_REFERENCE, DataReference.SCSCFName);
    AVP<AVPList> userIdentity = new AVP<AVPList>(Sh.USER_IDENTITY, new AVPList());
        userIdentity.getValue().add(Cx.PUBLIC_IDENTITY, "sip:alice@cipango.org");
    udr.getAVPs().add(userIdentity);
    udr.getAVPs().add(Common.AUTH_SESSION_STATE, AuthSessionState.NO_STATE_MAINTAINED);
    udr.getSession();
    udr.send();
    serverHandler.assertDone();
    clientHandler.assertDone();
  }

View Full Code Here

          assertEquals(_session, message.getSession());
        }
        else
        {
          DiameterServletAnswer sna;
          DiameterServletRequest request = (DiameterServletRequest) message;
  
          assertEquals(true, message.isRequest());
          assertEquals(Sh.SNR, request.getCommand());
          assertEquals(request.getApplicationId(), Sh.SH_APPLICATION_ID.getId());
          assertEquals(request.getDestinationHost(), "server");
          sna = request.createAnswer(Common.DIAMETER_SUCCESS);
          _sessionId = request.getSessionId();
          assertNotNull(_sessionId);
          _session = request.getSession();
          assertNotNull(_session);
          sna.send();
          
          Thread.sleep(50);
          DiameterServletRequest pnr = _session.createRequest(Sh.PNR, true);
          pnr.send();
        }
      }
      
    };
    _server.setHandler(serverHandler);
    _server.start();
    
    TestDiameterHandler clientHandler = new TestDiameterHandler()
    {
      private String _sessionId;
      private DiameterSession _session;
      
      @Override
      public void doHandle(DiameterMessage message) throws Throwable
      {
        if (message instanceof DiameterServletAnswer)
        {
          DiameterServletAnswer sna = (DiameterServletAnswer) message;
          assertEquals(Sh.SNA, sna.getCommand());
          assertEquals(sna.getApplicationId(), Sh.SH_APPLICATION_ID.getId());
          _sessionId = sna.getSessionId();
          _session = sna.getSession();
          assertNotNull(_sessionId);
          assertNotNull(_session);
          assertEquals(_sessionId, sna.getRequest().getSessionId());
        }
        else
        {
          DiameterServletRequest pnr = (DiameterServletRequest) message;
          assertEquals(Sh.PNR, pnr.getCommand());
          assertEquals(_sessionId, pnr.getSessionId());
          assertEquals(_session, pnr.getSession());
          pnr.createAnswer(Common.DIAMETER_SUCCESS).send();
        }
      }
    };
    _client.setHandler(clientHandler);
    _client.start();

View Full Code Here

TOP

Related Classes of org.cipango.diameter.api.DiameterServletRequest

org.cipango.diameter.node.NodeTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.