it wasn't called.
I'll send you my demo..
the class GrizzlyClientProtocolChain2.java is using the
(CallbackHandler)null
2009/1/5 Oleksiy Stashok <Oleksiy.Stashok_at_sun.com>
> Sebastien, are you sure, that QuoteQueryProtocolFilter is never called on
> client side? Can you pls. double check this?
> If no - pls. send me client and server side code - I'll check it.
>
> Thank you.
>
> WBR,
> Alexey.
>
>
> On Dec 23, 2008, at 14:56 , Survivant 00 wrote:
>
> I'm trying to create a client using ProtocolChain but the client never
>> received messages from the server.
>>
>> and another thing : when I'm using controller.start(); the program block
>> there, and if I'm using new Thread(controler).start(); it's fine.. (still
>> not receiving messages from the server)
>>
>> here my code
>>
>>
>> package grizzly.client;
>>
>> import java.io.IOException;
>> import java.net.InetSocketAddress;
>> import java.nio.ByteBuffer;
>>
>> import org.slf4j.Logger;
>> import org.slf4j.LoggerFactory;
>>
>> import grizzly.client.filter.QuoteQueryManagerFilter;
>> import grizzly.client.filter.QuoteQueryProtocolFilter;
>> import com.sun.grizzly.BaseSelectionKeyHandler;
>> import com.sun.grizzly.CallbackHandler;
>> import com.sun.grizzly.Controller;
>> import com.sun.grizzly.DefaultProtocolChain;
>> import com.sun.grizzly.ProtocolChain;
>> import com.sun.grizzly.ProtocolChainInstanceHandler;
>> import com.sun.grizzly.TCPConnectorHandler;
>> import com.sun.grizzly.TCPSelectorHandler;
>> import com.sun.grizzly.util.ByteBufferFactory;
>>
>> public class SmallGrizzlyClient {
>>
>> private static final Logger s_logger =
>> LoggerFactory.getLogger(SmallGrizzlyClient.class);
>>
>> private TCPConnectorHandler connector_handler;
>> private Controller controller;
>> private TCPSelectorHandler tcp_selector_handler;
>>
>> private ByteBuffer buf = ByteBufferFactory.allocateView(1000, false);
>> private ByteBuffer response = ByteBufferFactory.allocateView(1000,
>> false);
>>
>> public void init() {
>>
>> controller = new Controller();
>>
>> tcp_selector_handler = new TCPSelectorHandler(true);
>> tcp_selector_handler.setSelectionKeyHandler(new
>> BaseSelectionKeyHandler());
>> controller.addSelectorHandler(tcp_selector_handler);
>>
>> QuoteQueryProtocolFilter protocolParser = new
>> QuoteQueryProtocolFilter();
>> QuoteQueryManagerFilter quoteManagerFilter = new
>> QuoteQueryManagerFilter();
>>
>>
>> ProtocolChainInstanceHandler pciHandler = new
>> ProtocolChainInstanceHandler() {
>>
>> final ProtocolChain protocolChain = new DefaultProtocolChain();
>>
>> public boolean offer(ProtocolChain protocolChain) {
>> return false;
>>
>> }
>>
>> public ProtocolChain poll() {
>>
>> return protocolChain;
>> }
>> };
>>
>> controller.setProtocolChainInstanceHandler(pciHandler);
>>
>> ProtocolChain protocolChain = pciHandler.poll();
>> protocolChain.addFilter(protocolParser);
>> protocolChain.addFilter(quoteManagerFilter);
>>
>> //new Thread(controller).start(); // continue fine
>> try {
>> controller.start(); // BLOCK HERE
>> } catch (IOException e) {
>> // TODO Auto-generated catch block
>> e.printStackTrace();
>> }
>> connector_handler = (TCPConnectorHandler)
>> controller.acquireConnectorHandler(Controller.Protocol.TCP);
>> }
>>
>> public void connect(String host, int port){
>> try {
>> connector_handler.connect(new InetSocketAddress(host, port),
>> (CallbackHandler)null);
>>
>> } catch (Exception e) {
>> s_logger.error("Exception in execute..." + e);
>> }
>> }
>>
>> public void send(String quote) throws Exception {
>> byte[] msg = quote.getBytes();
>>
>> buf = ByteBufferFactory.allocateView(msg.length, false);
>>
>> buf.put(msg);
>> buf.flip();
>> connector_handler.write(buf, true);
>> buf.clear();
>>
>> }
>>
>> public void close(){
>> try {
>> if(connector_handler!=null){
>> connector_handler.close();
>> }
>> if(controller!=null){
>> controller.stop();
>> }
>> } catch (IOException e) {
>> s_logger.error("IOException", e);
>> }
>> }
>>
>> public static void main(String[] args) {
>> SmallGrizzlyClient client = new SmallGrizzlyClient();
>>
>> String host = "localhost";
>> int port = 7803;
>>
>> try {
>> client.init();
>> Thread.sleep(300);
>> client.connect(host, port);
>>
>> Thread.sleep(300);
>> client.send("hello[eoq]");
>>
>> Thread.sleep(5000);
>>
>> client.close();
>>
>> Thread.sleep(300);
>> } catch(Exception e){
>> s_logger.error("main", e);
>> } finally {
>> try {client.close();}catch(Exception e){}
>> }
>>
>> }
>>
>> }
>>
>>
>> PS I know that the message sent by the client is receive on the server and
>> in the server log I see a message sent too. I have a debug log in all my
>> method in the QuoteQueryProtocolFilter and QuoteQueryProtocolManager
>>
>>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: users-unsubscribe_at_grizzly.dev.java.net
> For additional commands, e-mail: users-help_at_grizzly.dev.java.net
>
>