Hello,
I am using spring-boot with camel.
Seems there is a bug.
My route is "from("wmq:TEST.Q.IN?...")
It seems the consumer doesn't get the queue name (destinationName).
In WMQConsumer the expresion: "this.getEndpoint().getDestinationName()" returns null that throws an error (line 55)
Setting the type like "wmq:queue:TEST.Q.IN" doesn't help.

Any chance to fix it? :)

Given route with pollEnrich :

<pollEnrich>
    <simple>smb:...</simple>
</pollEnrich>

When samba has a file
Then it hangs
Should process further.

Camel has another process to initialize consumer inside pollEnrich: start() for smb consumer has never been executed. See org.apache.camel.impl.EventDrivenPollingConsumer#doStart:

protected void doStart() throws Exception {
        this.consumer = this.createConsumer();
        if (this.consumer instanceof PollingConsumerPollingStrategy) {
            PollingConsumerPollingStrategy strategy = (PollingConsumerPollingStrategy)this.consumer;
            strategy.onInit();
        } else {
            ServiceHelper.startService(this.consumer);
        }

    }

As you see EventDrivenPollingConsumer is pollEnrich and consumer is SmbConsumer which implements PollingConsumerPollingStrategy so it calls onInit() instead of start() but SmbConsumer does nothing on onInit.

How to solve:
change SmbConsumer#onInit and call start there.

Affected version all from >= 2.21.x

Hi
I just asked on the Apache Camel Gitter channel if camel-extra is compatible with later Camel Releases such as 3.2.0 which I am using and a reply said it is not.

Are there plans to make camel-extra Apache Camel 3.x compatible?

Many Thanks,
Mikael

It seems that the conversion from SmbFile to SmbGenericFile is not correct. This causes that the AntPathMatcherFileFilter cannot correctly match includes/excludes.

When the smb consumer is started, I get the error: a java.lang.NoSuchMethodError: org.apache.camel.component.file.GenericFileConsumer.(Lorg/apache/camel/component/file/GenericFileEndpoint;Lorg/apache/camel/Processor;Lorg/apache/camel/component/file/GenericFileOperations;Lorg/apache/camel/component/file/GenericFileProcessStrategy;)V
The error occurs in the consumer constructor on calling the super constructor but I don't see why because there is a public GenericFileConsumer(GenericFileEndpoint endpoint, Processor processor, GenericFileOperations operations, GenericFileProcessStrategy processStrategy) constructor in the camel-core jar
stacktrace.txt
.

Hi team,

I tried using older version of this component (the one available on Maven repo), but it didn't work for me. However, I had some success with version 3.14.3-SNAPSHOT, well done. When are you guys going to push this component to Maven central?

PS: I didn't know how to ask you the question about this so used this channel, sorry for the inconvenience caused

Thanks in advance!
-S

Could you please guide on how to handle camel-jcifs consumer exception? I tried the following route

from("smb://xxxxxxx/&noop=true&idempotent=true&delay=10000&readLock=changed&readLockCheckInterval=5000&consumer.bridgeErrorHandler=true").onException(Exception.class).handled(true).process(new ErrorProcessor(sampleDocument));

Route worked fine for FTP/File component when the connection exception is thrown from consumer component. When I tried doing the same on jcifs, it is just displaying the connection exception as warning and not bridged with camel exception handler to be handled by onexception.

Exception as below

2019-04-26T10:22:52.517+0530 WARN o.a.c.c.j.SmbConsumer-213 Consumer Consumer[smb:/xxxxxxx/&noop=true&idempotent=true&delay=10000&readLock=changed&readLockCheckInterval=5000&consumer.errorHandler=true] failed polling endpoint: smb:/xxxxxxxx/&noop=true&idempotent=true&delay=10000&readLock=changed&readLockCheckInterval=5000&consumer.errorHandler=true. Will try again at next poll. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - Could not get files Failed to connect: 0.0.0.0<00>/10.96.59.177]
org.apache.camel.component.file.GenericFileOperationFailedException: Could not get files Failed to connect: 0.0.0.0<00>/10.96.59.177
at org.apacheextras.camel.component.jcifs.SmbOperations.listFiles(SmbOperations.java:350) ~[camel-jcifs-2.22.0.jar!/:2.22.0]
at org.apacheextras.camel.component.jcifs.SmbConsumer.pollDirectory(SmbConsumer.java:60) ~[camel-jcifs-2.22.0.jar!/:2.22.0]
at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:128) ~[camel-core-2.23.0.jar!/:2.23.0]
at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:174) [camel-core-2.23.0.jar!/:2.23.0]
at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:101) [camel-core-2.23.0.jar!/:2.23.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_191]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [?:1.8.0_191]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_191]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [?:1.8.0_191]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_191]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_191]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_191]
Caused by: jcifs.smb.SmbException: Failed to connect: 0.0.0.0<00>/10.96.59.177
at jcifs.smb.SmbTransport.connect(SmbTransport.java:309) ~[jcifs-1.3.17.jar!/:?]
at jcifs.smb.SmbTree.treeConnect(SmbTree.java:156) ~[jcifs-1.3.17.jar!/:?]
at jcifs.smb.SmbFile.doConnect(SmbFile.java:911) ~[jcifs-1.3.17.jar!/:?]
at jcifs.smb.SmbFile.connect(SmbFile.java:954) ~[jcifs-1.3.17.jar!/:?]
at jcifs.smb.SmbFile.connect0(SmbFile.java:880) ~[jcifs-1.3.17.jar!/:?]
at jcifs.smb.SmbFile.getType(SmbFile.java:1282) ~[jcifs-1.3.17.jar!/:?]
at jcifs.smb.SmbFile.doEnum(SmbFile.java:1733) ~[jcifs-1.3.17.jar!/:?]
at jcifs.smb.SmbFile.listFiles(SmbFile.java:1715) ~[jcifs-1.3.17.jar!/:?]
at jcifs.smb.SmbFile.listFiles(SmbFile.java:1648) ~[jcifs-1.3.17.jar!/:?]
at org.apacheextras.camel.component.jcifs.DefaultSmbClient.listFiles(DefaultSmbClient.java:161) ~[camel-jcifs-2.22.0.jar!/:2.22.0]
at org.apacheextras.camel.component.jcifs.SmbOperations.listFiles(SmbOperations.java:346) ~[camel-jcifs-2.22.0.jar!/:2.22.0]

Hi, first of all, thank you for this repository. Helped a lot already.

I am using camel for quarkus and jcifs was the missing component I needed.

Recently I updated the project to the latest quarkus (2.16.4) which uses apache camel 3.20.1

Long story short, is there any chance releasing jcifs for camel 3.20.1?

Much appreciated!

Hi,

there is an issue with the camel-zeromq component. Please see below

https://github.com/camel-extra/camel-extra/blob/master/components/camel-zeromq/src/main/java/org/apacheextras/camel/component/zeromq/Listener.java#L130

The listener class tries to terminate the context, while a socket is being operated in another thread.
Multi-threading operations like this are not supported by org.zeromq.ZMQ.Context.

The code in this class needs to find other ways to deal with the situation. It might be achieved by a control pipe and a poller, or other solution, except interrupting the running thread.

Originally posted by @fredoboulo in zeromq/jeromq#699 (comment)

Related question on SO: https://stackoverflow.com/questions/55327518/camel-zeromq-is-not-properly-terminating-jeromq-context