Examples of CommandResponse


Examples of com.automatak.dnp3.CommandResponse

        return new CommandResultCallback() {
            @Override
            public void onCommandCallback(int result, int status) {
                CommandResult r = CommandResult.fromType(result);
                CommandStatus s = CommandStatus.fromType(status);
                p.set(new CommandResponse(r,s));
            }
        };
    }
View Full Code Here

Examples of com.cisco.telnet.server.domain.response.CommandResponse

  }

  private String executeCommand(String command, TelnetCommand telnetCommand) {
    String response;
    CommandRequest commandRequest = new StringCommandRequest(command);
    CommandResponse commandResponse = telnetCommand.execute(commandRequest, sessionContext);
    response = commandResponse.getResultAsString();
    return response;
  }
View Full Code Here

Examples of mungbean.protocol.message.CommandResponse

    public boolean isMaster() {
        try {
            return execute(new DBConversation<Boolean>() {
                @Override
                public Boolean execute(Connection connection) {
                    CommandResponse response = connection.execute(new CommandRequest("$cmd", "ismaster"));
                    Object value = response.get("ismaster");
                    return value.equals(1L) || Boolean.TRUE.equals(value);
                }
            });
        } catch (RuntimeIOException e) {
            return false;
View Full Code Here

Examples of org.asteriskjava.manager.response.CommandResponse

    }

    public void testMultipleLogins() throws Exception
    {
        DefaultManagerConnection dmc;
        CommandResponse response;

        dmc = getDefaultManagerConnection();
        dmc.setDefaultResponseTimeout(5000);

        for (int i = 0; i < 10; i++)
        {
            dmc.login();
            response = (CommandResponse) dmc.sendAction(new CommandAction("show version"));
            assertTrue("version does not start with \"Asterisk\"", response.getResult().get(0).startsWith("Asterisk"));
            dmc.logoff();
        }
    }
View Full Code Here

Examples of org.chromium.sdk.internal.v8native.protocol.input.CommandResponse

    V8NativeProtocolParser parser = V8ProtocolParserAccess.get();

    IncomingMessage response = parser.parseIncomingMessage(json);
    Long l1 = response.seq();
    MessageType type = response.type();
    CommandResponse commandResponse = response.asCommandResponse();
    Long l2 = commandResponse.requestSeq();
    boolean success = commandResponse.success();
    SuccessCommandResponse successResponse = commandResponse.asSuccess();
    Boolean running = successResponse.running();
    Object body = successResponse.body();
    List<?> refs = successResponse.refs();
    SuccessCommandResponse successResponse2 = parser.parseSuccessCommandResponse(json);
    response = null;
View Full Code Here

Examples of org.freeswitch.esl.client.transport.CommandResponse

        log.debug( "Auth requested, sending [auth {}]", "*****" );
        EslMessage response = sendSyncSingleLineCommand( ctx.getChannel(), "auth " + password );
        log.debug( "Auth response [{}]", response );
        if ( response.getContentType().equals( Value.COMMAND_REPLY ) )
        {
            CommandResponse commandResponse = new CommandResponse( "auth " + password, response );
            listener.authResponseReceived( commandResponse );
        }
        else
        {
            log.error( "Bad auth response message [{}]", response );
View Full Code Here

Examples of org.geomajas.command.CommandResponse

  @Test
  public void testLog() throws Exception {
    LogRequest request = new LogRequest();
    request.setLevel(LogRequest.LEVEL_INFO);
    request.setStatement("Test log command");
    CommandResponse response = dispatcher.execute(LogRequest.COMMAND, request, null, "en");
    if (response.isError()) {
      response.getErrors().get(0).printStackTrace();
    }
    Assert.assertFalse(response.isError());

    request.setLevel(LogRequest.LEVEL_DEBUG);
    request.setStatement("Test debug log command");
    response = dispatcher.execute(LogRequest.COMMAND, request, null, "en");
    if (response.isError()) {
      response.getErrors().get(0).printStackTrace();
    }
    Assert.assertFalse(response.isError());

    request.setLevel(LogRequest.LEVEL_WARN);
    request.setStatement("Test warn log command");
    response = dispatcher.execute(LogRequest.COMMAND, request, null, "en");
    if (response.isError()) {
      response.getErrors().get(0).printStackTrace();
    }
    Assert.assertFalse(response.isError());

    request.setLevel(LogRequest.LEVEL_ERROR);
    request.setStatement("Test error log command");
    response = dispatcher.execute(LogRequest.COMMAND, request, null, "en");
    if (response.isError()) {
      response.getErrors().get(0).printStackTrace();
    }
    Assert.assertFalse(response.isError());
  }
View Full Code Here

Examples of org.geomajas.command.CommandResponse

  private SecurityTestCommand securityCommand;

  @Test
  public void testValidToken() {
    securityService.put("someToken", createTestAuthentication());
    CommandResponse response = commandDispatcher.execute("test.SecurityTestCommand", null, "someToken", null);
    Assert.assertEquals(0, response.getErrors().size());
  }
View Full Code Here

Examples of org.geomajas.command.CommandResponse

  }
 
  @Test
  public void testBadCommand() {
    securityService.put("someToken", createTestAuthentication());
    CommandResponse response = commandDispatcher.execute("test.BadCommand", null, "someToken", null);
    Assert.assertEquals(1, response.getErrors().size());
    Throwable error = response.getErrors().get(0);
    Assert.assertTrue(error instanceof GeomajasException);
    Assert.assertEquals(ExceptionCode.COMMAND_ACCESS_DENIED, ((GeomajasException) error).getExceptionCode());
  }
View Full Code Here

Examples of org.geomajas.command.CommandResponse

  }

  @Test
  public void testInValidToken() {
    securityService.put("someToken", createTestAuthentication());
    CommandResponse response = commandDispatcher.execute("test.SecurityTestCommand", null, "invalid", null);
    Assert.assertEquals(1, response.getErrors().size());
    Throwable error = response.getErrors().get(0);
    Assert.assertTrue(error instanceof GeomajasSecurityException);
    Assert.assertEquals(ExceptionCode.CREDENTIALS_MISSING_OR_INVALID,
        ((GeomajasSecurityException) error).getExceptionCode());
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.