Index

Search in book...
Toggle Font Controls
Create new playlist

Name your new playlist

Playlist description (optional)
Sign In

Email address

Password

Forgot Password?

or

Continue with Facebook

Continue with Google
Sign Up

Full Name

Email address

Confirm Email Address

Password

or

Continue with Facebook

Continue with Google

Previous Chapter

Appendix E. Akka and Camel

Camel in Action

Index

[SYMBOL][A][B][C][D][E][F][G][H][I][J][L][M][N][O][P][Q][R][S][T][U][V][W][X]

SYMBOL

--> operator ==> operator

A

ACID, 2^nd, 3^rd ActiveMQ, 2^nd dead letter queue TCP connectors VM protocol ActiveMQ component, 2^nd, 3^rd ActiveMQConnectionFactory addInterceptStrategy method addRoutes aggregate <aggregate> tag, 2^nd AggregationStrategy, 2^nd example thread safe using Aggregator EIP aggregated size aggregation strategy AggregationStrategy combining message, 2^nd completion condition, 2^nd Aggregated batch consumer completion conditions provided examples interval completion predicate completion, 2nd size completion timeout completion using multiple conditions completion size configuration additional option closeCorrelationKeyOn-Completion eagerCheckCompletion groupExchanges mandatory correlation expression correlation group correlation identifier, 2^nd, 3^rd invalid Exchange properties in Splitter EIP ordering persistence AggregationRepository, 2nd example file based repository HawtDB memory repository pluggable repository RecoverableAggregation-Repository setup HawtDB recovery, 2^nd background task, 2nd commit dead letter channel HawtDBAggregation-Repository interval maximum redeliveries recover RecoverableAggregation-Repository redelivered rollback setup similar to JMS Broker transaction using error handler reject incoming message uses cases akka actor actor API bang operator pattern match reply actor model ActorComponent akka-camel component asynchronous bangbang operator CamelContextManager sending message CamelService, 2^nd customize CamelServiceManager, 2^nd consume from Camel disable JMX endpointUri, 2^nd forwarding message, 2^nd immutable message message exchange pattern one-way messaging produce message ProducerTemplate receive, 2^nd receiveAfterProduce, 2^nd receiveBeforeProduce reply request-reply messaging route routing example sending message to actor software transactional memory some failure some message timeout with Spring XML response alternative languages annotation @Attachments @Autowired @Bean @BeanShell @Body, 2^nd @Consume @DynamicRouter @EL @EndpointInject @Groovy @Handler @Header, 2^nd @Headers @InOnly @InOut @JavaScript @MVEL @ONGL @OutHeaders @PHP @Produce @Properties @Property @Python @RoutingSlip @Ruby @Simple @XPath, 2^nd @XQuery Apache ActiveMQ, 2^nd, 3^rd Apache Camel website Apache CXF HTTP transport link to website Apache Felix Apache Karaf, 2^nd adding Camel feature features install bundle installing listing installed bundles log file shutdown OSGi container starting Apache Maven, 2^nd archetype plugin archetypeArtifactId archetypeVersion create vs. generate goal archetypes artifactId central repository, 2^nd configuring local Maven repository in Eclipse convention over configuration data directory dependency tree directories installed generating an OSGi bundle groupId local download cache managing projects Maven Eclipse plugin obtaining POM, 2^nd pom.xml, 2^nd quickstart archetype recommended reading src directory transitive dependencies using the m2eclipse plugin Apache MINA Apache OpenJPA Apache ServiceMix, 2^nd message bus scalability Apache Tomcat, 2^nd deploying Camel hot deployment, 2^nd leverage servlet transport starting using CXFServlet ApplicationContext, 2^nd ApplicationContextRegistry registry, 2^nd Archetypes asynchronous messaging, 2^nd, 3^rd Atomikos6 @Attachments auditing autocomplete automating tasks AutoStartup, disabling @Autowired

B

BatchConsumer @Bean bean BeanProcessor, 2^nd, 3^rd method adapting to method signature AmbigiousMethodCall Exception BeanInvocation beanRef CamelBeanMethodName @Handler method selection algorithm MethodNotFoundException, 2nd, 3rd NoTypeConversionAvailable Exception selecting bean method selection example, 2nd understanding bean method selection method call expression parameter binding @Bean @Body, 2nd built-in types exception @Header, 2nd multiple parameters @NamespacePrefix single parameter table of annotations table of build in types table of language annotations using annotations using language annotations @XPath @XPath with namespace registry ApplicationContextRegistry JndiRegistry lookup lookup in OSGi service registry lookup in Spring lookupByType multiple registries OsgiServiceRegistry SimpleRegistry table of registries typesafe lookups Service Activator EIP Spring, @Autowired using bean in Java DSL <bean> in Spring XML beanRef from a Processor Bean component, 2^nd <bean> tag BeanInvocation @BeanShell BeanShell bindy annotations BindyType.Csv @CsvRecord data types used @DataField specifying package name using CSV using FIX using fixed length @Body, 2^nd browse builder pattern

C

Camel alternative languages archetypes list of archetypes using camel-archetype-component using camel-archetype-java architecture CamelContext component consumer domain-specific language (DSL) endpoint high level modular and pluggable processor producer routes routing engine bridging routes together community, 2^nd component library components, understanding configuration, easy ConsumerTemplate core, lightweight creating custom components creating routes in Java creating routes with Spring creating WAR from Camel application deploying Camel developing interceptors developing projects directories installed EIPs endpoint example first revisited hide Camel APIs hiding middleware higher-level abstractions Java DSL bean method choice method convertBodyTo method end method, 2nd endsWith predicate executorService method from method header method log method multicast method noStreamCaching method otherwise method recipientList method regex predicate stop method stopOnException method streamCaching method to method tokenize method using Camel Proxy from Java DSL wireTap method xpath method Maven dependencies message model exchange message obtaining OSGi ready payload-agnostic router POJO model predicates and expressions regular expression predicate xpath expression producer and consumer templates ProducerTemplate, 2^nd protocol support reasons to use remoting and Camel proxy route startup order routing routing and mediation engine routing annotations, 2^nd @Consume example dependencies injecting a proxy producer loading annotated classes into Camel @Produce example receiving messages with @Consume referencing a shared endpoint sending messages with @Produce specifying what Camel-Context to use routing engine routing with beans running Scala DSL --> operator ==> operator adding Scala routes to the CamelContext comparison with Java DSL EIPs support maven-scala-plugin Scala RouteBuilder using Java-based Camel-Context with routes shutting down Spring DSL adding a processor adding multiple routes advanced configuration options CamelBeanPostProcessor configuring components and endpoints consumerTemplate element custom camelContext element defining a reusable endpoint dynamic RouteBuilder loading example finding route builders importing configuration and routes importing route defined in another file naming a component packageScan element proxy element route id routeContext element routePolicyRef option routerBuilder element shutdownRoute option starting a Spring Camel-Context manually streamCache option template element when method starting, 2^nd startup options scope TypeConverter using in Eclipse web console, 2nd Camel community articles, blogs, podcasts IRC and JIRA mailing list and reference card website .camel directory Camel extensions, JUnit Camel Extra project, 2^nd Camel registry Camel Test Kit camel-core module, components CamelContext, 2^nd, 3^rd accessing via Processor createNewProducerTemplate method graceful shutdown namespace setStreamCaching method start method starting startRoute stopRoute CamelContext id <camelContext> tag CamelContextFactoryBean CamelInvocationHandler CamelNamespaceHandler Channel, 2^nd, 3^rd, 4^th code-first, 2^nd codec commons-net compensation rollback using synchronization Component, 2^nd component ActiveMQ, 2^nd activemq transaction actor asynchronous processing akka-camel Bean, 2^nd bean, using OGNL custom component, @ManagedAttribute customize output log Direct, 2^nd @EndpointInject fault File file concurrency simple language variables FTP simple language variables HawtDB, 2^nd HTTP Jasypt Jetty, 2^nd, 3^rd, 4^th continuations JMS log MINA, 2^nd, 3^rd Mock, 2^nd unit testing Properties, 2^nd properties file syntax using without Spring SEDA, 2^nd, 3^rd, 4^th simulating smtp velocity XSLT Component interface component resolver components ActiveMQ autodiscovering components bean example using InOut MEP how BeanComponent is resolved camel-core module creating a custom component CXF code-first development configuring using endpoint bean configuring using URI options contract-first development cxf-codegen-plugin in Maven dataFormat option dataformats document literal exposing a route as a web service, 2nd HTTP-based components invoking a web service Maven dependencies modes of development operationName header portName option producer and consumer terminology in web services Service Endpoint Interface serviceClass option serviceName option specifying operation to invoke transports using a WSDL using Apache Tomcat for HTTP inbound endpoints wsdl2java tool wsdl2service tool wsdl2xml tool wsdlURL option dataset Direct, 2^nd how a consumer calls a producer File default filename delay option delete option exclude option fileName option include option locking files maxMessagesPerPoll option move option noop option, 2nd reading and writing files recursive option simple expression for filename writing files example File and FTP Components FTP binary option CamelFileName header consuming files default FTP port disconnect option example using embedded FTP server Maven dependency, 2nd, 3rd maximumReconnect-Attempts option password password option reconnectDelay option remote directory transitive dependencies URI options username username option using embedded FTP server for testing Hibernate HTTP, 2^nd JBI JBoss JDBC example Maven dependency readSize option statement option URI options useJDBC4ColumnName AndLabelSemantics option using a bean to create the SQL statement Jetty JMS, 2^nd, 3^rd ActiveMQConnection-Factory autoStartup options clientId options concurrentConsumers options configure JMS provider connecting to ActiveMQ connecting to ActiveMQ: over TCP disableReplyTo options durableSubscriptionName options endpoint URI exchangePattern option how headers are handled how to empty a JMS queue JMSCorrelationID header JMSReplyTo header mapJmsMessage option Maven dependency, 2nd maxConcurrentConsumers options message mappings replyTo option, 2nd request/reply messaging requestTimeout options selector options sending and receiving messages sending messages with the ProducerTemplate TCP as transport timeToLive option transacted options URI options using a topic using multiple JMS providers valid JMS headers JPA connecting Camel JPA to OpenJPA consumeDelete option consumeLockEntity option consumer.delay option consumer.initialDelay option consumer.namedQuery option consumer.nativeQuery option consumer.query option @Entity example flushOnSend option manually querying the database Maven dependencies maximumResults option maxMessagesPerPoll option persistenceUnit option persistenceUnitName transactionManager option URI options LGPL/GPL components manually adding to the CamelContext message headers set MINA codec option CumulativeProtocol-Decoder custom codecs, 2nd encoding option example filters option Maven dependency object serialization codec setting up a TCP server sync option textline codec textline option textlineDelimiter option timeout option transferExchange option transport types URI options mock naming a component in Spring no component found error number of components overview Quartz cron option cron triggers job.name option job.propertyName option JobDetail Maven dependency SimpleTrigger Trigger trigger.propertyName option trigger.repeatCount option trigger.repeatInterval option URI options ref SEDA, 2^nd, 3^rd concurrentConsumers option multipleConsumers option pros and cons publish-subscribe size option timeout option URI options waitForTaskToComplete option Servlet, 2^nd SQL stream timer VM, 2^nd Composed Message Processor EIP concurrency akka asynchronous task CPU-bound eip aggregate multicast, 2nd recipient list split threads using wiretap, 2nd, 3rd Future IO-bound ordering parallel processing parallelProcessing performance improving splitter, parallelProcessing transaction limitation concurrency client API asynchronous task Callable ExecutorService Future, 2^nd future get get with timeout isDone in Camel in Java ProducerTemplate asyncCallback asyncCallbackRequestBody asyncCallbackSendBody asynchronous methods provided asyncRequestBody asyncSend asyncSendBody Runnable Synchronization SynchronizationAdapter timeout, 2^nd ConnectionFactory @Consume consumer, 2^nd event-driven consumer polling consumer ScheduledPollConsumer Consumers ConsumerTemplate, list of methods receiveBodyNoWait Content Enricher EIP enrich, 2^nd pollEnrich, 2^nd Content-Based Router EIP, 2^nd, 3^rd <context:property-placeholder> tag contextConfigLocation convention over configuration correlation id, 2^nd <correlationExpression> tag cron expressions CSV, 2^nd table of data types used transforming using bean transforming using Processor custom component changing endpoint URI scheme Component and Endpoint classes data marshaling disabling producer or consumer creating extending from default implementations how endpoint URI properties work Producers and Consumers what makes up a component CXFServlet

D

data format configuring CSV camel-csv configure consume CSV files DataFormat API JSON camel-jackson camel-xstream marshal, 2^nd, 3^rd table of data formats unmarshal, 2^nd, 3^rd using JAXB using XStream writing custom ReverseDataFormat using Camel type converters data format transformation data integration and data mapping data mapping, definition data transformation enrich in routes message transformation in component adapter using bean using components using data formats, 2^nd using Freemarker using Processor using templating using the Content Enricher EIP using the Message Translator EIP using transform() from Java from Spring XML using Velocity using XStream XSL Transformations (XSLT) data type transformation using type converter database HSQLDB SQL databases Dead Letter Channel EIP, 2^nd, 3^rd decouple middleware from business logic DefaultComponent DefaultConsumer DefaultEndpoint DefaultProducer Delayer EIP dependencies deploying Camel in a Java application file copy example pros and cons using Main helper class to load Spring context using raw Spring in a web application in Apache Tomcat in Jetty overriding CamelContext filename pros and cons using Spring context listener in Apache Karaf in JBoss Application Server pros and cons in OSGi installing a bundle pros and cons standalone deployment strategy Apache Tomcat pros and cons Java application pros and cons Java EE Application Server JBoss Application Server pros and cons Jetty OSGi pros and cons standalone pros and cons web application pros and cons developing Camel projects Direct component, 2^nd distribution, obtaining doc directory doCatch doFinally domain-specific language (DSL), 2^nd, 3^rd doTry DSL which DSL to use? Dynamic Router EIP, 2^nd @DynamicRouter

E

EAI Eclipse, 2^nd, 3^rd configuring local Maven repository import wizard M2_REPO variable m2eclipse plugin Maven Eclipse plugin package explorer using Camel Eclipse Equinox EIP Aggregator command message Composed Message Processor, 2^nd concurrent consumers, 2^nd content enricher Content-Based Router, 2^nd content-based router (CBR) example routing after a CBR Dead Letter Channel, 2^nd, 3^rd, 4^th, 5^th Delayer Dynamic Router, 2^nd, 3^rd @DynamicRouter Load Balancer, 2^nd log message filter Message Translator multicast configuring the thread pool implement with a JMS topic parallel multicast parallelProcessing stopping on exception multicast, aggregate reply patterns supporting concurrency Recipient List recipient list comma-separated recipients example RecipientList annotation Routing Slip, 2^nd @RoutingSlip Service Activator EIP, 2^nd Splitter, 2^nd, 3^rd, 4^th big file configuring thread pool file example low memory usage ordering parallelProcessing streaming mode thread pool threads Throttler Transactional Client wiretap, 2^nd concurrency @EL EL embedded FTP server endpoint, 2^nd BrowsableEndpoint @EndpointInject file, 2^nd FTP HTTP, 2^nd mock, 2^nd SEDA, 2^nd TCP, 2^nd URI, 2^nd, 3^rd, 4^th URL <endpoint> tag Endpoint URI context path, 2^nd how options work options, 2^nd scheme, 2^nd @EndpointInject enrich Enrich vs. pollEnrich enterprise integration patterns (EIPs) implemented as Processor Enterprise Service Bus (ESB) Camel is not an ESB @Entity entity manager error handler HandleFault Load Balancer EIP failover TransactionErrorHandler error handlers DeadLetterChannel, 2^nd DefaultErrorHandler, 2^nd features LoggingErrorHandler, 2^nd NoErrorHandler, 2^nd scope TransactionErrorHandler, 2^nd error handling caught exception context scoped, 2^nd continued dead letter channel dead letter endpoint dead letter queue useOriginalMessage using original message dead letter queue default error handler default settings detour detour message doTry...doCatch...doFinally error handlers provided errorHandler, 2^nd errorHandlerRef exception caused exception context scope continued custom exception handling detour message exception hierarchy gap detection handle handled maximumRedeliveries multiple exception onException, 2nd onWhen redeliverDelay understanding catching understanding handle understanding redelivery using exception policies using processor failover failure endpoint fault getException handle fault ignoring exception lifecycle logging error handler no error handler onException, 2^nd, 3^rd original input message PollingConsumerPollStrategy redeliver redelivery asynchronous, 2nd backOffMultiplier custom processing exhausted, 2nd exponential backoff file rollback maximumRedeliveries onRedeliver recoverable errors redeliverDelay redelivered redelivery counter redelivery policy, 2nd redeliveryDelay redeliveryPolicy retryAttemptedLogLevel retryWhile synchronous table of redelivery options useExponentialBackOff using RedeliveryErrorHandler, 2^nd route scoped scope, 2^nd, 3^rd setException, 2^nd setFault table of error handlers transaction error handler try catch understanding irrecoverable recoverable redelivery where error handling applies <errorHandler> tag, 2^nd errors, recoverable and irrecoverable, 2^nd event EventNotifier EventObject filtering event notification using custom EventNotifier examples directory exception policies <exception> tag ExceptionHandler exchange exchange ID in message instance, working on via Processor MEP out message properties exchange id Exchange.CAUSED_EXCEPTION expression compound custom evaluate ExpressionAdapter fluent builder, syntax sugar Message Translator EIP transform method call, 2^nd, 3^rd, 4^th syntax sugar using custom expression in Java DSL with Spring XML using scripting language as expression builder methods expression language dependency evaluate expression Simple, 2^nd external DSL

F

failed to resolve endpoint failover Load Balancer EIP strategy custom priority based round robin <failover> tag File component file endpoint, 2^nd file transfer files filesystem filter flow of messages in route fluent interface <from> tag FTP, 2^nd FTPComponent, 2^nd, 3^rd FTPEndpoint, 2^nd FTPS

G

generate an Eclipse project GenericFile graceful shutdown example @Groovy Groovy, 2^nd

H

HandleFault @Handler HawtDB persistence aggregator setup transaction HawtDB component, 2^nd @Header, 2^nd @Headers hello world Hibernate hiding middleware, 2^nd high availability Hohpe, Gregor HTTP, 2^nd, 3^rd HttpOperationFailed-Exception ping service HTTP endpoint, 2^nd HyperSQL

I

IDEs importing Camel project into Eclipse importing generated Eclipse project in-flight messages in-flight registry in-memory messaging @InOnly InOnly MEP, 2^nd @InOut InOut MEP, 2^nd, 3^rd inspecting messages integration testing interceptors, 2^nd adding an interceptor to the CamelContext addInterceptStrategy method applying more than one interceptor delay example excluding a Processor from interception how interceptors modify a route intercept intercept multiple endpoints InterceptFromEndpoint InterceptStrategy interface wrapping Processors in interceptors wrapProcessorInInterceptors method InterceptStrategy internal DSL Inversion of Control (IoC)

J

Jasypt component Java Java API for XML Web Services. See JAX-WS. Java DSL, 2^nd Java EE container Java Management Extensions. See JMX. Java Message Service. See JMS. Java Persistence Architecture. See JPA. Java Transaction API (JTA) Java Web Start java.util.Timer @JavaScript JavaScript javax.jms.Message javax.jws.WebService javax.persistence.Entity javax.sql.DataSource JAX-WS, 2^nd jaxb annotated bean contextPath jaxb.index using annotations @XmlAccessorType @XmlAttribute @XmlRootElement JBI JBoss Application Server starting JConsole, 2^nd, 3^rd, 4^th, 5^th, 6^th JDBC, 2^nd jdbc, data source JdbcTemplate Jetty continuations deploying Camel in JMS, 2^nd acknowledge mode, auto ActiveMQ, embedded broker browse queue BytesMessage consumer dead letter queue, 2^nd how to empty a JMS queue JMS message implementations MapMessage ObjectMessage StreamMessage TextMessage transaction JMS component, 2^nd JMS destination JmsTemplate JMX, 2^nd DefaultManagementAgent exposed Camel MBeans JMX connector jmxAgent @ManagedResource ManagementAgent ManagementAware managing Camel application managing lifecycle managing Tracer MBean Spring JMX using JConsole remotely using JMX with Camel JNDI JndiRegistry lookup in WebSphere JndiRegistry, 2^nd, 3^rd JPA, 2^nd JpaTransactionManager jsch json JSON marshaling beans selecting json library JUnit extensions JXPath

..................Content has been hidden....................

You can't read the all page of ebook, please click here login for view all page.