You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2021/02/25 07:05:06 UTC
[camel] branch regen_bot updated (9dbd0f0 -> 22c7af5)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
in repository https://gitbox.apache.org/repos/asf/camel.git.
discard 9dbd0f0 Regen for commit 1f2c368b3809e227485691bd29899362dceb9bbd
add 22c7af5 CAMEL-16222: camel-core - ExchangeFactory SPI to allow to use exchange pooling (#5122)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (9dbd0f0)
\
N -- N -- N refs/heads/regen_bot (22c7af5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../src/main/java/__name__Consumer.java | 3 +-
camel-dependencies/pom.xml | 2 +-
.../main/camel-main-configuration-metadata.json | 5 +-
.../apache/camel/component/ahc/ws/WsConsumer.java | 2 +-
.../apache/camel/component/apns/ApnsConsumer.java | 2 +-
.../apache/camel/component/as2/AS2Consumer.java | 9 +-
.../camel/component/asterisk/AsteriskConsumer.java | 9 +-
.../consumer/AtmosScheduledPollConsumer.java | 4 -
.../consumer/AtmosScheduledPollGetConsumer.java | 14 +-
.../atmosphere/websocket/WebsocketConsumer.java | 6 +-
.../atomix/client/map/AtomixMapConsumer.java | 2 +-
.../client/messaging/AtomixMessagingConsumer.java | 2 +-
.../atomix/client/queue/AtomixQueueConsumer.java | 2 +-
.../atomix/client/set/AtomixSetConsumer.java | 2 +-
.../atomix/client/value/AtomixValueConsumer.java | 2 +-
.../camel/attachment/DefaultAttachmentMessage.java | 5 +
.../apache/camel/component/avro/AvroEndpoint.java | 14 -
.../apache/camel/component/avro/AvroListener.java | 16 +-
.../aws2/ddbstream/Ddb2StreamConsumer.java | 8 +-
.../aws2/ddbstream/Ddb2StreamEndpoint.java | 9 -
.../component/aws2/kinesis/Kinesis2Consumer.java | 13 +-
.../component/aws2/kinesis/Kinesis2Endpoint.java | 11 -
.../camel/component/aws2/s3/AWS2S3Consumer.java | 75 ++-
.../camel/component/aws2/s3/AWS2S3Endpoint.java | 72 ---
.../camel/component/aws2/sqs/Sqs2Consumer.java | 52 +-
.../camel/component/aws2/sqs/Sqs2Endpoint.java | 44 --
.../azure/eventhubs/EventHubsConsumer.java | 34 +-
.../azure/eventhubs/EventHubsEndpoint.java | 32 -
.../component/azure/storage/blob/BlobConsumer.java | 2 +-
.../azure/storage/datalake/DataLakeConsumer.java | 2 +-
.../azure/storage/queue/QueueConsumer.java | 13 +-
.../azure/storage/queue/QueueEndpoint.java | 13 -
.../component/beanstalk/BeanstalkConsumer.java | 3 +-
.../component/cassandra/CassandraConsumer.java | 7 +-
.../apache/camel/component/cmis/CMISConsumer.java | 2 +-
.../org/apache/camel/coap/CamelCoapResource.java | 3 +-
.../camel/component/cometd/CometdConsumer.java | 20 +-
.../camel/component/cometd/CometdConsumerTest.java | 12 +
.../consul/endpoint/ConsulEventConsumer.java | 44 +-
.../consul/endpoint/ConsulKeyValueConsumer.java | 35 +-
.../camel/component/corda/CordaConsumer.java | 14 +-
.../component/couchbase/CouchbaseConsumer.java | 55 +-
.../component/couchdb/CouchDbChangesetTracker.java | 7 +-
.../camel/component/couchdb/CouchDbConsumer.java | 19 +-
.../camel/component/couchdb/CouchDbEndpoint.java | 13 -
.../couchdb/CouchDbChangesetTrackerTest.java | 14 +-
.../component/couchdb/CouchDbEndpointTest.java | 27 -
.../camel/component/dataset/DataSetConsumer.java | 35 +-
.../camel/component/dataset/DataSetEndpoint.java | 4 +-
.../camel/component/debezium/DebeziumConsumer.java | 3 +-
.../camel/component/debezium/DebeziumEndpoint.java | 9 +-
.../component/debezium/DebeziumEndpointTest.java | 12 +-
.../component/disruptor/DisruptorConsumer.java | 11 +
.../docker/consumer/DockerEventsConsumer.java | 23 +-
.../docker/consumer/DockerStatsConsumer.java | 23 +-
.../consumer/DropboxScheduledPollConsumer.java | 4 -
.../consumer/DropboxScheduledPollGetConsumer.java | 45 +-
.../DropboxScheduledPollSearchConsumer.java | 33 +-
.../camel/component/ehcache/EhcacheConsumer.java | 4 +-
.../elsql/ElSqlConsumerDynamicParameterTest.java | 104 ----
.../camel/component/etcd/EtcdStatsConsumer.java | 2 +-
.../camel/component/etcd/EtcdWatchConsumer.java | 6 +-
.../camel/component/facebook/FacebookConsumer.java | 6 +-
.../component/file/watch/FileWatchConsumer.java | 2 +-
.../apache/camel/component/file/FileConsumer.java | 9 +
.../camel/component/file/GenericFileConsumer.java | 8 +-
.../camel/component/flatpack/FlatpackEndpoint.java | 4 +-
.../component/file/remote/RemoteFileConsumer.java | 9 +
.../remote/RemoteFileIgnoreDoPollErrorTest.java | 8 +
.../component/git/consumer/GitBranchConsumer.java | 2 +-
.../component/git/consumer/GitCommitConsumer.java | 2 +-
.../component/git/consumer/GitTagConsumer.java | 2 +-
.../component/github/consumer/CommitConsumer.java | 2 +-
.../component/github/consumer/EventsConsumer.java | 2 +-
.../consumer/PullRequestCommentConsumer.java | 2 +-
.../github/consumer/PullRequestConsumer.java | 2 +-
.../component/github/consumer/TagConsumer.java | 2 +-
.../mail/stream/GoogleMailStreamConsumer.java | 43 +-
.../mail/stream/GoogleMailStreamEndpoint.java | 42 --
.../google/pubsub/GooglePubsubConsumer.java | 8 +-
.../pubsub/consumer/CamelMessageReceiver.java | 9 +-
.../sheets/stream/GoogleSheetsStreamConsumer.java | 48 +-
.../sheets/stream/GoogleSheetsStreamEndpoint.java | 37 --
.../google/storage/GoogleCloudStorageConsumer.java | 64 +-
.../google/storage/GoogleCloudStorageEndpoint.java | 59 --
.../apache/camel/component/gora/GoraConsumer.java | 10 +-
.../camel/component/gora/GoraConsumerTest.java | 88 ---
.../guava/eventbus/CamelEventHandler.java | 18 +-
.../guava/eventbus/FilteringCamelEventHandler.java | 5 +-
.../guava/eventbus/GuavaEventBusConsumer.java | 8 +-
.../guava/eventbus/GuavaEventBusEndpoint.java | 7 -
.../instance/HazelcastInstanceConsumer.java | 4 +-
.../hazelcast/list/HazelcastListConsumer.java | 6 -
.../hazelcast/listener/CamelListener.java | 4 +-
.../hazelcast/map/HazelcastMapConsumer.java | 6 -
.../multimap/HazelcastMultimapConsumer.java | 6 -
.../hazelcast/queue/HazelcastQueueConsumer.java | 4 +-
.../HazelcastReplicatedmapConsumer.java | 6 -
.../hazelcast/seda/HazelcastSedaConsumer.java | 32 +-
.../hazelcast/set/HazelcastSetConsumer.java | 6 -
.../hazelcast/topic/HazelcastTopicConsumer.java | 6 -
.../camel/component/hbase/HBaseConsumer.java | 5 +-
.../apache/camel/component/hdfs/HdfsConsumer.java | 44 +-
.../org/apache/camel/http/common/CamelServlet.java | 4 +-
.../apache/camel/component/http/HttpProducer.java | 15 +-
.../apache/camel/component/iec60870/Constants.java | 5 +
.../component/iec60870/client/ClientConsumer.java | 30 +-
.../ignite/events/IgniteEventsConsumer.java | 3 +-
.../ignite/messaging/IgniteMessagingConsumer.java | 11 +-
.../component/infinispan/InfinispanConsumer.java | 28 +-
.../apache/camel/component/irc/IrcConsumer.java | 90 ++-
.../apache/camel/component/irc/IrcEndpoint.java | 77 +--
.../camel/component/irc/IrcConsumerTest.java | 12 +
.../camel/component/ironmq/IronMQConsumer.java | 19 +-
.../camel/component/ironmq/IronMQEndpoint.java | 21 -
.../apache/camel/component/jbpm/JBPMConsumer.java | 7 +-
.../jbpm/server/CamelKieServerExtensionTest.java | 45 --
.../camel/component/jcache/JCacheConsumer.java | 7 +-
.../jclouds/JcloudsBlobStoreConsumer.java | 2 +-
.../camel/component/jclouds/JcloudsConsumer.java | 46 --
.../camel/component/jcr/EndpointEventListener.java | 12 +-
.../apache/camel/component/jcr/JcrConsumer.java | 2 +-
.../component/jetty/CamelContinuationServlet.java | 4 +-
.../jgroups/raft/CamelRoleChangeListener.java | 17 +-
.../jgroups/raft/JGroupsRaftConsumer.java | 2 +-
.../jgroups/raft/JGroupsRaftEndpoint.java | 7 -
.../component/jgroups/CamelJGroupsReceiver.java | 19 +-
.../camel/component/jgroups/JGroupsConsumer.java | 2 +-
.../jgroups/CamelJGroupsReceiverTest.java | 58 --
.../apache/camel/component/jira/JiraConstants.java | 2 +
.../jira/consumer/NewCommentsConsumer.java | 2 +-
.../component/jira/consumer/NewIssuesConsumer.java | 2 +-
.../jira/consumer/WatchUpdatesConsumer.java | 9 +-
.../jira/consumer/WatchUpdatesConsumerTest.java | 5 +-
.../component/jms/EndpointMessageListener.java | 28 +-
.../apache/camel/component/jms/JmsConsumer.java | 2 +-
.../org/apache/camel/component/jms/JmsMessage.java | 8 +
.../jms/JmsInOnlyPooledExchangeTest.java} | 42 +-
.../apache/camel/component/jmx/JMXConsumer.java | 4 +-
.../apache/camel/component/jooq/JooqConsumer.java | 2 +-
.../apache/camel/component/jpa/JpaConsumer.java | 25 +-
.../component/jt400/Jt400DataQueueConsumer.java | 2 +-
.../component/jt400/Jt400MsgQueueConsumer.java | 2 +-
.../camel/component/kafka/KafkaConsumer.java | 36 +-
.../camel/component/kafka/KafkaEndpoint.java | 21 -
.../camel/component/kafka/KafkaConsumerTest.java | 12 +
.../camel/component/kafka/KafkaEndpointTest.java | 75 ---
.../config_maps/KubernetesConfigMapsConsumer.java | 4 +-
.../KubernetesCustomResourcesConsumer.java | 4 +-
.../deployments/KubernetesDeploymentsConsumer.java | 4 +-
.../kubernetes/hpa/KubernetesHPAConsumer.java | 4 +-
.../namespaces/KubernetesNamespacesConsumer.java | 4 +-
.../kubernetes/nodes/KubernetesNodesConsumer.java | 4 +-
.../kubernetes/pods/KubernetesPodsConsumer.java | 4 +-
.../KubernetesReplicationControllersConsumer.java | 5 +-
.../services/KubernetesServicesConsumer.java | 5 +-
.../apache/camel/component/mail/MailConsumer.java | 11 +-
.../mail/MailConsumerAuthenticatorTest.java | 9 +
.../component/master/EndpointUriEncodingTest.java | 2 +-
.../component/milo/client/MiloClientConsumer.java | 5 +-
.../component/milo/server/MiloServerConsumer.java | 4 +-
.../apache/camel/component/mina/MinaConsumer.java | 99 +--
.../apache/camel/component/mina/MinaEndpoint.java | 11 -
.../mina/MinaTransferExchangeOptionTest.java | 1 -
.../camel/component/minio/MinioConsumer.java | 36 +-
.../camel/component/minio/MinioEndpoint.java | 40 +-
.../apache/camel/component/mllp/MllpEndpoint.java | 2 +-
.../component/mllp/MllpTcpServerConsumer.java | 8 +-
.../apache/camel/component/mock/MockEndpoint.java | 52 +-
.../component/mongodb/gridfs/GridFsConsumer.java | 2 +-
.../mongodb/MongoDbChangeStreamsConsumer.java | 1 +
.../mongodb/MongoDbChangeStreamsThread.java | 14 +-
.../camel/component/mongodb/MongoDbEndpoint.java | 12 -
.../component/mongodb/MongoDbTailingThread.java | 14 +-
.../camel/component/mybatis/MyBatisConsumer.java | 21 +-
.../mybatis/MyBatisConsumerIsolatedTest.java | 53 --
.../apache/camel/component/nats/NatsConsumer.java | 40 +-
.../component/netty/http/NettyHttpEndpoint.java | 32 -
.../component/netty/http/NettyHttpMessage.java | 19 +-
.../http/handlers/HttpServerChannelHandler.java | 30 +
.../http/NettyHttpSimplePooledExchangeTest.java | 72 +++
.../netty/DefaultServerInitializerFactory.java | 1 -
.../camel/component/netty/NettyEndpoint.java | 10 +-
.../netty/handlers/ServerChannelHandler.java | 11 +-
.../NettyTextlineInOnlyPooledExchangeTest.java | 63 ++
.../camel/component/nitrite/NitriteConsumer.java | 3 +-
.../apache/camel/component/nsq/NsqConsumer.java | 13 +-
.../camel/oaipmh/handler/AbstractHandler.java | 9 +-
.../org/apache/camel/oaipmh/handler/Harvester.java | 14 +-
.../component/optaplanner/OptaPlannerConsumer.java | 8 +-
.../component/paho/mqtt5/PahoMqtt5Consumer.java | 14 +-
.../component/paho/mqtt5/PahoMqtt5Endpoint.java | 13 -
.../apache/camel/component/paho/PahoConsumer.java | 14 +-
.../apache/camel/component/paho/PahoEndpoint.java | 14 -
.../slot/PgReplicationSlotConsumer.java | 2 +-
.../camel/component/pgevent/PgEventConsumer.java | 10 +-
.../apache/camel/pgevent/PgEventConsumerTest.java | 30 +-
.../http/vertx/VertxPlatformHttpConsumer.java | 20 +-
.../camel/component/pubnub/PubNubConsumer.java | 9 +-
.../component/pulsar/PulsarMessageListener.java | 42 +-
.../component/quickfixj/QuickfixjEndpoint.java | 13 +-
.../quickfixj/converter/QuickfixjConverters.java | 23 +
.../component/quickfixj/QuickfixjConsumerTest.java | 147 -----
.../camel/component/rabbitmq/RabbitConsumer.java | 11 +-
.../camel/component/rabbitmq/RabbitMQConsumer.java | 10 +
.../component/rabbitmq/RabbitMQConsumerTest.java | 42 +-
.../reactive/streams/ReactiveStreamsConsumer.java | 4 +-
.../component/salesforce/SalesforceConsumer.java | 3 +-
.../salesforce/SalesforceConsumerTest.java | 15 +-
.../component/scheduler/SchedulerConsumer.java | 29 +-
.../sip/listener/SipSubscriptionListener.java | 8 +-
.../apache/camel/component/sjms/SjmsEndpoint.java | 8 +-
.../apache/camel/component/sjms/SjmsMessage.java | 8 +
.../sjms/consumer/EndpointMessageListener.java | 29 +-
.../sjms/consumer/InOnlyConsumerQueueTest.java | 11 +
...ueueTest.java => InOnlyPooledExchangeTest.java} | 23 +-
.../camel/component/slack/SlackConsumer.java | 22 +-
.../camel/component/slack/SlackEndpoint.java | 26 -
.../smpp/MessageReceiverListenerImpl.java | 24 +-
.../apache/camel/component/smpp/SmppConsumer.java | 3 +-
.../apache/camel/component/smpp/SmppEndpoint.java | 28 -
.../smpp/MessageReceiverListenerImplTest.java | 117 ----
.../camel/component/smpp/SmppConsumerTest.java | 12 +
.../apache/camel/component/snmp/SnmpEndpoint.java | 14 -
.../camel/component/snmp/SnmpTrapConsumer.java | 17 +-
.../component/SoroushBotAbstractConsumer.java | 38 +-
.../component/SoroushBotMultiThreadConsumer.java | 1 +
.../component/SoroushBotSingleThreadConsumer.java | 1 +
.../camel/component/splunk/SplunkConsumer.java | 28 +-
.../integration/SpringIntegrationConsumer.java | 17 +-
.../integration/SpringIntegrationMessage.java | 6 +
.../springrabbit/EndpointMessageListener.java | 33 +-
...MQConsumer.java => SpringRabbitMQConsumer.java} | 8 +-
.../springrabbit/SpringRabbitMQEndpoint.java | 2 +-
.../RabbitMQConsumerPooledExchangeIntTest.java | 70 +++
.../camel/component/redis/RedisConsumer.java | 8 +-
.../spring/ws/SpringWebserviceConsumer.java | 75 ++-
.../spring/ws/SpringWebserviceMessage.java | 6 +
.../camel/component/cron/SpringCronConsumer.java | 2 +-
.../apache/camel/component/sql/SqlConsumer.java | 9 +-
.../apache/camel/component/ssh/SshConsumer.java | 26 +-
.../camel/component/stomp/StompEndpoint.java | 10 +-
.../camel/component/stream/StreamConsumer.java | 12 +-
.../camel/component/stream/StreamEndpoint.java | 9 -
.../camel/component/telegram/TelegramConsumer.java | 11 +-
.../camel/component/telegram/TelegramEndpoint.java | 10 -
.../thrift/server/ThriftMethodHandler.java | 18 +-
.../camel/component/timer/TimerConsumer.java | 19 +-
.../camel/component/undertow/UndertowConsumer.java | 33 +-
.../camel/component/undertow/UndertowEndpoint.java | 20 -
.../component/vertx/kafka/VertxKafkaConsumer.java | 21 +-
.../component/vertx/kafka/VertxKafkaEndpoint.java | 21 -
.../vertx/websocket/VertxWebsocketConsumer.java | 5 +-
.../camel/component/vertx/VertxConsumer.java | 5 +-
.../camel/websocket/jsr356/JSR356Consumer.java | 2 +-
.../component/websocket/WebsocketConsumer.java | 2 +-
.../component/websocket/WebsocketConsumerTest.java | 23 +-
.../consumer/AbstractWordpressConsumer.java | 17 +-
.../apache/camel/component/xmpp/XmppConsumer.java | 23 +-
.../apache/camel/component/xmpp/XmppEndpoint.java | 9 -
.../yammer/YammerMessagePollingConsumer.java | 3 +-
.../yammer/YammerUserPollingConsumer.java | 3 +-
.../component/zookeeper/ZooKeeperConsumer.java | 2 +-
.../src/main/java/org/apache/camel/Consumer.java | 24 +
.../src/main/java/org/apache/camel/Endpoint.java | 15 +-
.../org/apache/camel/ExtendedCamelContext.java | 22 +
.../java/org/apache/camel/ExtendedExchange.java | 8 +
.../src/main/java/org/apache/camel/Message.java | 7 +
.../src/main/java/org/apache/camel/Ordered.java | 2 +-
.../main/java/org/apache/camel/PooledExchange.java | 71 +++
.../java/org/apache/camel/spi/ExchangeFactory.java | 167 +++++
.../apache/camel/spi/ExchangeFactoryManager.java | 88 +++
.../main/java/org/apache/camel/spi/UnitOfWork.java | 18 +-
.../camel/impl/engine/AbstractCamelContext.java | 47 ++
.../camel/impl/engine/CamelInternalProcessor.java | 20 +-
.../camel/impl/engine/DefaultExchangeFactory.java | 239 ++++++++
.../impl/engine/DefaultExchangeFactoryManager.java | 181 ++++++
.../camel/impl/engine/DefaultUnitOfWork.java | 70 ++-
.../apache/camel/impl/engine/MDCUnitOfWork.java | 13 +-
.../camel/impl/engine/PooledExchangeFactory.java | 188 ++++++
.../camel/impl/engine/SimpleCamelContext.java | 18 +
.../camel/impl/ExtendedCamelContextConfigurer.java | 12 +
.../camel/impl/lw/LightweightCamelContext.java | 22 +
.../impl/lw/LightweightRuntimeCamelContext.java | 26 +
.../apache/camel/model/RoutingSlipDefinition.java | 6 +-
.../component/dataset/DataSetTestEndpointTest.java | 12 +-
.../camel/component/mock/MockAsBeanTest.java | 12 +-
.../apache/camel/processor/PooledExchangeTest.java | 85 +++
.../RecipientListWithSimpleExpressionTest.java | 2 +
.../MainConfigurationPropertiesConfigurer.java | 18 +
.../camel-main-configuration-metadata.json | 5 +-
core/camel-main/src/main/docs/main.adoc | 5 +-
.../camel/main/DefaultConfigurationConfigurer.java | 27 +-
.../camel/main/DefaultConfigurationProperties.java | 75 ++-
.../api/management/mbean/CamelOpenMBeanTypes.java | 15 +
.../mbean/ManagedExchangeFactoryManagerMBean.java | 62 ++
.../management/JmxManagementLifecycleStrategy.java | 4 +
.../mbean/ManagedExchangeFactoryManager.java | 146 +++++
.../management/ManagedNonManagedServiceTest.java | 2 +-
.../management/ManagedPooledExchangeTest.java | 132 ++++
...edProducerRouteAddRemoveRegisterAlwaysTest.java | 2 +-
.../management/ManagedRouteAddRemoveTest.java | 2 +-
.../src/test/resources/log4j2.properties | 2 +-
...{DefaultExchange.java => AbstractExchange.java} | 102 +--
.../org/apache/camel/support/DefaultConsumer.java | 49 +-
.../org/apache/camel/support/DefaultEndpoint.java | 15 +-
.../org/apache/camel/support/DefaultExchange.java | 681 +--------------------
.../support/DefaultInterceptSendToEndpoint.java | 5 +
.../org/apache/camel/support/DefaultMessage.java | 8 +
.../camel/support/DefaultPooledExchange.java | 168 +++++
.../org/apache/camel/support/MessageSupport.java | 7 +
.../camel/support/PollingConsumerSupport.java | 11 +
.../org/apache/camel/support/UnitOfWorkHelper.java | 12 +-
.../camel/support/component/ApiConsumerHelper.java | 8 +-
docs/components/modules/others/pages/main.adoc | 5 +-
.../ROOT/pages/camel-3x-upgrade-guide-3_9.adoc | 17 +
parent/pom.xml | 2 +-
317 files changed, 4435 insertions(+), 3245 deletions(-)
delete mode 100644 components/camel-elsql/src/test/java/org/apache/camel/component/elsql/ElSqlConsumerDynamicParameterTest.java
delete mode 100644 components/camel-gora/src/test/java/org/apache/camel/component/gora/GoraConsumerTest.java
delete mode 100644 components/camel-jclouds/src/main/java/org/apache/camel/component/jclouds/JcloudsConsumer.java
delete mode 100644 components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/CamelJGroupsReceiverTest.java
copy components/{camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyConsumerQueueTest.java => camel-jms/src/test/java/org/apache/camel/component/jms/JmsInOnlyPooledExchangeTest.java} (51%)
delete mode 100644 components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaEndpointTest.java
delete mode 100644 components/camel-mybatis/src/test/java/org/apache/camel/component/mybatis/MyBatisConsumerIsolatedTest.java
create mode 100644 components/camel-netty-http/src/test/java/org/apache/camel/component/netty/http/NettyHttpSimplePooledExchangeTest.java
create mode 100644 components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyTextlineInOnlyPooledExchangeTest.java
delete mode 100644 components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjConsumerTest.java
copy components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/{InOnlyConsumerQueueTest.java => InOnlyPooledExchangeTest.java} (69%)
delete mode 100644 components/camel-smpp/src/test/java/org/apache/camel/component/smpp/MessageReceiverListenerImplTest.java
rename components/camel-spring-rabbitmq/src/main/java/org/apache/camel/component/springrabbit/{RabbitMQConsumer.java => SpringRabbitMQConsumer.java} (94%)
create mode 100644 components/camel-spring-rabbitmq/src/test/java/org/apache/camel/component/springrabbit/integration/RabbitMQConsumerPooledExchangeIntTest.java
create mode 100644 core/camel-api/src/main/java/org/apache/camel/PooledExchange.java
create mode 100644 core/camel-api/src/main/java/org/apache/camel/spi/ExchangeFactory.java
create mode 100644 core/camel-api/src/main/java/org/apache/camel/spi/ExchangeFactoryManager.java
create mode 100644 core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultExchangeFactory.java
create mode 100644 core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultExchangeFactoryManager.java
create mode 100644 core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/PooledExchangeFactory.java
create mode 100644 core/camel-core/src/test/java/org/apache/camel/processor/PooledExchangeTest.java
create mode 100644 core/camel-management-api/src/main/java/org/apache/camel/api/management/mbean/ManagedExchangeFactoryManagerMBean.java
create mode 100644 core/camel-management/src/main/java/org/apache/camel/management/mbean/ManagedExchangeFactoryManager.java
create mode 100644 core/camel-management/src/test/java/org/apache/camel/management/ManagedPooledExchangeTest.java
copy core/camel-support/src/main/java/org/apache/camel/support/{DefaultExchange.java => AbstractExchange.java} (92%)
create mode 100644 core/camel-support/src/main/java/org/apache/camel/support/DefaultPooledExchange.java