Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Comment: updated per CAMEL-4880/4881

...

The Solr component allows you to interface with an Apache Lucene Solr server (based on SolrJ 3.5.0).

Maven users will need to add the following dependency to their pom.xml for this component:

...

name

default value

description

maxRetries

0

maximum number of retries to attempt in the event of transient errors

soTimeout

1000

read timeout on the underlying HttpConnectionManager. This is desirable for queries, but probably not for indexing

connectionTimeout

100

connectionTimeout on the underlying HttpConnectionManager

defaultMaxConnectionsPerHost

2

maxConnectionsPerHost on the underlying HttpConnectionManager

maxTotalConnections

20

maxTotalConnection on the underlying HttpConnectionManager

followRedirects

false

indicates whether redirects are used to get to the Solr server

allowCompression

false

server side must support gzip or deflate for this to have any effect

requestHandler

/update (xml)

set the request handler to be used

streamingThreadCount

2

Camel 2.10 set the number of threads for the StreamingUpdateSolrServer

streamingQueueSize

10

Camel 2.10 set the queue size for the StreamingUpdateSolrServer

Message Operations

The following Solr operations are currently supported. Simply set an exchange header with a key of "SolrOperation" and a value set to one of the following. Some operations also require the message body to be set.

operation

message body

description

INSERT

empty

adds an index using message headers (must be prefixed with "SolrField.")

INSERT

SolrInputDocument

Camel 2.10 adds an index based on the given SolrInputDocument

INSERT_STREAMING

empty

Camel 2.10 uses the StreamingUpdateSolrServer to add an index using message headers (

n/a

insert a new record based on headers values (headers must be prefixed with "SolrField.")

INSERT_STREAMING

SolrInputDocument

Camel 2.10 uses the StreamingUpdateSolrServer to add an index based on the given SolrInputDocument

ADD_BEAN

bean instance

insert a new record adds an index based on values in an annotated bean

DELETE_BY_ID

index id to delete

delete a record by ID

DELETE_BY_QUERY

query string

delete a record by a query

COMMIT

n/a

performs a commit on any pending index changes

ROLLBACK

n/a

performs a rollback on any pending index changes

OPTIMIZE

n/a

performs a commit on any pending index changes and then runs the optimize command

...