Dear Dev Team,
First I'm not a developer but just an IT administrator.
We are working to implement NiFi with ActiveMQ extension nevertheless it
doesn't work fine.
We use NiFi 1.19.1, ActiveMQ extension and Java Eclipse Adoptium 11.
We need to use a proxy HTTP (SQUID) to access to internet.
Within the NiFi log we have :
2023-03-15 14:15:16,769 INFO [Cleanup Archive for default]
o.a.n.c.repository.FileSystemRepository Successfully deleted 0 files (0 bytes)
from archive
2023-03-15 14:15:16,769 INFO [Cleanup Archive for default]
o.a.n.c.repository.FileSystemRepository Archive cleanup completed for container
default; will now allow writing to this container. Bytes used = 48.31 GB, bytes
free = 41.05 GB, capacity = 89.37 GB
2023-03-15 14:15:21,207 INFO [pool-7-thread-1]
o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile
Repository
2023-03-15 14:15:21,207 INFO [pool-7-thread-1]
o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile
Repository with 732 records in 0 milliseconds
2023-03-15 14:15:40,739 DEBUG [ActiveMQ Task-1]
o.a.a.t.failover.FailoverTransport Connect fail to: ssl://url:61616, reason: {}
java.net.SocketTimeoutException: Connect timed out
at
java.base/java.net.SocksSocketImpl.readSocksReply(SocksSocketImpl.java:139)
at
java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:455)
at java.base/java.net.Socket.connect(Socket.java:609)
at
java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)
at
org.apache.activemq.transport.tcp.TcpTransport.connect(TcpTransport.java:525)
at
org.apache.activemq.transport.tcp.TcpTransport.doStart(TcpTransport.java:488)
at
org.apache.activemq.util.ServiceSupport.start(ServiceSupport.java:55)
at
org.apache.activemq.transport.AbstractInactivityMonitor.start(AbstractInactivityMonitor.java:169)
at
org.apache.activemq.transport.InactivityMonitor.start(InactivityMonitor.java:52)
at
org.apache.activemq.transport.TransportFilter.start(TransportFilter.java:64)
at
org.apache.activemq.transport.WireFormatNegotiator.start(WireFormatNegotiator.java:72)
at
org.apache.activemq.transport.failover.FailoverTransport.doReconnect(FailoverTransport.java:1019)
at
org.apache.activemq.transport.failover.FailoverTransport$2.iterate(FailoverTransport.java:149)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:829)
2023-03-15 14:15:40,739 DEBUG [ActiveMQ Task-1]
o.a.activemq.transport.tcp.TcpTransport Stopping transport
ssl:///XX.XX.XXX.XX:3128 (Our Proxy IP and port)
2023-03-15 14:15:40,739 DEBUG [ActiveMQ Task-1]
o.a.activemq.thread.TaskRunnerFactory Initialized TaskRunnerFactory[ActiveMQ
Task] using ExecutorService:
java.util.concurrent.ThreadPoolExecutor@2762cc08[Running<mailto:java.util.concurrent.ThreadPoolExecutor@2762cc08[Running>,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
2023-03-15 14:15:40,739 DEBUG [ActiveMQ Task-1]
o.a.activemq.transport.tcp.TcpTransport Closed socket
Socket[addr=/XX.XX.XXX.XX,port=3128,localport=60080]
2023-03-15 14:15:40,739 DEBUG [ActiveMQ Task-1]
org.apache.activemq.util.ThreadPoolUtils Forcing shutdown of ExecutorService:
java.util.concurrent.ThreadPoolExecutor@2762cc08[Running<mailto:java.util.concurrent.ThreadPoolExecutor@2762cc08[Running>,
pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 0]
2023-03-15 14:15:40,739 DEBUG [ActiveMQ Task-1]
o.a.a.t.failover.FailoverTransport Attempting 257th connect to: ssl://url:61616
2023-03-15 14:15:41,223 INFO [pool-7-thread-1]
o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile
Repository
2023-03-15 14:15:41,223 INFO [pool-7-thread-1]
o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile
Repository with 732 records in 0 milliseconds
Could the problem come from using a proxy ?
Do we need to check ActiveMQ configuration ?
Many thanks for your support.
Best regards
Sylvain HODCENT
[Hutchinson
®]<http://www.hutchinson.com/?utm_campaign=signature&utm_medium=email&utm_source=fr&utm_term=logo>
Systèmes Antivibratoires - HUTCHINSON AVS
CAD/CAE Administrator - R&D Department
PAULSTRA SNC - Parc d'activité de Beauvoir - 26 Bd de Péringondas
28207 CHATEAUDUN CEDEX - France
[email protected]<mailto:[email protected]>
www.hutchinson.com<http://www.hutchinson.com/?utm_campaign=signature&utm_medium=email&utm_source=website>
[Linkedin]<http://www.hutchinson.com/fr/tracking?redirect=linkedin&url=https%3A%2F%2Fwww.linkedin.com%2Fcompany%2Fhutchinson&utm_campaign=signature&utm_medium=email&utm_source=linkedin>
[Youtube]
<http://www.hutchinson.com/fr/tracking?redirect=youtube&url=https%3A%2F%2Fwww.youtube.com%2Fchannel%2FUC87vwGqc3JB-W3It-cYPKjQ&utm_campaign=signature&utm_medium=email&utm_source=youtube>
[contributing to future mobility -
585*100]<http://www.hutchinson.com/?utm_campaign=signature&utm_medium=email&utm_source=banner&utm_term=contributing+to+future+mobility+-+585%2A100>
Pour la planète, n'imprimez ce mail que si c'est nécessaire.
CONFIDENTIALITÉ :
Ce courrier électronique (y compris ses éventuelles pièces jointes) peut
contenir des informations susceptibles d'être confidentielles.
Il ne peut être utilisé autrement que pour la finalité pour laquelle il a été
envoyé.
Au cas où il ne vous serait pas destiné, merci de le supprimer et d'en avertir
immédiatement l'expéditeur.
