yes I'm using a ProtocolParser..
QuoteQueryProtocolFilter protocolParser = new QuoteQueryProtocolFilter();
:)
I'll put a flag on my thread. I need to fix that before putting my
application in test.
2008/11/12 Jeanfrancois Arcand <Jeanfrancois.Arcand_at_sun.com>
> Salut,
>
> Survivant 00 wrote:
>
>> I just find a bug in my application. I don't know how to get notify when
>> I client close the connection with the server. (TCP)
>>
>
> I can't remember when we talked about that, but I was under the impression
> the ReadFilter has an API to register listener when the connection get
> closed. But looking at the code, I guess I've dreamed....
>
> The solution is to write your own SelectionKeyHandler and monitor the
> SelectionKey that are closed. But I don't really like the solution.
>
> The logic should really be in ReadFilter, but I suspect you are using
> ProtocolParser and let me investigate more...Alexey and John might wakes
> faster than me on that :-)
>
> A+
>
> -Jeanfrancois
>
>
>
>
>> here the init of the server
>>
>> public void init(){
>> System.out.println("listening for incoming TCP Connections on
>> port : " + f_port);
>> try {
>> f_controller = new Controller();
>> TCPSelectorHandler tcpSelectorHandler = new
>> TCPSelectorHandler();
>> tcpSelectorHandler.setPort(f_port);
>>
>> Pipeline pipeline = new DefaultPipeline();
>> pipeline.setMaxThreads(5);
>> f_controller.setPipeline(pipeline);
>> tcpSelectorHandler.setSelectionKeyHandler(new
>> BaseSelectionKeyHandler());
>> f_controller.addSelectorHandler(tcpSelectorHandler);
>> QuoteQueryProtocolFilter protocolParser = new
>> QuoteQueryProtocolFilter();
>> QuoteQueryManagerFilter quoteManagerFilter = new
>> QuoteQueryManagerFilter(f_quoteManager);
>> final ProtocolChain protocolChain = new
>> DefaultProtocolChain();
>> protocolChain.addFilter(protocolParser);
>> protocolChain.addFilter(quoteManagerFilter);
>> ((DefaultProtocolChain)
>> protocolChain).setContinuousExecution(true);
>>
>>
>> ProtocolChainInstanceHandler pciHandler = new
>> DefaultProtocolChainInstanceHandler() {
>>
>> public ProtocolChain poll() {
>>
>> return protocolChain;
>> }
>>
>> public boolean offer(ProtocolChain protocolChain) {
>> return false;
>>
>> }
>> };
>>
>> f_controller.setProtocolChainInstanceHandler(pciHandler);
>> try {
>> f_controller.start();
>> } catch (IOException e) {
>> e.printStackTrace();
>> }
>> } catch (Exception e) {
>> System.exit(-10);
>> }
>> }
>>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>
>