Details
-
Type:
Patch submission
-
Status:
Closed
-
Priority:
Critical
-
Resolution: Fixed
-
Affects Version/s: 2.2.1
-
Fix Version/s: 3.0.1, 3.1.0, Bug Backlog
-
Component/s: Transport: Quartz
-
Labels:None
-
Environment:
jdk: 1.6
jre: java-6-sun-1.6.0.16
OS: ubuntu 9.0.4
-
User impact:Low
-
Configuration:
-
Similar Issues:None
Description
When I attempt to utilize a quartz-endpoint-polling-job to grab files from a file-endpoint, the <file:filename-wildcard-filter> I have configured on the file-endpoint is NOT applied, and ALL of the files in the specified directory are processed including sub-directories
Activity
David Kjerrumgaard
made changes -
| Field | Original Value | New Value |
|---|---|---|
| Attachment | EndpointPollingJob.java [ 12629 ] |
Mike Schilling
made changes -
| Issue Type | Bug [ 1 ] | Patch submission [ 5 ] |
| Fix Version/s | Bug Backlog [ 10522 ] | |
| Priority | To be reviewed [ 6 ] | Critical [ 2 ] |
Dirk Olmes
made changes -
| Assignee | Mike Schilling [ mike.schilling ] |
Mike Schilling
made changes -
| Fix Version/s | 3.0.1 [ 10877 ] |
Mike Schilling
made changes -
| Link | This issue blocks BL-294 [ BL-294 ] |
Mike Schilling
made changes -
| Status | Open [ 1 ] | Closed [ 6 ] |
| Fix Version/s | 3.1.0 [ 10898 ] | |
| Resolution | Fixed [ 1 ] |
| Transition | Time In Source Status | Execution Times | Last Executer | Last Execution Date | |||||
|---|---|---|---|---|---|---|---|---|---|
|
239d 2h 23m | 1 | Mike Schilling | 05/Nov/10 06:09 PM |
This list may be incomplete, as errors occurred whilst retrieving source from linked applications:
- Repository mule on http://foo.bar/ failed: Error in remote call to 'FishEye 0 (http://foo.bar/)' (http://foo.bar) [AbstractRestCommand{path='/rest-service-fe/changeset-v1/listChangesets/', params={expand=changesets[-21:-1].revisions[0:29], comment=MULE-4784, p4JobFixed=MULE-4784, rep=mule}, methodType=GET}] : java.net.UnknownHostException: foo.bar
The problematic class is or.mule.transport,quartz.EndpointPollingJob,
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
....
try
{
MuleClient client = connector.getClient();
logger.debug("Attempting to receive event on: " + jobConfig.getEndpointRef());
/* PROBLEM OCCURS ON THE NEXT LINE.
*
*/
MuleMessage result = client.request(jobConfig.getEndpointRef(), jobConfig.getTimeout());
if (result != null)
{ logger.debug("Received event on: " + jobConfig.getEndpointRef()); }{
if (logger.isDebugEnabled())
//we need to do this because
result = (MuleMessage)((ThreadSafeAccess)result).newThreadCopy();
//Add the context properties to the message.
result.addProperties(jobDataMap, PropertyScope.INVOCATION);
receiver.routeMessage(result);
{ throw new JobExecutionException(e); }}
}
catch (MuleException e)
- The code needs to handle InboundEndpoints and OutBoundEndpoints differently, specifically
- applying the filters to InboundEndpoints.....
*/
MuleMessage result = client.request(jobConfig.getEndpointRef(), jobConfig.getTimeout());
if (result != null) { if (logger.isDebugEnabled()) { logger.debug("Received event on: " + jobConfig.getEndpointRef()); } //we need to do this because result = (MuleMessage)((ThreadSafeAccess)result).newThreadCopy(); //Add the context properties to the message. result.addProperties(jobDataMap, PropertyScope.INVOCATION); receiver.routeMessage(result); } } catch (MuleException e) { throw new JobExecutionException(e); }