Unmarshaling (json) в Apache Camel ⇐ JAVA

[Anonymous]

Я новичок в Apache Camel. И я хочу выполнить простую задачу, используя Apache Camel. У меня есть данные JSON, доступные на этом URL http: // localhost: 8080/users/. Есть данные JSON от моей службы отдыха. Но я хочу доставить эти данные JSON и Unmarshal их в Pojo, используя Apache Camel и написать некоторые данные в файл TXT. Но мое приложение начинается, а затем не останавливается.

Код: Выделить всё

[{"id":1,"login":"admin","password":"admin","passwordAgain":null,"email":"admin@admin.com","firstName":"Admin","lastName":"Adminovich","birthday":"2010-10-10","role":{"id":1,"name":"admin"}},
{"id":5,"login":"Snow123","password":"1111","passwordAgain":null,"email":"john@snow.com","firstName":"John","lastName":"Snow","birthday":"2010-10-10","role":{"id":2,"name":"user"}}]< /code>
< /div>
< /div>
< /p>

spring.xmlобразной PrettyPrint-Override ">











< /code>
< /div>
< /div>
< /p>

myroutebuilder < /p>


import Mapping.User;
import Mapping.Users;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.main.Main;
import org.apache.camel.component.restlet.RestletConstants;
import org.apache.camel.model.dataformat.JsonLibrary;
import org.restlet.Response;
import org.restlet.data.MediaType;
import org.restlet.data.Status;

public class MyRouteBuilder extends RouteBuilder {

private String routePort = null;
private String routeAnswer = null;

public void restart() {
String start = "Route Property Placeholder Example started on port" + " 8080" + "!";
System.out.println(start);
}

public void configure() throws Exception {
from("timer:foo?repeatCount=1").to("http://10.10.34.145:8080/users/").unmarshal().json(JsonLibrary.Jackson,  Users.class ).log("STARTED!")
.process(new Processor() {
public void process (Exchange exchange) throws Exception {
Users usersList = exchange.getIn().getBody(Users.class);
exchange.getIn().setBody(usersList.usersList);
System.out.println(usersList.usersList.size());
}
}).to("file:///home/name/username/Desktop/camel.txt").stop();

}
}< /code>
< /div>
< /div>
< /p>

user < /p>






< /div>
< /div>
< /p>

Пользователи < /p>






< /div>
< /div>

main < /p>



import org.apache.camel.main.Main;

public class MainClass {

public static void main(String[] args) {
Main main = new Main();
main.enableHangupSupport();

MyRouteBuilder rb = new MyRouteBuilder();
main.addRouteBuilder(rb);
try {
main.run(args);
} catch (Exception e) {
e.printStackTrace();
}
}

}

Подробнее здесь: https://stackoverflow.com/questions/374 ... ache-camel