Daniel Feist
2012-07-12 01:40:58 UTC
- It doesn't make sense for any kind of test to cover this?
- Can we try to commit with 'MULE' JIRA's for community visibility.
Dan
- Can we try to commit with 'MULE' JIRA's for community visibility.
Dan
Revision
24614
Author
pablo.lagreca
Date
2012-07-11 10:34:20 -0500 (Wed, 11 Jul 2012)
Log Message
EE-2700 - only the primary node does polling for http
Modified Paths
branches/mule-3.2.x/transports/http/src/main/java/org/mule/transport/http/PollingHttpMessageReceiver.java
Diff
Modified: branches/mule-3.2.x/transports/http/src/main/java/org/mule/transport/http/PollingHttpMessageReceiver.java (24613 => 24614)
--- branches/mule-3.2.x/transports/http/src/main/java/org/mule/transport/http/PollingHttpMessageReceiver.java 2012-07-11 13:58:26 UTC (rev 24613)
+++ branches/mule-3.2.x/transports/http/src/main/java/org/mule/transport/http/PollingHttpMessageReceiver.java 2012-07-11 15:34:20 UTC (rev 24614)
@@ -53,6 +53,11 @@
setupFromConnector(connector);
}
+ protected boolean pollOnPrimaryInstanceOnly() {
+ return true;
+ }
+
protected void setupFromConnector(Connector connector) throws CreateException
{
if (!(connector instanceof HttpPollingConnector))
http://xircles.codehaus.org/manage_email
24614
Author
pablo.lagreca
Date
2012-07-11 10:34:20 -0500 (Wed, 11 Jul 2012)
Log Message
EE-2700 - only the primary node does polling for http
Modified Paths
branches/mule-3.2.x/transports/http/src/main/java/org/mule/transport/http/PollingHttpMessageReceiver.java
Diff
Modified: branches/mule-3.2.x/transports/http/src/main/java/org/mule/transport/http/PollingHttpMessageReceiver.java (24613 => 24614)
--- branches/mule-3.2.x/transports/http/src/main/java/org/mule/transport/http/PollingHttpMessageReceiver.java 2012-07-11 13:58:26 UTC (rev 24613)
+++ branches/mule-3.2.x/transports/http/src/main/java/org/mule/transport/http/PollingHttpMessageReceiver.java 2012-07-11 15:34:20 UTC (rev 24614)
@@ -53,6 +53,11 @@
setupFromConnector(connector);
}
+ protected boolean pollOnPrimaryInstanceOnly() {
+ return true;
+ }
+
protected void setupFromConnector(Connector connector) throws CreateException
{
if (!(connector instanceof HttpPollingConnector))
http://xircles.codehaus.org/manage_email