Re: Broken conections after ACTIVEMQ restart
Nelson, in my scenario I do have a Cas Multiplier which produces a child CAS for each input CAS. For the purpose of this test its not important how many internal delegates there are in a pipeline. The service is configured as a Cas Multiplier and it does send child CASes when a broker is running. The problem is that once the input CAS is received, its reply queue is bound to a specific temp reply queue. When a broker is bounced, that queue is not valid anymore and cant be used to return child CASes nor the input CAS. To guard against such cases you need to use timeouts on the client side. Like I said in my previous email I dont get how an input CAS can be returned back to the client after a broker bounce. This should not happen since its temp queue does not exist in a new broker. I am still looking at this scenario as I don't like what I see in the service log. I think there might be a bug in the UIMA-AS but I am still investigating. Bug or not, what I described above is how UIMA-AS works. You should not expect any replies from a service working on a CAS that was sent through a broker that is bounced before a reply. -jerry On Tue, Sep 27, 2016 at 3:18 PM, nelson riverawrote: > My service is a aggregate analysis engine that receives input CAS > with the direcction of a directory of documents, the first component > is a MultiplerCas that for each document generate a child CAS, each > child CAS continues the flow that are other primitive annotators > (primitive annotators in c++ that can throw exceptions), then exists > other MultiplerCas that acts as Merger, waiting the complete > processing of each child CAS and finally generate a child CAS where > each child CAS previously processed is a view of CAS, this a child CAS > that is composed of view continĂșa el flujo a otro AE, que espera un > CAS de esta manera. > I will send you my uima-as descriptor, to understand better my > service. All delegates are co-located. > > i will trys with uima-as-2.9.0 snapshot how you say, to see how it behaves > > 2016-09-27 14:27 GMT-04:00, Jaroslaw Cwiklik : > > I was able to stage this scenario in which an aggregate service cas > > multiplier receives a single input CAS and > > produces a child CAS. > > > > Scenario: > > 1) Service receives input CAS > > 2) CasMultiplier generates a child CAS > > 3) AE.process() is called (child CAS) and it sleeps for awhile > > 4) Broker is shutdown > > 5) AE.process() awakes from sleep > > 6) Uima-AS tries to deliver child CAS to a remote client > > 7) Connection is invalid so the child CAS is dropped > > 8) Broker is restarted > > 9) Listeners reconnect: > > INFO | Successfully refreshed JMS Connection > > INFO | Successfully refreshed JMS Connection > > 10) Broker log shows: > > WARN Service- Async error occurred: > > org.apache.activemq.DestinationDoesNotExistException: The destination > > temp-queue://ID:bluejws65-53920-1474997439574-8:1:1 does not exist. > > WARN Service- Async error occurred: > > org.apache.activemq.DestinationDoesNotExistException: The destination > > temp-queue://ID:bluejws65-53920-1474997439574-8:1:1 does not exist. > > > > The service failed to send a reply.Nothing is delivered to a client as > > expected. This is the confusing part since you see a parent CAS being > sent > > to a client. I just cant imagine how this is possible. > > > > When a service receives an input CAS in a message, it extracts a JMS > > replyTo object which is a JMS temp queue and stores in an internal cache > > until it is time to send a reply. Temp queues are transient and unique > each > > time one is created. > > > > If the broker dies and subsequently restarts, the cached replyTo queue > > object is invalid (temp queue no longer exist) which leads to > > "Async error occurred: > > org.apache.activemq.DestinationDoesNotExistException" as shows above. > > > > In the service log I see a bunch of these exceptions: > > > > 02:05:46.574 - 56: > > org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl. > openChannel: > > WARNING: Service: Test Aggregate TAE Unable to Open Connection To Broker: > > tcp://localhost:61616?wireFormat.maxInactivityDuration=0 - Silently > > Retrying ... > > 02:05:46.574 - 56: > > org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl. > openChannel: > > WARNING: > > javax.jms.JMSException: Could not connect to broker URL: > > tcp://localhost:61616?wireFormat.maxInactivityDuration=0. Reason: > > java.net.ConnectException: Connection refused > > > > This is *after* the service is restarted so there seems to be a problem > > with reestablishing the connection to a new broker. > > I am still investigating that part. I just am confused how you are able > to > > see a reply in the client. > > > > -Jerry > > > > > > On Tue, Sep 27, 2016 at 1:13 PM, Jaroslaw Cwiklik > wrote: > > > >> From what I understand there are two issues: >
Re: Broken conections after ACTIVEMQ restart
My service is a aggregate analysis engine that receives input CAS with the direcction of a directory of documents, the first component is a MultiplerCas that for each document generate a child CAS, each child CAS continues the flow that are other primitive annotators (primitive annotators in c++ that can throw exceptions), then exists other MultiplerCas that acts as Merger, waiting the complete processing of each child CAS and finally generate a child CAS where each child CAS previously processed is a view of CAS, this a child CAS that is composed of view continĂșa el flujo a otro AE, que espera un CAS de esta manera. I will send you my uima-as descriptor, to understand better my service. All delegates are co-located. i will trys with uima-as-2.9.0 snapshot how you say, to see how it behaves http://uima.apache.org/resourceSpecifier;> AnalyzerAE Deploy Descriptor Deploys AnalyzerAE
Re: Broken conections after ACTIVEMQ restart
My service is a aggregate analysis engine that receives input CAS with the direcction of a directory of documents, the first component is a MultiplerCas that for each document generate a child CAS, each child CAS continues the flow that are other primitive annotators (primitive annotators in c++ that can throw exceptions), then exists other MultiplerCas that acts as Merger, waiting the complete processing of each child CAS and finally generate a child CAS where each child CAS previously processed is a view of CAS, this a child CAS that is composed of view continĂșa el flujo a otro AE, que espera un CAS de esta manera. I will send you my uima-as descriptor, to understand better my service. All delegates are co-located. i will trys with uima-as-2.9.0 snapshot how you say, to see how it behaves 2016-09-27 14:27 GMT-04:00, Jaroslaw Cwiklik: > I was able to stage this scenario in which an aggregate service cas > multiplier receives a single input CAS and > produces a child CAS. > > Scenario: > 1) Service receives input CAS > 2) CasMultiplier generates a child CAS > 3) AE.process() is called (child CAS) and it sleeps for awhile > 4) Broker is shutdown > 5) AE.process() awakes from sleep > 6) Uima-AS tries to deliver child CAS to a remote client > 7) Connection is invalid so the child CAS is dropped > 8) Broker is restarted > 9) Listeners reconnect: > INFO | Successfully refreshed JMS Connection > INFO | Successfully refreshed JMS Connection > 10) Broker log shows: > WARN Service- Async error occurred: > org.apache.activemq.DestinationDoesNotExistException: The destination > temp-queue://ID:bluejws65-53920-1474997439574-8:1:1 does not exist. > WARN Service- Async error occurred: > org.apache.activemq.DestinationDoesNotExistException: The destination > temp-queue://ID:bluejws65-53920-1474997439574-8:1:1 does not exist. > > The service failed to send a reply.Nothing is delivered to a client as > expected. This is the confusing part since you see a parent CAS being sent > to a client. I just cant imagine how this is possible. > > When a service receives an input CAS in a message, it extracts a JMS > replyTo object which is a JMS temp queue and stores in an internal cache > until it is time to send a reply. Temp queues are transient and unique each > time one is created. > > If the broker dies and subsequently restarts, the cached replyTo queue > object is invalid (temp queue no longer exist) which leads to > "Async error occurred: > org.apache.activemq.DestinationDoesNotExistException" as shows above. > > In the service log I see a bunch of these exceptions: > > 02:05:46.574 - 56: > org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl.openChannel: > WARNING: Service: Test Aggregate TAE Unable to Open Connection To Broker: > tcp://localhost:61616?wireFormat.maxInactivityDuration=0 - Silently > Retrying ... > 02:05:46.574 - 56: > org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl.openChannel: > WARNING: > javax.jms.JMSException: Could not connect to broker URL: > tcp://localhost:61616?wireFormat.maxInactivityDuration=0. Reason: > java.net.ConnectException: Connection refused > > This is *after* the service is restarted so there seems to be a problem > with reestablishing the connection to a new broker. > I am still investigating that part. I just am confused how you are able to > see a reply in the client. > > -Jerry > > > On Tue, Sep 27, 2016 at 1:13 PM, Jaroslaw Cwiklik wrote: > >> From what I understand there are two issues: >> >> 1) Why service JMS listeners are not reconnecting when a broker is >> bounced. This >> should be done by default. The 2.9.0 snapshot may address this since >> a >> listener >> uses newer AMQ jars (5.14.0) >> >> 2) What happens to a child CAS when a Broker disappears and the service >> wants >> to deliver it to a client that is not reachable. I need to >> investigate >> this part. I think >> such CAS is dropped but that should be reflected in a log and also >> the >> input CAS >> should be marked as failed. Again something for me to investigate. >> >> I will try to set up a test to see if I can create the scenario.It will >> take me a bit of time >> to set this up but I will let you know what happens. >> >> -jerry >> >> On Tue, Sep 27, 2016 at 12:42 PM, Jaroslaw Cwiklik >> wrote: >> >>> Here is the uima-as 2.9.0-SNAPSHOT to try: >>> https://repository.apache.org/content/repositories/snapshots >>> /org/apache/uima/uima-as/2.9.0-SNAPSHOT/uima-as-2.9.0-201609 >>> 23.195233-6.tar.gz >>> >>> Can you briefly describe your service? Does your service have any remote >>> delegates or all parts of the pipeline are in the same process? >>> Do you see and exceptions in the service log? >>> >>> -jerry >>> >>> On Tue, Sep 27, 2016 at 9:07 AM, nelson rivera >>> >>> wrote: >>> I was testing with AMQ broker 5.14.0 and i
Re: Broken conections after ACTIVEMQ restart
I was able to stage this scenario in which an aggregate service cas multiplier receives a single input CAS and produces a child CAS. Scenario: 1) Service receives input CAS 2) CasMultiplier generates a child CAS 3) AE.process() is called (child CAS) and it sleeps for awhile 4) Broker is shutdown 5) AE.process() awakes from sleep 6) Uima-AS tries to deliver child CAS to a remote client 7) Connection is invalid so the child CAS is dropped 8) Broker is restarted 9) Listeners reconnect: INFO | Successfully refreshed JMS Connection INFO | Successfully refreshed JMS Connection 10) Broker log shows: WARN Service- Async error occurred: org.apache.activemq.DestinationDoesNotExistException: The destination temp-queue://ID:bluejws65-53920-1474997439574-8:1:1 does not exist. WARN Service- Async error occurred: org.apache.activemq.DestinationDoesNotExistException: The destination temp-queue://ID:bluejws65-53920-1474997439574-8:1:1 does not exist. The service failed to send a reply.Nothing is delivered to a client as expected. This is the confusing part since you see a parent CAS being sent to a client. I just cant imagine how this is possible. When a service receives an input CAS in a message, it extracts a JMS replyTo object which is a JMS temp queue and stores in an internal cache until it is time to send a reply. Temp queues are transient and unique each time one is created. If the broker dies and subsequently restarts, the cached replyTo queue object is invalid (temp queue no longer exist) which leads to "Async error occurred: org.apache.activemq.DestinationDoesNotExistException" as shows above. In the service log I see a bunch of these exceptions: 02:05:46.574 - 56: org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl.openChannel: WARNING: Service: Test Aggregate TAE Unable to Open Connection To Broker: tcp://localhost:61616?wireFormat.maxInactivityDuration=0 - Silently Retrying ... 02:05:46.574 - 56: org.apache.uima.adapter.jms.activemq.JmsEndpointConnection_impl.openChannel: WARNING: javax.jms.JMSException: Could not connect to broker URL: tcp://localhost:61616?wireFormat.maxInactivityDuration=0. Reason: java.net.ConnectException: Connection refused This is *after* the service is restarted so there seems to be a problem with reestablishing the connection to a new broker. I am still investigating that part. I just am confused how you are able to see a reply in the client. -Jerry On Tue, Sep 27, 2016 at 1:13 PM, Jaroslaw Cwiklikwrote: > From what I understand there are two issues: > > 1) Why service JMS listeners are not reconnecting when a broker is > bounced. This > should be done by default. The 2.9.0 snapshot may address this since a > listener > uses newer AMQ jars (5.14.0) > > 2) What happens to a child CAS when a Broker disappears and the service > wants > to deliver it to a client that is not reachable. I need to investigate > this part. I think > such CAS is dropped but that should be reflected in a log and also the > input CAS > should be marked as failed. Again something for me to investigate. > > I will try to set up a test to see if I can create the scenario.It will > take me a bit of time > to set this up but I will let you know what happens. > > -jerry > > On Tue, Sep 27, 2016 at 12:42 PM, Jaroslaw Cwiklik > wrote: > >> Here is the uima-as 2.9.0-SNAPSHOT to try: >> https://repository.apache.org/content/repositories/snapshots >> /org/apache/uima/uima-as/2.9.0-SNAPSHOT/uima-as-2.9.0-201609 >> 23.195233-6.tar.gz >> >> Can you briefly describe your service? Does your service have any remote >> delegates or all parts of the pipeline are in the same process? >> Do you see and exceptions in the service log? >> >> -jerry >> >> On Tue, Sep 27, 2016 at 9:07 AM, nelson rivera >> wrote: >> >>> I was testing with AMQ broker 5.14.0 and i get the same error. not >>> appears to be broker >>> issues, appears to be uima-as issues. Any other idea, i am stagnant at >>> work >>> >>> 2016-09-22 13:04 GMT-04:00, Jaroslaw Cwiklik : >>> > Can you install AMQ broker 5.14.0 to see if this is related to broker >>> > issues. >>> > >>> > -jerry >>> > >>> > On Thu, Sep 22, 2016 at 11:29 AM, nelson rivera < >>> nelsonriver...@gmail.com> >>> > wrote: >>> > >>> >> just like that, the parent CAS comes back but the child CAS doesnt. >>> >> >>> >> And the child CAS if processed, because the uima-as log shows the >>> >> lines of the other annotators primitive of the flow processing the >>> >> child CAS, but not comes back to UIMA-AS client. >>> >> >>> >> uima-as log only shows >>> >> "Jms Listener Failed. Endpoint: >>> >> temp-queue://ID:localhsot-H81-M1-33610-1474481197190-1:1:1 Managed >>> By: >>> >> tcp://localhost:61616 Reason: javax.jms.JMSException: >>> >> java.io.EOFException" >>> >> ADVERTENCIA: Jms Listener Failed. Endpoint:
Re: Broken conections after ACTIVEMQ restart
>From what I understand there are two issues: 1) Why service JMS listeners are not reconnecting when a broker is bounced. This should be done by default. The 2.9.0 snapshot may address this since a listener uses newer AMQ jars (5.14.0) 2) What happens to a child CAS when a Broker disappears and the service wants to deliver it to a client that is not reachable. I need to investigate this part. I think such CAS is dropped but that should be reflected in a log and also the input CAS should be marked as failed. Again something for me to investigate. I will try to set up a test to see if I can create the scenario.It will take me a bit of time to set this up but I will let you know what happens. -jerry On Tue, Sep 27, 2016 at 12:42 PM, Jaroslaw Cwiklikwrote: > Here is the uima-as 2.9.0-SNAPSHOT to try: > https://repository.apache.org/content/repositories/snapshots > /org/apache/uima/uima-as/2.9.0-SNAPSHOT/uima-as-2.9.0- > 20160923.195233-6.tar.gz > > Can you briefly describe your service? Does your service have any remote > delegates or all parts of the pipeline are in the same process? > Do you see and exceptions in the service log? > > -jerry > > On Tue, Sep 27, 2016 at 9:07 AM, nelson rivera > wrote: > >> I was testing with AMQ broker 5.14.0 and i get the same error. not >> appears to be broker >> issues, appears to be uima-as issues. Any other idea, i am stagnant at >> work >> >> 2016-09-22 13:04 GMT-04:00, Jaroslaw Cwiklik : >> > Can you install AMQ broker 5.14.0 to see if this is related to broker >> > issues. >> > >> > -jerry >> > >> > On Thu, Sep 22, 2016 at 11:29 AM, nelson rivera < >> nelsonriver...@gmail.com> >> > wrote: >> > >> >> just like that, the parent CAS comes back but the child CAS doesnt. >> >> >> >> And the child CAS if processed, because the uima-as log shows the >> >> lines of the other annotators primitive of the flow processing the >> >> child CAS, but not comes back to UIMA-AS client. >> >> >> >> uima-as log only shows >> >> "Jms Listener Failed. Endpoint: >> >> temp-queue://ID:localhsot-H81-M1-33610-1474481197190-1:1:1 Managed By: >> >> tcp://localhost:61616 Reason: javax.jms.JMSException: >> >> java.io.EOFException" >> >> ADVERTENCIA: Jms Listener Failed. Endpoint: XClusterAnalyzerAggregate >> >> Managed By: tcp://localhost:61616 Reason: >> >> javax.jms.IllegalStateException: The Consumer is closed.. >> >> >> >> The CAS is send to service after restart the Broker, and how say >> >> parent CAS comes back but the child CAS doesnt. And if i try quiesce >> >> the Aggregate Service console shows : "Quiescing UIMA-AS Service. >> >> Remaining Number of CASes to Process:1". I suppose that is the child >> >> CAS. >> >> >> >> the client if can send more CASes to the service, but not receive >> >> response, for each CAS send after the one CAS that was send after >> >> restart broker (for which parent CAS comes back but the child CAS >> >> doesnt) not comes back parent CAS or child CAS. >> >> >> >> More specific: >> >> scenario 1: >> >> 1- Start Broker and UIMA-AS aggregate service. Everything is fine. >> >> >> >> 2- Restart Broker (without restart the service). UIMA-AS log show : >> >> "Jms Listener Failed." >> >> 3- Client sends a CAS to UIMA-AS aggregate service.(The parent CAS >> >> comes back but the child CAS doesnt, to the uima-as client.) >> >> If i try quiesce the Aggregate Service console shows : "Quiescing >> >> UIMA-AS Service. Remaining Number of CASes to Process:1" >> >> >> >> scenario 2: >> >> 1- Start Broker and UIMA-AS aggregate service. Everything is fine. >> >> >> >> 2- Restart Broker (without restart the service). UIMA-AS log show : >> >> "Jms Listener Failed." >> >> 3- Client sends a CAS to UIMA-AS aggregate service.(The parent CAS >> >> comes back but the child CAS doesnt, to the uima-as client) >> >> 4- Client sends another CAS to UIMA-AS aggregate service.(not comes >> >> back parent CAS or child CAS , to the uima-as client) >> >> 5- Client sends another CAS to UIMA-AS aggregate service.(not comes >> >> back parent CAS or child CAS , to the uima-as client) >> >> If i try quiesce the Aggregate Service console shows: "Quiescing >> >> UIMA-AS Service. Remaining Number of CASes to Process:5" >> >> >> >> >> >> >> >> >> >> >> >> 2016-09-22 10:50 GMT-04:00, Jaroslaw Cwiklik : >> >> > When a parent CAS comes back (after broker is restored), can the >> client >> >> > send more CASes to the service and receive responses? I am trying to >> >> > determine what the real problem is here. >> >> > >> >> > 1) JMS Listener not recovering connection >> >> > 2) UIMA-AS is not handling CAS reply failures when broker connection >> is >> >> > stale >> >> > >> >> > -jerry >> >> > >> >> > On Thu, Sep 22, 2016 at 10:38 AM, Jaroslaw Cwiklik > > >> >> > wrote: >> >> > >> >> >> Strange. You say that the parent CAS comes back but
Re: Broken conections after ACTIVEMQ restart
Here is the uima-as 2.9.0-SNAPSHOT to try: https://repository.apache.org/content/repositories/ snapshots/org/apache/uima/uima-as/2.9.0-SNAPSHOT/uima- as-2.9.0-20160923.195233-6.tar.gz Can you briefly describe your service? Does your service have any remote delegates or all parts of the pipeline are in the same process? Do you see and exceptions in the service log? -jerry On Tue, Sep 27, 2016 at 9:07 AM, nelson riverawrote: > I was testing with AMQ broker 5.14.0 and i get the same error. not > appears to be broker > issues, appears to be uima-as issues. Any other idea, i am stagnant at work > > 2016-09-22 13:04 GMT-04:00, Jaroslaw Cwiklik : > > Can you install AMQ broker 5.14.0 to see if this is related to broker > > issues. > > > > -jerry > > > > On Thu, Sep 22, 2016 at 11:29 AM, nelson rivera < > nelsonriver...@gmail.com> > > wrote: > > > >> just like that, the parent CAS comes back but the child CAS doesnt. > >> > >> And the child CAS if processed, because the uima-as log shows the > >> lines of the other annotators primitive of the flow processing the > >> child CAS, but not comes back to UIMA-AS client. > >> > >> uima-as log only shows > >> "Jms Listener Failed. Endpoint: > >> temp-queue://ID:localhsot-H81-M1-33610-1474481197190-1:1:1 Managed By: > >> tcp://localhost:61616 Reason: javax.jms.JMSException: > >> java.io.EOFException" > >> ADVERTENCIA: Jms Listener Failed. Endpoint: XClusterAnalyzerAggregate > >> Managed By: tcp://localhost:61616 Reason: > >> javax.jms.IllegalStateException: The Consumer is closed.. > >> > >> The CAS is send to service after restart the Broker, and how say > >> parent CAS comes back but the child CAS doesnt. And if i try quiesce > >> the Aggregate Service console shows : "Quiescing UIMA-AS Service. > >> Remaining Number of CASes to Process:1". I suppose that is the child > >> CAS. > >> > >> the client if can send more CASes to the service, but not receive > >> response, for each CAS send after the one CAS that was send after > >> restart broker (for which parent CAS comes back but the child CAS > >> doesnt) not comes back parent CAS or child CAS. > >> > >> More specific: > >> scenario 1: > >> 1- Start Broker and UIMA-AS aggregate service. Everything is fine. > >> > >> 2- Restart Broker (without restart the service). UIMA-AS log show : > >> "Jms Listener Failed." > >> 3- Client sends a CAS to UIMA-AS aggregate service.(The parent CAS > >> comes back but the child CAS doesnt, to the uima-as client.) > >> If i try quiesce the Aggregate Service console shows : "Quiescing > >> UIMA-AS Service. Remaining Number of CASes to Process:1" > >> > >> scenario 2: > >> 1- Start Broker and UIMA-AS aggregate service. Everything is fine. > >> > >> 2- Restart Broker (without restart the service). UIMA-AS log show : > >> "Jms Listener Failed." > >> 3- Client sends a CAS to UIMA-AS aggregate service.(The parent CAS > >> comes back but the child CAS doesnt, to the uima-as client) > >> 4- Client sends another CAS to UIMA-AS aggregate service.(not comes > >> back parent CAS or child CAS , to the uima-as client) > >> 5- Client sends another CAS to UIMA-AS aggregate service.(not comes > >> back parent CAS or child CAS , to the uima-as client) > >> If i try quiesce the Aggregate Service console shows: "Quiescing > >> UIMA-AS Service. Remaining Number of CASes to Process:5" > >> > >> > >> > >> > >> > >> 2016-09-22 10:50 GMT-04:00, Jaroslaw Cwiklik : > >> > When a parent CAS comes back (after broker is restored), can the > client > >> > send more CASes to the service and receive responses? I am trying to > >> > determine what the real problem is here. > >> > > >> > 1) JMS Listener not recovering connection > >> > 2) UIMA-AS is not handling CAS reply failures when broker connection > is > >> > stale > >> > > >> > -jerry > >> > > >> > On Thu, Sep 22, 2016 at 10:38 AM, Jaroslaw Cwiklik > >> > wrote: > >> > > >> >> Strange. You say that the parent CAS comes back but the child CAS > >> doesnt. > >> >> Are there any exceptions in the service log? Perhaps the service is > >> >> unable > >> >> to send the child CAS due to missing broker. There should be > something > >> in > >> >> the uima-as log about this. > >> >> > >> >> -jerry > >> >> > >> >> On Thu, Sep 22, 2016 at 10:19 AM, nelson rivera > >> >> > >> >> wrote: > >> >> > >> >>> Yes, it is supposed to do the service, given a > >> >>> CAS it produces a child CAS and and this CAS continue in the flow, > >> >>> that are other primitive annotators. And I expected that the child > >> >>> CAS > >> >>> will sent to UIMA-AS client, but not do. > >> >>> > >> >>> the scenario: > >> >>> 1- Start Broker and UIMA-AS aggregate service > >> >>> 2- Client sends a CAS to UIMA-AS aggregate service to verify > >> >>> everything is fine. The process is correct. > >> >>> > >> >>> 3- Restart Broker (without restart the
Re: Broken conections after ACTIVEMQ restart
I was testing with AMQ broker 5.14.0 and i get the same error. not appears to be broker issues, appears to be uima-as issues. Any other idea, i am stagnant at work 2016-09-22 13:04 GMT-04:00, Jaroslaw Cwiklik: > Can you install AMQ broker 5.14.0 to see if this is related to broker > issues. > > -jerry > > On Thu, Sep 22, 2016 at 11:29 AM, nelson rivera > wrote: > >> just like that, the parent CAS comes back but the child CAS doesnt. >> >> And the child CAS if processed, because the uima-as log shows the >> lines of the other annotators primitive of the flow processing the >> child CAS, but not comes back to UIMA-AS client. >> >> uima-as log only shows >> "Jms Listener Failed. Endpoint: >> temp-queue://ID:localhsot-H81-M1-33610-1474481197190-1:1:1 Managed By: >> tcp://localhost:61616 Reason: javax.jms.JMSException: >> java.io.EOFException" >> ADVERTENCIA: Jms Listener Failed. Endpoint: XClusterAnalyzerAggregate >> Managed By: tcp://localhost:61616 Reason: >> javax.jms.IllegalStateException: The Consumer is closed.. >> >> The CAS is send to service after restart the Broker, and how say >> parent CAS comes back but the child CAS doesnt. And if i try quiesce >> the Aggregate Service console shows : "Quiescing UIMA-AS Service. >> Remaining Number of CASes to Process:1". I suppose that is the child >> CAS. >> >> the client if can send more CASes to the service, but not receive >> response, for each CAS send after the one CAS that was send after >> restart broker (for which parent CAS comes back but the child CAS >> doesnt) not comes back parent CAS or child CAS. >> >> More specific: >> scenario 1: >> 1- Start Broker and UIMA-AS aggregate service. Everything is fine. >> >> 2- Restart Broker (without restart the service). UIMA-AS log show : >> "Jms Listener Failed." >> 3- Client sends a CAS to UIMA-AS aggregate service.(The parent CAS >> comes back but the child CAS doesnt, to the uima-as client.) >> If i try quiesce the Aggregate Service console shows : "Quiescing >> UIMA-AS Service. Remaining Number of CASes to Process:1" >> >> scenario 2: >> 1- Start Broker and UIMA-AS aggregate service. Everything is fine. >> >> 2- Restart Broker (without restart the service). UIMA-AS log show : >> "Jms Listener Failed." >> 3- Client sends a CAS to UIMA-AS aggregate service.(The parent CAS >> comes back but the child CAS doesnt, to the uima-as client) >> 4- Client sends another CAS to UIMA-AS aggregate service.(not comes >> back parent CAS or child CAS , to the uima-as client) >> 5- Client sends another CAS to UIMA-AS aggregate service.(not comes >> back parent CAS or child CAS , to the uima-as client) >> If i try quiesce the Aggregate Service console shows: "Quiescing >> UIMA-AS Service. Remaining Number of CASes to Process:5" >> >> >> >> >> >> 2016-09-22 10:50 GMT-04:00, Jaroslaw Cwiklik : >> > When a parent CAS comes back (after broker is restored), can the client >> > send more CASes to the service and receive responses? I am trying to >> > determine what the real problem is here. >> > >> > 1) JMS Listener not recovering connection >> > 2) UIMA-AS is not handling CAS reply failures when broker connection is >> > stale >> > >> > -jerry >> > >> > On Thu, Sep 22, 2016 at 10:38 AM, Jaroslaw Cwiklik >> > wrote: >> > >> >> Strange. You say that the parent CAS comes back but the child CAS >> doesnt. >> >> Are there any exceptions in the service log? Perhaps the service is >> >> unable >> >> to send the child CAS due to missing broker. There should be something >> in >> >> the uima-as log about this. >> >> >> >> -jerry >> >> >> >> On Thu, Sep 22, 2016 at 10:19 AM, nelson rivera >> >> >> >> wrote: >> >> >> >>> Yes, it is supposed to do the service, given a >> >>> CAS it produces a child CAS and and this CAS continue in the flow, >> >>> that are other primitive annotators. And I expected that the child >> >>> CAS >> >>> will sent to UIMA-AS client, but not do. >> >>> >> >>> the scenario: >> >>> 1- Start Broker and UIMA-AS aggregate service >> >>> 2- Client sends a CAS to UIMA-AS aggregate service to verify >> >>> everything is fine. The process is correct. >> >>> >> >>> 3- Restart Broker (without restart the service). UIMA-AS log show : >> >>> "Jms Listener Failed." >> >>> 4- Client sends a CAS to UIMA-AS aggregate service >> >>> >> >>> UIMA-AS client receive the parent CAS, but not child CAS. >> >>> >> >>> Thank for you quick reply >> >>> >> >>> 2016-09-22 9:48 GMT-04:00, Jaroslaw Cwiklik : >> >>> > Can you clarify if the UIMA-AS service is a Cas Multiplier. Meaning >> >>> given a >> >>> > CAS it produces child CASes >> >>> > which are then sent to UIMA-AS client. Is this what this service is >> >>> > supposed to do if the broker is running? >> >>> > >> >>> > Can you confirm the scenario: >> >>> > 1) Client sends a CAS to UIMA-AS aggregate service >>