Tag: spring-integration

Habe ich eine Konfigurations-bean, die eine Liste der zulässigen Werte: @Component public class Conf { public List<String> getAllowedValues() { return Arrays.asList("A", "B", "C", "D"); } Habe ich aufgefüllt, meine Kopfzeilen mit einem Feld namens 'someValue' und ich

Beim hinzufügen von Nachrichten an eine queue, in die eine ActiveMQ-broker, wo es keine Abonnenten, die Warteschlange füllt und schließlich der Produzent-thread hängt, nicht veröffentlichen kann mehr Nachrichten. In einem Versuch, das problem zu beheben ich ein

Bin ich mit spring integration, um TCP-Aufruf zum server, indem Sie einige Nachricht und erste Antwort zurück. Ich bevorzuge channel-adapter zum senden und empfangen von bulk-Nachrichten. Das problem, das ich bin vor ist mit der Antwort Kanal.

In meinem Anwendungskontext Datei Eclipse zeigt den Fehler: Referenzierten Datei enthält Fehler (http://www.springframework.org/schema/integration). applicationContext.xml Linie 1 XML-Problem Blick auf die Fehler detail in Eclipse sehe ich: White spaces are required between publicId and systemId Nach anderen Leuten

Ich bin ein Anfänger auf den Frühling und ich muss ein Projekt für die Schule. Welche Art von Projekt kann ich tun, was ich verwenden kann, Spring Batch und Integration. Ich weiß, dass ich schreiben kann, Dateien

Ich versuche einen server im Frühjahr, der hört auf einem TCP-port und verbindungen akzeptiert. Ich weiß, wie, um eingehende Anfragen zu meinem Dienst, und es kann die Reaktion auf diese. Allerdings würde ich mag, um das senden

Begann ich mit spring-integration-kafka in mein Projekt, und ich kann das produzieren und konsumieren von Nachrichten von Kafka. Aber jetzt, ich wollen, um zu produzieren-Nachricht an bestimmte partition und verbrauchen auch Nachricht von der entsprechenden partition. Beispiel,

Schrieb ich eine einfache spring-integration-Anwendung, verschiebt Dateien von einem Verzeichnis in ein anderes, es sieht wie folgt aus: @Bean @InboundChannelAdapter(value="requestChannel", poller = @Poller(fixedDelay="100")) public FileReadingMessageSource adapter(){ FileReadingMessageSource source = new FileReadingMessageSource(); source.setDirectory(new File("D:/TestIn")); return source; } @Bean

Ich bin versucht zu schreiben-channel-adapter für JMS-queue ein. Ich möchte, um eine Nachricht zu senden, um JMS-Warteschlange und erhalten Sie an der Spring-Integration-Kanal. Wenn ich mit normal-JMS (mit ActiveMQ), alles funktioniert einwandfrei, also gehe ich davon aus

Habe ich eine Spring-Integration-Anwendung mit Spring Boot. Ich würde gerne wissen, wie konfigurieren der JMX-mit Spring Boot. Ich glaube, standardmäßig JMX konfiguriert ist, wenn mit Spring-Boot-Antrieb. Muss ich konfigurieren, alles andere, um in der Lage zu exportieren

Bin ich immer eine Ausnahme Dispatcher has no subscribers auf die outboundChannel und kann nicht herausfinden, warum. Ich bin sicher, es ist etwas einfacher, ich habe gestrippt zurück mein code, um ein sehr einfaches Beispiel: Meinen Kontext

Ist es eh manuell starten/init einem channel-adapter? Ich habe zwei Paare von inbound - /outbound-Adapter in meinem context.xml und möchte zur Laufzeit entscheiden, welche von Ihnen ich will loslegen. EDIT: Das konkrete Szenario: Ich habe einen client,

Ich versuche zu verspotten, den externen Anruf anzunehmen. HTML: ResponseEntity<?> httpResponse = requestGateway.pushNotification(xtifyRequest); requestGateway ist eine Schnittstelle. public interface RequestGateway { ResponseEntity<?> pushNotification(XtifyRequest xtifyRequest); } Unten ist die test-Methode, die ich bin versucht zu tun. @Test public

Hab ich etwas gesucht, aber konnte nicht finden jedes sample/Beispiel. Habe ich eine Anforderung, wo die geo-Koordinaten aus einer Tabelle (Eingabe) gelesen, verarbeitet zu erzeugen, POI ' s verbunden zu koordinieren. So eine geo-Koordinate wird in einer

Habe ich ein kleines Programm lauscht auf einem port 30003. Es ist eine server-Klasse, die Prozesse bytestream-Daten wie folgt: sbsSocket = new Socket(sbsHost, sbsPort); sbsReader = new BufferedReader(new InputStreamReader(sbsSocket.getInputStream())); private void startSBSMessageReceiverThread() { new Thread(new Runnable() {

Habe ich zwei Systeme integriert sind, mit RabbitMQ. Hintergrund Client-senden Sie multiple-request-Nachrichten von Spring-AMQP outbound-Gateway zu RabbitMQExchange, die rabbitmq-DirectExchange verwenden round-robin - Versand dieser Nachrichten an Mehrere Arbeitnehmer(die Arbeiter sind unabhängige, die sich auf verschiedenen desktops die

Derzeit in unserem Projekt verwenden wir das spring-framework. Wir sind in der Planung und Implementierung von Spring Integration framework in unser Projekt, weil einige der Projektanforderungen. Wollte ich werfen, Spring-Integration-Beispiel(Spring-Integration-Rest-HTTP-Pfad-Nutzung Demo) appications unten ist applicationContext-http-int.xml Datei <?xml

Gut, ich bin versucht zu konsumieren REST-webservice mit RestTemplate im Frühjahr. Der Dienst gibt eine JSON Liste von Objekten, die in ihm als unten. [ { "name": "123", "ids": { "y": 36.41666667, "x": 39.58333333, "z": 12 },

Mein Aktuelles Projekt basiert auf Spring Batch und Spring integration. Mein Ziel ist mit Spring Batch zum ausführen von job-flow-Schritte: Datei Lesen von SFTP-server(Schritt 1). die Datei entschlüsseln(Schritt 2). speichern Sie die Datei in die Datenbank(Schritt 3).

Bin ich mit spring-integration in mein Projekt. Wenn ich die Bereitstellung der app in den jetty-container, erhalte ich folgende exception: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'integrationRequestMappingHandlerMapping': Initialization of bean failed; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating

<int:poller fixed-delay="${fixedDelay}" default="true"> <int:advice-chain> <ref bean="pollAdvise"/> </int:advice-chain> </int:poller> <bean id="pollAdvise" class="org.springframework.integration.scheduling.PollSkipAdvice"> <constructor-arg ref="healthCheckStrategy"/> </bean> <bean id="healthCheckStrategy" class="test.main.ServiceHealthCheckPollSkipStrategy"> <property name="url" value="${url}"/> <property name="doHealthCheck" value="${doHealthCheck}"/> <property name="restTemplate" ref="restTemplate"/> </bean> <bean id="restTemplate" class="org.springframework.web.client.RestTemplate"> <constructor-arg ref="requestFactory"/> </bean> <bean id="requestFactory" class="test.BatchClientHttpRequestFactory"> <constructor-arg

Ich wan ' T zu schreiben, Spring-Boot-Anwendung im Frühjahr, die werden monitoring-Verzeichnis in windows, und wenn ich sub-Ordner, oder fügen Sie neue hinzu oder löschen vorhandene ich möchte Informationen über die. Wie kann ich das tun? Ich

bekam ich diese Fehlermeldung, wenn ich dieses Beispiel http://viralpatel.net/blogs/2010/11/spring3-mvc-hibernate-maven-tutorial-eclipse-example.html javax.servlet.ServletException: Servlet.init() for servlet spring threw exception org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:462) org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:100) org.apache.catalina.valves.AccessLogValve.invoke(AccessLogValve.java:562) org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:395) org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:250) org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:188) org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:166) org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:302) java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.lang.Thread.run(Unknown Source) root cause org.springframework.beans.factory.BeanCreationException: Error creating bean with

Ich bin neu in Spring-Framework und in der Tat, ich bin zu lernen und mit Spring Boot. Vor kurzem, in der app, die ich entwickle, die ich gemacht Quartz Scheduler arbeiten, und jetzt möchte ich Spring Integration

Sind wir mit den neuesten Frühjahrs-Boot für einen Frühling-app und mithilfe der neuesten Frühjahrs-Integration für SFTP. Ich habe die Spring-Integration-SFTP-Dokumentations-Website, und ich fand das Spring-Boot-Konfiguration ist: @Bean public SessionFactory<LsEntry> sftpSessionFactory() { DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true); factory.setHost("localhost");