camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Andrea Cosentino (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CAMEL-7501) Only one ZooKeeperRoutePolicy possible
Date Sat, 02 May 2015 12:11:06 GMT

    [ https://issues.apache.org/jira/browse/CAMEL-7501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14525229#comment-14525229
] 

Andrea Cosentino commented on CAMEL-7501:
-----------------------------------------

You're right, Nathan. Good catch! :-)

Test with the substring:

{code}
2015-05-02 13:58:23,478 [main           ] INFO  AvailablePortFinder            - getNextAvailable(39913)
-> 39913
2015-05-02 13:58:23,478 [main           ] INFO  ZooKeeperTestSupport           - Starting
Zookeeper Test Infrastructure
2015-05-02 13:58:23,606 [ain-EventThread] INFO  estSupport$TestZookeeperClient - TestClient
connected
2015-05-02 13:58:23,606 [main           ] INFO  ZooKeeperTestSupport           - Started Zookeeper
Test Infrastructure on port 39913
2015-05-02 13:58:23,608 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - ********************************************************************************
2015-05-02 13:58:23,608 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - Testing:
routeDoublePoliciesAndTwoRoutes(org.apache.camel.component.zookeeper.policy.ZookeeperDoubleRoutePolicyTest)
2015-05-02 13:58:23,608 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - ********************************************************************************
2015-05-02 13:58:23,806 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) is starting
2015-05-02 13:58:23,807 [main           ] INFO  DefaultManagementStrategy      - JMX is disabled
2015-05-02 13:58:23,863 [main           ] INFO  DefaultTypeConverter           - Loaded 183
type converters
2015-05-02 13:58:23,864 [main           ] INFO  DefaultCamelContext            - AllowUseOriginalMessage
is enabled. If access to the original message is not needed, then its recommended to turn
this option off as it may improve performance.
2015-05-02 13:58:23,864 [main           ] INFO  DefaultCamelContext            - StreamCaching
is not in use. If using streams then its recommended to enable stream caching. See more details
at http://camel.apache.org/stream-caching.html
2015-05-02 13:58:23,864 [main           ] INFO  DefaultCamelContext            - Total 0 routes,
of which 0 is started.
2015-05-02 13:58:23,869 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) started in 0.058 seconds
2015-05-02 13:58:24,084 [main           ] INFO  estSupport$TestZookeeperClient - Created znode
named '/someapp'
2015-05-02 13:58:24,288 [main           ] INFO  estSupport$TestZookeeperClient - Created znode
named '/someapp/somepolicy'
2015-05-02 13:58:24,492 [main           ] INFO  estSupport$TestZookeeperClient - Created znode
named '/someapp/someotherpolicy'
2015-05-02 13:58:24,632 [main           ] INFO  DefaultCamelContext            - Route: route1
started and consuming from: Endpoint[direct://policy-controlled]
2015-05-02 13:58:24,635 [main           ] INFO  DefaultCamelContext            - Route: route2
started and consuming from: Endpoint[direct://policy-controlled-1]
2015-05-02 13:58:24,651 [main           ] INFO  ZooKeeperElection              - Initializing
ZookeeperElection with uri 'zookeeper:localhost:39913/someapp/somepolicy'
2015-05-02 13:58:24,669 [main           ] WARN  ZookeeperProducer              - Node '/someapp/somepolicy/ancosen-home-73fdb664-2361-4fbd-9c06-74958c140c5c'
did not exist, creating it.
2015-05-02 13:58:24,677 [main           ] INFO  ZooKeeperElection              - Candidate
node '/someapp/somepolicy/ancosen-home-73fdb664-2361-4fbd-9c06-74958c140c5c' has been created
2015-05-02 13:58:24,700 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-
started and consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
2015-05-02 13:58:24,707 [main           ] INFO  MockEndpoint                   - Asserting:
Endpoint[mock://controlled] is satisfied
2015-05-02 13:58:24,708 [main           ] INFO  ZooKeeperElection              - Initializing
ZookeeperElection with uri 'zookeeper:localhost:39913/someapp/someotherpolicy'
2015-05-02 13:58:24,714 [main           ] WARN  ZookeeperProducer              - Node '/someapp/someotherpolicy/ancosen-home-e61215bc-dc9e-4773-8040-8af82bea10e3'
did not exist, creating it.
2015-05-02 13:58:24,717 [main           ] INFO  ZooKeeperElection              - Candidate
node '/someapp/someotherpolicy/ancosen-home-e61215bc-dc9e-4773-8040-8af82bea10e3' has been
created
2015-05-02 13:58:24,718 [main           ] INFO  DefaultShutdownStrategy        - Starting
to graceful shutdown 1 routes (timeout 10 seconds)
2015-05-02 13:58:24,723 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: election-route-ancosen-
shutdown complete, was consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
2015-05-02 13:58:24,723 [main           ] INFO  DefaultShutdownStrategy        - Graceful
shutdown of 1 routes completed in 0 seconds
2015-05-02 13:58:24,724 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-
is stopped, was consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
2015-05-02 13:58:24,730 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-
is shutdown and removed, was consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
2015-05-02 13:58:24,734 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-
started and consuming from: Endpoint[zookeeper://localhost:39913/someapp/someotherpolicy]
2015-05-02 13:58:24,736 [main           ] INFO  MockEndpoint                   - Asserting:
Endpoint[mock://controlled-1] is satisfied
2015-05-02 13:58:24,736 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - ********************************************************************************
2015-05-02 13:58:24,736 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - Testing done:
routeDoublePoliciesAndTwoRoutes(org.apache.camel.component.zookeeper.policy.ZookeeperDoubleRoutePolicyTest)
2015-05-02 13:58:24,736 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - Took: 0.867
seconds (867 millis)
2015-05-02 13:58:24,736 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - ********************************************************************************
2015-05-02 13:58:24,737 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) is shutting down
2015-05-02 13:58:24,737 [main           ] INFO  DefaultShutdownStrategy        - Starting
to graceful shutdown 3 routes (timeout 10 seconds)
2015-05-02 13:58:24,738 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: election-route-ancosen-
shutdown complete, was consuming from: Endpoint[zookeeper://localhost:39913/someapp/someotherpolicy]
2015-05-02 13:58:24,738 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: route2
shutdown complete, was consuming from: Endpoint[direct://policy-controlled-1]
2015-05-02 13:58:24,738 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: route1
shutdown complete, was consuming from: Endpoint[direct://policy-controlled]
2015-05-02 13:58:24,738 [main           ] INFO  DefaultShutdownStrategy        - Graceful
shutdown of 3 routes completed in 0 seconds
2015-05-02 13:58:24,743 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) uptime 0.937 seconds
2015-05-02 13:58:24,743 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) is shutdown in 0.006 seconds
2015-05-02 13:58:24,744 [main           ] INFO  ZooKeeperTestSupport           - Stopping
Zookeeper Test Infrastructure
2015-05-02 13:58:24,747 [main           ] INFO  ZooKeeperTestSupport           - Stopped Zookeeper
Test Infrastructure
{code}

Only one election route started, shutdown of this route and start of the other election route
with the same id.

{code}
2015-05-02 13:58:24,700 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-
started and consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
.
.
.
2015-05-02 13:58:24,718 [main           ] INFO  DefaultShutdownStrategy        - Starting
to graceful shutdown 1 routes (timeout 10 seconds)
2015-05-02 13:58:24,723 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: election-route-ancosen-
shutdown complete, was consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
2015-05-02 13:58:24,723 [main           ] INFO  DefaultShutdownStrategy        - Graceful
shutdown of 1 routes completed in 0 seconds
2015-05-02 13:58:24,724 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-
is stopped, was consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]

2015-05-02 13:58:24,734 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-
started and consuming from: Endpoint[zookeeper://localhost:39913/someapp/someotherpolicy]
{code}

Test without substring:

{code}
2015-05-02 13:59:42,606 [main           ] INFO  AvailablePortFinder            - getNextAvailable(39913)
-> 39913
2015-05-02 13:59:42,607 [main           ] INFO  ZooKeeperTestSupport           - Starting
Zookeeper Test Infrastructure
2015-05-02 13:59:42,735 [ain-EventThread] INFO  estSupport$TestZookeeperClient - TestClient
connected
2015-05-02 13:59:42,735 [main           ] INFO  ZooKeeperTestSupport           - Started Zookeeper
Test Infrastructure on port 39913
2015-05-02 13:59:42,738 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - ********************************************************************************
2015-05-02 13:59:42,738 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - Testing:
routeDoublePoliciesAndTwoRoutes(org.apache.camel.component.zookeeper.policy.ZookeeperDoubleRoutePolicyTest)
2015-05-02 13:59:42,738 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - ********************************************************************************
2015-05-02 13:59:42,962 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) is starting
2015-05-02 13:59:42,962 [main           ] INFO  DefaultManagementStrategy      - JMX is disabled
2015-05-02 13:59:43,028 [main           ] INFO  DefaultTypeConverter           - Loaded 183
type converters
2015-05-02 13:59:43,029 [main           ] INFO  DefaultCamelContext            - AllowUseOriginalMessage
is enabled. If access to the original message is not needed, then its recommended to turn
this option off as it may improve performance.
2015-05-02 13:59:43,029 [main           ] INFO  DefaultCamelContext            - StreamCaching
is not in use. If using streams then its recommended to enable stream caching. See more details
at http://camel.apache.org/stream-caching.html
2015-05-02 13:59:43,030 [main           ] INFO  DefaultCamelContext            - Total 0 routes,
of which 0 is started.
2015-05-02 13:59:43,034 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) started in 0.069 seconds
2015-05-02 13:59:43,248 [main           ] INFO  estSupport$TestZookeeperClient - Created znode
named '/someapp'
2015-05-02 13:59:43,454 [main           ] INFO  estSupport$TestZookeeperClient - Created znode
named '/someapp/somepolicy'
2015-05-02 13:59:43,659 [main           ] INFO  estSupport$TestZookeeperClient - Created znode
named '/someapp/someotherpolicy'
2015-05-02 13:59:43,795 [main           ] INFO  DefaultCamelContext            - Route: route1
started and consuming from: Endpoint[direct://policy-controlled]
2015-05-02 13:59:43,797 [main           ] INFO  DefaultCamelContext            - Route: route2
started and consuming from: Endpoint[direct://policy-controlled-1]
2015-05-02 13:59:43,813 [main           ] INFO  ZooKeeperElection              - Initializing
ZookeeperElection with uri 'zookeeper:localhost:39913/someapp/somepolicy'
2015-05-02 13:59:43,832 [main           ] WARN  ZookeeperProducer              - Node '/someapp/somepolicy/ancosen-home-74bce950-9db9-4d75-b070-cd5fefcaba42'
did not exist, creating it.
2015-05-02 13:59:43,838 [main           ] INFO  ZooKeeperElection              - Candidate
node '/someapp/somepolicy/ancosen-home-74bce950-9db9-4d75-b070-cd5fefcaba42' has been created
2015-05-02 13:59:43,860 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-home-74bce950-9db9-4d75-b070-cd5fefcaba42
started and consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
2015-05-02 13:59:43,866 [main           ] INFO  MockEndpoint                   - Asserting:
Endpoint[mock://controlled] is satisfied
2015-05-02 13:59:43,867 [main           ] INFO  ZooKeeperElection              - Initializing
ZookeeperElection with uri 'zookeeper:localhost:39913/someapp/someotherpolicy'
2015-05-02 13:59:43,873 [main           ] WARN  ZookeeperProducer              - Node '/someapp/someotherpolicy/ancosen-home-e00213ec-cf67-4a80-ac11-8b0d8b7785fe'
did not exist, creating it.
2015-05-02 13:59:43,876 [main           ] INFO  ZooKeeperElection              - Candidate
node '/someapp/someotherpolicy/ancosen-home-e00213ec-cf67-4a80-ac11-8b0d8b7785fe' has been
created
2015-05-02 13:59:43,880 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-home-e00213ec-cf67-4a80-ac11-8b0d8b7785fe
started and consuming from: Endpoint[zookeeper://localhost:39913/someapp/someotherpolicy]
2015-05-02 13:59:43,881 [main           ] INFO  MockEndpoint                   - Asserting:
Endpoint[mock://controlled-1] is satisfied
2015-05-02 13:59:43,881 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - ********************************************************************************
2015-05-02 13:59:43,881 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - Testing done:
routeDoublePoliciesAndTwoRoutes(org.apache.camel.component.zookeeper.policy.ZookeeperDoubleRoutePolicyTest)
2015-05-02 13:59:43,881 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - Took: 0.847
seconds (847 millis)
2015-05-02 13:59:43,881 [main           ] INFO  ZookeeperDoubleRoutePolicyTest - ********************************************************************************
2015-05-02 13:59:43,882 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) is shutting down
2015-05-02 13:59:43,882 [main           ] INFO  DefaultShutdownStrategy        - Starting
to graceful shutdown 4 routes (timeout 10 seconds)
2015-05-02 13:59:43,886 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: election-route-ancosen-home-e00213ec-cf67-4a80-ac11-8b0d8b7785fe
shutdown complete, was consuming from: Endpoint[zookeeper://localhost:39913/someapp/someotherpolicy]
2015-05-02 13:59:43,887 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: election-route-ancosen-home-74bce950-9db9-4d75-b070-cd5fefcaba42
shutdown complete, was consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
2015-05-02 13:59:43,888 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: route2
shutdown complete, was consuming from: Endpoint[direct://policy-controlled-1]
2015-05-02 13:59:43,888 [ - ShutdownTask] INFO  DefaultShutdownStrategy        - Route: route1
shutdown complete, was consuming from: Endpoint[direct://policy-controlled]
2015-05-02 13:59:43,888 [main           ] INFO  DefaultShutdownStrategy        - Graceful
shutdown of 4 routes completed in 0 seconds
2015-05-02 13:59:43,897 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) uptime 0.936 seconds
2015-05-02 13:59:43,897 [main           ] INFO  DefaultCamelContext            - Apache Camel
2.16-SNAPSHOT (CamelContext: camel-1) is shutdown in 0.015 seconds
2015-05-02 13:59:43,898 [main           ] INFO  ZooKeeperTestSupport           - Stopping
Zookeeper Test Infrastructure
2015-05-02 13:59:43,902 [main           ] INFO  ZooKeeperTestSupport           - Stopped Zookeeper
Test Infrastructure

{code}

Two distinct election routes started:

{code}
2015-05-02 13:59:43,860 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-home-74bce950-9db9-4d75-b070-cd5fefcaba42
started and consuming from: Endpoint[zookeeper://localhost:39913/someapp/somepolicy]
.
.
.
2015-05-02 13:59:43,880 [main           ] INFO  DefaultCamelContext            - Route: election-route-ancosen-home-e00213ec-cf67-4a80-ac11-8b0d8b7785fe
started and consuming from: Endpoint[zookeeper://localhost:39913/someapp/someotherpolicy]
{code}

> Only one ZooKeeperRoutePolicy possible
> --------------------------------------
>
>                 Key: CAMEL-7501
>                 URL: https://issues.apache.org/jira/browse/CAMEL-7501
>             Project: Camel
>          Issue Type: Improvement
>          Components: camel-zookeeper
>    Affects Versions: 2.12.3
>            Reporter: Scott Stults
>            Assignee: Andrea Cosentino
>             Fix For: Future
>
>
> If two ZooKeeperRoutePolicy's are created and used in separate routes, only one leader
election route gets created. This effectively nullifies the route policy for the second route,
meaning it works regardless of leadership status (even on the other route).



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message