elasticsearch and camel integration -


I am trying to integrate the camel with elasticsearch ApplicationContext.xml contains the following 

  & lt; Route id = "timer-to-console" & gt; & Lt; From Yuri = "Timer: // Foo? Default Rate = True & amp; Period = 10s" / & gt; & Lt; Change & gt; & Lt; Simple & gt; Hello web application, how are you? & Lt; / simple & gt; & Lt; / Change & gt; & Lt; Yuri = "stream: out" /> & Lt; From Yuri = "Elastic Search: // Local" /> & Lt; / Route & gt;   
 Then when I run  
  mvn jetty: run   
, I'm getting the following  > 
  Very Quarantine = 0, Removed Time = Mon 21 Apr 13:14:43 PDT 2014} BodyType String Body Hello Web Application, How are you? ] stack trace ----------------------------------------------- - ---------------------------------------- java.lang.IllegalArgumentException: operation is unavailable $ ProcessorToAsyncProcessorBridge.process (AsyncProcessorConverterHelper.java:61) on Org.apache.camel.component.elasticsearch.ElasticsearchProducer.process (ElasticsearchProducer.java:54) org.apache.camel.util.AsyncProcessorConverterHelper   < p>  elasticsearch: // clusterName [options] I need to specify  
 / code>  
 thanks,   
 
 The following example with a quick look on the page shown:  
 
 elasticsearch: // local? Operation = INDEX and indexName = twitter and indexType = tweet   
 This will be in an index (index) to index  twitter  in a type of  tweet  Has been named. You can use whatever value you want for indexName and indexType.  
  Update:  Resilient camber is searching for component documentation again ... I think the  local  as the server name in the elastic search connection , You have to run local elastic search examples with local clust users. By default, flexible checker configuration (elasticsearch.yml) is set to run with the clustered user of  Lolastic search

Comments

Post a Comment

Popular posts from this blog

Verilog Error: output or inout port "Q" must be connected to a structural net expression -

I get the error every time, I try to compile. I'm not sure why anyone can help is? I'm new to verilog. Module D_FF (clerk, d, reset_n, q); Input D, Clack, reset_en; Output Q; reg Q; lab4_gdl f1 (.lk (~ clk), d (d), .q.m (qm)); lab4_GDL f2 (.Clk (Clk), D (QM), .Q (Q)); Always start at @ (posedge clk, neggeous reset_n) (Reset_n == 0) Q & lt; = 0; Other questions & lt; = D; Edit End: The problem is what we are asking to do: In this section, you apply the memory / registration circuit on the AlterEdie 2 board. will do. The circuit has the following specifications: The present value of swift SW15-0 on the D2 board should be shown in four hexadecimal four sections of HEX3-0. This part of the circuit will be combination logic. To use an active-less asynchronous reset and KEY1 to use KEY0 as the clock input, you must store SW15-0in in a 16-bit register in the value The register should be enabled to have a 16-bit positive edge, which uses the embedded D flip-flo...
Read more

Installing croogo for cakephp -

I'm new to the keyboard, I want to install Crogo in KKPP 2.3. My question: The way to extract the file is: - Changing cakephp2.3 / app / plugging / folder in app (do not work. Error admin controller not found) or - CakePP-2.3.3 / app / (Not working ). Sorry for my bad english language: (please help me and thank you.) crogo a cms by kcfp has been developed ... meaning kkfp is already there .. just Croogo Download and read their documentation ... and try Google about some CMS ...
Read more

c# - ASP.NET MVC - Attaching an entity of type 'MODELNAME' failed because another entity of the same type already has the same primary key value -

In brief, the wrapper module is inserted during posting and the status of an entry is changed to 'modified' . Before changing the state, the state is set to 'separate', but calling attachments () causes the same error to be thrown away. I am using EF 6. Model / wrapper class public class avi model {public A is a {get; Set; } Public listing & lt; B & gt; B {received; Set; } Public cc {receipt; Set; }} Administrator edit public functioning (int? id) {if (id == null) {new HttpStatusCodeResult (HttpStatusCode.BadRequest); } If (! Conveyor Access (id.Value)) new HTTPTitus code result (HTTP status code. Forbidden); Var aViewModel = new AViewModel (); aViewModel.A = db.As.Find (id); If (aViewModel.Receipt == zero) {return HttpNotFound (); } aViewModel.b = db.Bs.Where (x => x.aid == id.Value) .Oolist (); AViewModel.Vendor = db.Cs.Where (x => x.cid == aViewModel.a.cID) .FirstOrDefault (); See Return (aViewModel); } [HTPFost] [Valid AntitiferousTeacon...
Read more