Skip navigation
(Alan_Smithee)
Currently Being Moderated

Clustered Glassfish JMS Subscription Problem (BlazeDS is Missing ClientID)

Mar 18, 2009 12:53 PM

We are migrating our BlazeDS environment under standalone Glassfish instances to clustered instances and we're now seeing this Glassfish error when a BlazeDS consumer tries to subscribe to a JMS message service:

[#|2009-03-18T15:51:33.863-0400|SEVERE|sun-appserver2.1|javax.jms.Sess ion.mqjmsra|_ThreadID=17;_ThreadName=httpWorkerThread-38080-1;_Request ID=4bdd20d7-d53c-4bbe-b157-9e0e28e4bbf5;|MQJMSRA_SA4001: createSubscriber:Exception:Require non-null, non-empty clientId for clustered non-durable subscription:cId=null|#]

Which seems to be saying that Glassfish requires the client to add a non null client ID. I am trying to find out why Glassfish requires this, but I don't see how to set the clientId in BlazeDS even if I had to. Is there a reason why BlazeDS does not use a clientID when subscribing and is there a way to change that behaviour?

(we're using a old version of BlazeDS : 3.0.0.544)
754 Views   1 Reply   Latest reply: (Alan_Smithee), Mar 19, 2009 12:48 PM
 
Replies
  • Currently Being Moderated
    1. (Alan_Smithee),
    Mar 19, 2009 12:48 PM   in reply to (Alan_Smithee)
    Report
    Here is some more detail about the failure. It looks like the client id is there (clientId = 6E65CA2E-AD0A-B43C-07B1-93E298534CB7) but somehow it's not being passed to the java Subscriber interface (or at least that's what Glassfish is complaining about).

    if this helps anyone:

    [#|2009-03-19T15:02:11.017-0400|INFO|sun-appserver2.1|javax.enterprise .system.stream.out|_ThreadID=17;_ThreadName=httpWorkerThread-38080-0;|
    [BlazeDS] 03/19/2009 15:02:11.016 [INFO] [Endpoint.General] Channel endpoint nrt-amf-polling received request.|#]

    [#|2009-03-19T15:02:11.030-0400|INFO|sun-appserver2.1|javax.enterprise .system.stream.out|_ThreadID=17;_ThreadName=httpWorkerThread-38080-0;|
    [BlazeDS] 03/19/2009 15:02:11.030 [INFO] [Service.Message.JMS] JMS consumer for JMS destination 'myTopic' is starting.|#]

    [#|2009-03-19T15:02:11.035-0400|SEVERE|sun-appserver2.1|javax.jms.Sess ion.mqjmsra|_ThreadID=17;_ThreadName=httpWorkerThread-38080-0;_Request ID=775538ad-6dc9-4c37-8eda-1c92a5159ae7;|MQJMSRA_SA4001: createSubscriber:Exception:Require non-null, non-empty clientId for clustered non-durable subscription:cId=null|#]

    [#|2009-03-19T15:02:11.036-0400|INFO|sun-appserver2.1|javax.enterprise .system.stream.out|_ThreadID=17;_ThreadName=httpWorkerThread-38080-0;|
    [BlazeDS] 03/19/2009 15:02:11.036 [INFO] [Service.Message.JMS] JMS consumer for JMS destination 'myTopic' is being removed from the JMS adapter due to the following error: MQJMSRA_SA4001: createSubscriber:Exception:Require non-null, non-empty clientId for clustered non-durable subscription:cId=null|#]

    [#|2009-03-19T15:02:11.037-0400|INFO|sun-appserver2.1|javax.enterprise .system.stream.out|_ThreadID=17;_ThreadName=httpWorkerThread-38080-0;|
    [BlazeDS] 03/19/2009 15:02:11.037 [INFO] [Service.Message.JMS] JMS consumer for JMS destination 'myTopic' is stopping.|#]

    [#|2009-03-19T15:02:11.044-0400|INFO|sun-appserver2.1|javax.enterprise .system.stream.out|_ThreadID=17;_ThreadName=httpWorkerThread-38080-0;|
    [BlazeDS] 03/19/2009 15:02:11.044 [INFO] [Service.Message.JMS] The corresponding MessageClient for JMS consumer for JMS destination 'myTopic' is being invalidated|#]

    [#|2009-03-19T15:02:11.050-0400|INFO|sun-appserver2.1|javax.enterprise .system.stream.out|_ThreadID=17;_ThreadName=httpWorkerThread-38080-0;|
    [BlazeDS] 03/19/2009 15:02:11.049 [ERROR] [Message.General] Unhandled error when processing a message: java.lang.RuntimeException: MessageClient has been invalidated.
    incomingMessage: Flex Message (flex.messaging.messages.CommandMessage)
    operation = subscribe
    selector = documentId = 68882 AND ticketId <> '71803febc8c39e49ac2995b15a24f0f0'
    clientId = 6E65CA2E-AD0A-B43C-07B1-93E298534CB7
    correlationId =
    destination = topicQueue
    messageId = A8DD1F01-4427-91C0-983E-201C94E4767F
    timestamp = 1237489331020
    timeToLive = 0
    body = {}
    hdr(DSSelector) = documentId = 68882 AND ticketId <> '71803febc8c39e49ac2995b15a24f0f0'
    hdr(DSRemoteCredentials) =
    hdr(DSId) = 6E3378A7-C708-D4AE-32DB-642F3B8CB8AD
    hdr(DSValidateEndpoint) = true
    hdr(DSEndpoint) = nrt-amf-polling
    errorReply: Flex Message (flex.messaging.messages.ErrorMessage)
    clientId = 6E65CA2E-AD0A-B43C-07B1-93E298534CB7
    correlationId = A8DD1F01-4427-91C0-983E-201C94E4767F
    destination = topicQueue
    messageId = 6E65FE76-7708-988C-2512-68103AE71E48
    timestamp = 1237489331047
    timeToLive = 0
    body = null
    code = Server.Processing
    message = There was an unhandled failure on the server. MessageClient has been invalidated.
    details = null
    rootCause = null
    body = null
    extendedData = null
    stackTrace for: java.lang.RuntimeException: MessageClient has been invalidated.
    flex.messaging.MessageClient.checkValid(MessageClient.java:894)
    flex.messaging.MessageClient.addSubscription(MessageClient.java:507)
    flex.messaging.services.messaging.SubscriptionManager.addSubscriber(S ubscriptionManager.java:498)
    flex.messaging.services.MessageService.manageSubscriptions(MessageSer vice.java:850)
    flex.messaging.services.MessageService.serviceCommand(MessageService. java:282)
    flex.messaging.MessageBroker.routeCommandToService(MessageBroker.java :1527)
    flex.messaging.endpoints.AbstractEndpoint.serviceMessage(AbstractEndp oint.java:855)
    flex.messaging.endpoints.amf.MessageBrokerFilter.invoke(MessageBroker Filter.java:121)
    flex.messaging.endpoints.amf.LegacyFilter.invoke(LegacyFilter.java:15 8)
    flex.messaging.endpoints.amf.SessionFilter.invoke(SessionFilter.java: 49)
    flex.messaging.endpoints.amf.BatchProcessFilter.invoke(BatchProcessFi lter.java:67)
    flex.messaging.endpoints.amf.SerializationFilter.invoke(Serialization Filter.java:146)
    flex.messaging.endpoints.BaseHTTPEndpoint.service(BaseHTTPEndpoint.ja va:274)
    flex.messaging.MessageBrokerServlet.service(MessageBrokerServlet.java :377)
    javax.servlet.http.HttpServlet.service(HttpServlet.java:847)
    org.apache.catalina.core.ApplicationFilterChain.servletService(Applic ationFilterChain.java:427)
    org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperV alve.java:315)
    org.apache.catalina.core.StandardContextValve.invokeInternal(Standard ContextValve.java:287)
    org.apache.catalina.core.StandardContextValve.invoke(StandardContextV alve.java:218)
    org.apache.catalina.core.StandardPipeline.doInvoke(StandardPipeline.j ava:648)
    org.apache.catalina.core.StandardPipeline.doInvoke(StandardPipeline.j ava:593)
    com.sun.enterprise.web.WebPipeline.invoke(WebPipeline.java:94)
    com.sun.enterprise.web.PESessionLockingStandardPipeline.invoke(PESess ionLockingStandardPipeline.java:98)
    org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.j ava:222)
    org.apache.catalina.core.StandardPipeline.doInvoke(StandardPipeline.j ava:648)
    org.apache.catalina.core.StandardPipeline.doInvoke(StandardPipeline.j ava:593)
    org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.jav a:587)
    org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:1096 )
    org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineVal ve.java:166)
    org.apache.catalina.core.StandardPipeline.doInvoke(StandardPipeline.j ava:648)
    org.apache.catalina.core.StandardPipeline.doInvoke(StandardPipeline.j ava:593)
    org.apache.catalina.core.StandardPipeline.invoke(StandardPipeline.jav a:587)
    org.apache.catalina.core.ContainerBase.invoke(ContainerBase.java:1096 )
    org.apache.coyote.tomcat5.CoyoteAdapter.service(CoyoteAdapter.java:28 8)
    com.sun.enterprise.web.connector.grizzly.DefaultProcessorTask.invokeA dapter(DefaultProcessorTask.java:647)
    com.sun.enterprise.web.connector.grizzly.DefaultProcessorTask.doProce ss(DefaultProcessorTask.java:579)
    com.sun.enterprise.web.connector.grizzly.DefaultProcessorTask.process (DefaultProcessorTask.java:831)
    com.sun.enterprise.web.connector.grizzly.DefaultReadTask.executeProce ssorTask(DefaultReadTask.java:341)
    com.sun.enterprise.web.connector.grizzly.DefaultReadTask.doTask(Defau ltReadTask.java:263)
    com.sun.enterprise.web.connector.grizzly.DefaultReadTask.doTask(Defau ltReadTask.java:214)
    com.sun.enterprise.web.connector.grizzly.TaskBase.run(TaskBase.java:2 65)
    com.sun.enterprise.web.connector.grizzly.WorkerThreadImpl.run(WorkerT hreadImpl.java:116)
    |#]
     
    |
    Mark as:
Actions

More Like This

  • Retrieving data ...

Bookmarked By (0)