I just see this code, which you sent:
> for (Iterator iter = context.getCometHandlers().iterator() ;
> iter.hasNext() ;) {
> handler = (CometHandler) iter.next();
> System.out.println("Found handler: " + handler);
> }
As I understand CometHandlers you iterate should be called during
notification process, right?
So it could be useful (IMHO), if you can add some output to those
handlers, to see if they got notified.
Thanks.
WBR,
Alexey.
On Aug 18, 2009, at 18:02 , victorng wrote:
>
> Sorry - I'm not quite clear on your request.
>
> Which CometHandler should I be modifying? I'm using the built in
> BayeuxHandler in the CometdServlet - do you want me to modify that
> class and
> redeploy?
>
> vic
>
>
>
> Oleksiy Stashok wrote:
>>
>> Hi,
>>
>> can I ask you to add some output to CometHandler code, to see if all
>> CometHandlers got notified and the problem is only in sending data
>> over socket.
>>
>> Thanks.
>>
>> WBR,
>> Alexey.
>>
>> On Aug 17, 2009, at 20:15 , victorng wrote:
>>
>>>
>>> I can reproduce this behaviour with the following code:
>>>
>>> I'm using GF v2.1 with the stock grizzly.
>>>
>>> I *thought* I saw this working but I guess I was delusional on
>>> Friday. :)
>>>
>>> I'm sending messages via JMS to a queue - I can see the messages get
>>> through, the cometcontext is properly acquired and I can see the
>>> CometHandlers all there - but nothing comes through on the website.
>>>
>>>
>>> The demo app I'm using is grizzly-cometd-chat-1.9.9.war
>>> (http://download.java.net/maven/2/com/sun/grizzly/samples/grizzly-cometd-chat/1.9.9/
>>> )
>>> and the MDB I'm using is at the bottom of this message.
>>>
>>> If it's of use, here's my Jython JMS code:
>>>
>>> def send():
>>> context = get_context()
>>> qfactory = context.lookup("jms/MyConnectionFactory")
>>> qconnection = qfactory.createQueueConnection('senduser',
>>> 'sendpass')
>>> qsession = qconnection.createQueueSession(False,
>>> Session.AUTO_ACKNOWLEDGE)
>>> qsender = qsession.createSender(context.lookup("jms/MyQueue"))
>>> msg = qsession.createTextMessage()
>>> msg.setText('this is a test message')
>>> qsender.send(msg)
>>>
>>> Is there something I should be doing to flush the messages down to
>>> the
>>> CometHandlers?
>>>
>>> thanks,
>>> vic
>>>
>>>
>>> Server logs:
>>>
>>> [#|2009-08-17T14:03:07.688-0400|INFO|sun-appserver2.1|
>>> javax.enterprise.system.stream.out|_ThreadID=40;_ThreadName=p:
>>> thread-pool-1; w: 47;|
>>> Got message: this is a test message|#]
>>>
>>> [#|2009-08-17T14:03:07.688-0400|INFO|sun-appserver2.1|
>>> javax.enterprise.system.stream.out|_ThreadID=40;_ThreadName=p:
>>> thread-pool-1; w: 47;|
>>> Engine:
>>> com.sun.enterprise.web.connector.grizzly.comet.CometEngine_at_1ef2fd3|
>>> #]
>>>
>>> [#|2009-08-17T14:03:07.688-0400|INFO|sun-appserver2.1|
>>> javax.enterprise.system.stream.out|_ThreadID=40;_ThreadName=p:
>>> thread-pool-1; w: 47;|
>>> ContextPath: /cometd/cometd|#]
>>>
>>> [#|2009-08-17T14:03:07.688-0400|INFO|sun-appserver2.1|
>>> javax.enterprise.system.stream.out|_ThreadID=40;_ThreadName=p:
>>> thread-pool-1; w: 47;|
>>> Context: /cometd/cometd|#]
>>>
>>> [#|2009-08-17T14:03:07.688-0400|INFO|sun-appserver2.1|
>>> javax.enterprise.system.stream.out|_ThreadID=40;_ThreadName=p:
>>> thread-pool-1; w: 47;|
>>> Sent {chat=Wake up call from the chatroom :-) to /chat/demo,
>>> user=ChatPinger} back down to the comet context|#]
>>>
>>> [#|2009-08-17T14:03:07.688-0400|INFO|sun-appserver2.1|
>>> javax.enterprise.system.stream.out|_ThreadID=40;_ThreadName=p:
>>> thread-pool-1; w: 47;|
>>> Found handler: com.sun.grizzly.cometd.DataHandler_at_11ab4ec|#]
>>>
>>> [#|2009-08-17T14:03:07.688-0400|INFO|sun-appserver2.1|
>>> javax.enterprise.system.stream.out|_ThreadID=40;_ThreadName=p:
>>> thread-pool-1; w: 47;|
>>> Found handler: com.sun.grizzly.cometd.BayeuxCometHandler_at_eaa683|#]
>>>
>>> [#|2009-08-17T14:03:07.688-0400|INFO|sun-appserver2.1|
>>> javax.enterprise.system.stream.out|_ThreadID=40;_ThreadName=p:
>>> thread-pool-1; w: 47;|
>>> Completed try block|#]
>>>
>>> --- code snip ---
>>>
>>> package com.crankycoder;
>>> import javax.ejb.MessageDriven;
>>> import javax.jms.MessageListener;
>>> import javax.jms.Message;
>>> import javax.jms.TextMessage;
>>> import java.util.Map;
>>> import java.util.HashMap;
>>> import java.util.Iterator;
>>> import com.sun.enterprise.web.connector.grizzly.comet.CometContext;
>>> import com.sun.enterprise.web.connector.grizzly.comet.CometEngine;
>>> import com.sun.grizzly.cometd.CometdNotificationHandler;
>>> import com.sun.grizzly.cometd.CometdRequest;
>>> import com.sun.enterprise.web.connector.grizzly.comet.CometHandler;
>>> import com.sun.grizzly.cometd.CometdResponse;
>>> import com.sun.grizzly.cometd.bayeux.Data;
>>> import com.sun.grizzly.cometd.bayeux.DeliverResponse;
>>>
>>> @MessageDriven(mappedName="jms/MyQueue")
>>> public class HelloMDB implements MessageListener {
>>>
>>> public void onMessage(Message msg) {
>>> try {
>>> if (msg instanceof TextMessage) {
>>> TextMessage txtmsg = (TextMessage) msg;
>>> String cpath = "/cometd/cometd";
>>> String topic ="/chat/demo";
>>> CometHandler handler = null;
>>> System.out.println("Got message: "+txtmsg.getText());
>>> CometEngine engine = CometEngine.getEngine();
>>> System.out.println("Engine: " + engine);
>>> CometContext context = engine.getCometContext(cpath);
>>> System.out.println("ContextPath: " + cpath);
>>> System.out.println("Context: " + context);
>>>
>>> Map<String, Object> map = new HashMap<String, Object>();
>>> map.put("chat", "Wake up call from the chatroom :-) to
>>> "+topic);
>>> map.put("user", "ChatPinger");
>>> Data data = new Data();
>>> data.setMapData(map);
>>> data.setChannel(topic);
>>> DeliverResponse deliverResponse = new DeliverResponse();
>>> deliverResponse.setChannel(topic);
>>> deliverResponse.setData(data);
>>> deliverResponse.setLast(true);
>>> deliverResponse.setFollow(true);
>>> context.notify(deliverResponse);
>>> System.out.println("Sent "+map+" back down to the comet
>>> context");
>>> for (Iterator iter = context.getCometHandlers().iterator() ;
>>> iter.hasNext() ;) {
>>> handler = (CometHandler) iter.next();
>>> System.out.println("Found handler: " + handler);
>>> }
>>> System.out.println("Completed try block");
>>> }
>>> } catch (Exception e) { System.out.println(e.toString()); }
>>> }
>>> }
>>>
>>> --
>>> View this message in context:
>>> http://www.nabble.com/grizzly-cometd-bayeux-not-sending-messages-to-all-subscribed-clients.-tp24460710p25011615.html
>>> Sent from the Grizzly - Users mailing list archive at Nabble.com.
>>>
>>>
>>> ---------------------------------------------------------------------
>>> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
>>> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>>>
>>
>>
>> ---------------------------------------------------------------------
>> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
>> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>>
>>
>>
>
> --
> View this message in context: http://www.nabble.com/grizzly-cometd-bayeux-not-sending-messages-to-all-subscribed-clients.-tp24460710p25028141.html
> Sent from the Grizzly - Users mailing list archive at Nabble.com.
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>