com.sun.grizzly.cometd
Class BayeuxParser

java.lang.Object
  extended by com.sun.grizzly.cometd.BayeuxParser

public class BayeuxParser
extends Object

This class implement the Bayeux Server side protocol.

Author:
Jeanfrancois Arcand, TAKAI, Naoto

Field Summary
static String DEFAULT_CONTENT_TYPE
           
protected static DataHandler dumyhandler
           
 
Constructor Summary
BayeuxParser()
           
BayeuxParser(PublishInterceptor publishInterceptor)
           
 
Method Summary
 PublishInterceptor getPublishInterceptor()
          Interceptor, which (if not null) will process published data on channel.
 void onConnect(CometdContext cometdContext)
           
 void onDisconnect(CometdContext cometdContext)
           
 void onHandshake(CometdContext cometdContext)
           
 void onPing(CometdContext cometdContext)
           
 void onPublish(CometdContext cometdContext)
           
 void onReconnect(CometdContext cometdContext)
           
 void onStatus(CometdContext cometdContext)
           
 void onSubscribe(CometdContext cometdContext)
           
 void onUnsubscribe(CometdContext cometdContext)
           
 void parse(CometdContext cometdContext)
           
 void setPublishInterceptor(PublishInterceptor publishInterceptor)
          Interceptor, which (if not null) will process published data on channel.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

DEFAULT_CONTENT_TYPE

public static final String DEFAULT_CONTENT_TYPE
See Also:
Constant Field Values

dumyhandler

protected static final DataHandler dumyhandler
Constructor Detail

BayeuxParser

public BayeuxParser()

BayeuxParser

public BayeuxParser(PublishInterceptor publishInterceptor)
Method Detail

parse

public void parse(CometdContext cometdContext)
           throws IOException
Throws:
IOException

onHandshake

public void onHandshake(CometdContext cometdContext)
                 throws IOException
Throws:
IOException

onConnect

public void onConnect(CometdContext cometdContext)
               throws IOException
Throws:
IOException

onDisconnect

public void onDisconnect(CometdContext cometdContext)
                  throws IOException
Throws:
IOException

onReconnect

public void onReconnect(CometdContext cometdContext)
                 throws IOException
Throws:
IOException

onSubscribe

public void onSubscribe(CometdContext cometdContext)
                 throws IOException
Throws:
IOException

onUnsubscribe

public void onUnsubscribe(CometdContext cometdContext)
                   throws IOException
Throws:
IOException

onPublish

public void onPublish(CometdContext cometdContext)
               throws IOException
Throws:
IOException

onPing

public void onPing(CometdContext cometdContext)
            throws IOException
Throws:
IOException

onStatus

public void onStatus(CometdContext cometdContext)
              throws IOException
Throws:
IOException

getPublishInterceptor

public PublishInterceptor getPublishInterceptor()
Interceptor, which (if not null) will process published data on channel. If Interceptor is null - default logic is applied - everyone gets notified.

Returns:
PublishInterceptor

setPublishInterceptor

public void setPublishInterceptor(PublishInterceptor publishInterceptor)
Interceptor, which (if not null) will process published data on channel. If Interceptor is null - default logic is applied - everyone gets notified.

Parameters:
publishInterceptor - PublishInterceptor


Copyright © 2013 Oracle Corporation. All Rights Reserved.