You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2014/08/20 09:01:23 UTC
git commit: CAMEL-7723 Fixed the CS errors of camel-sjms
Repository: camel
Updated Branches:
refs/heads/master 11b328236 -> c88548c22
CAMEL-7723 Fixed the CS errors of camel-sjms
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c88548c2
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c88548c2
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c88548c2
Branch: refs/heads/master
Commit: c88548c220f34fb18d893213ae9a1ebb4f38445d
Parents: 11b3282
Author: Willem Jiang <wi...@gmail.com>
Authored: Wed Aug 20 15:01:11 2014 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Wed Aug 20 15:01:11 2014 +0800
----------------------------------------------------------------------
.../java/org/apache/camel/component/sjms/SjmsConsumer.java | 6 +++---
.../java/org/apache/camel/component/sjms/SjmsProducer.java | 4 ++--
.../camel/component/sjms/AsyncStartStopListenerTest.java | 4 ++--
3 files changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/c88548c2/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsConsumer.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsConsumer.java
index 3c4b82f..c6070d6 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsConsumer.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsConsumer.java
@@ -147,12 +147,12 @@ public class SjmsConsumer extends DefaultConsumer {
super.doStart();
this.executor = getEndpoint().getCamelContext().getExecutorServiceManager().newDefaultThreadPool(this, "SjmsConsumer");
consumers = new MessageConsumerPool();
- if(getEndpoint().isAsyncStartListener()){
+ if (getEndpoint().isAsyncStartListener()) {
getEndpoint().getComponent().getAsyncStartStopExecutorService().submit(new Runnable() {
@Override
public void run() {
try {
- consumers.fillPool();
+ consumers.fillPool();
} catch (Throwable e) {
log.warn("Error starting listener container on destination: " + getDestinationName() + ". This exception will be ignored.", e);
}
@@ -172,7 +172,7 @@ public class SjmsConsumer extends DefaultConsumer {
protected void doStop() throws Exception {
super.doStop();
if (consumers != null) {
- if(getEndpoint().isAsyncStopListener()){
+ if (getEndpoint().isAsyncStopListener()) {
getEndpoint().getComponent().getAsyncStartStopExecutorService().submit(new Runnable() {
@Override
public void run() {
http://git-wip-us.apache.org/repos/asf/camel/blob/c88548c2/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
index 64a5914..1a31818 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/SjmsProducer.java
@@ -135,7 +135,7 @@ public abstract class SjmsProducer extends DefaultAsyncProducer {
this.executor = getEndpoint().getCamelContext().getExecutorServiceManager().newDefaultThreadPool(this, "SjmsProducer");
if (getProducers() == null) {
setProducers(new MessageProducerPool());
- if(getEndpoint().isAsyncStartListener()){
+ if (getEndpoint().isAsyncStartListener()) {
getEndpoint().getComponent().getAsyncStartStopExecutorService().submit(new Runnable() {
@Override
public void run() {
@@ -161,7 +161,7 @@ public abstract class SjmsProducer extends DefaultAsyncProducer {
protected void doStop() throws Exception {
super.doStop();
if (getProducers() != null) {
- if(getEndpoint().isAsyncStopListener()){
+ if (getEndpoint().isAsyncStopListener()) {
getEndpoint().getComponent().getAsyncStartStopExecutorService().submit(new Runnable() {
@Override
public void run() {
http://git-wip-us.apache.org/repos/asf/camel/blob/c88548c2/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java
index b10698f..49a16ed 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/AsyncStartStopListenerTest.java
@@ -33,7 +33,7 @@ public class AsyncStartStopListenerTest extends JmsTestSupport {
@Test
public void testAsyncStartStopConsumer() throws Exception {
- sendBodyAndAssert("sjms:queue:foo.startstop");
+ sendBodyAndAssert("sjms:queue:foo.startstop");
}
@Test
@@ -54,7 +54,7 @@ public class AsyncStartStopListenerTest extends JmsTestSupport {
@Test
public void testAsyncStartStopProducer() throws Exception {
sendBodyAndAssert("sjms:queue:foo?asyncStopListener=true&asyncStartListener=true");
- }
+ }
private void sendBodyAndAssert(final String uri) throws InterruptedException {
String body1 = "Hello World";