Class OortComet

java.lang.Object

org.cometd.common.AbstractClientSession

org.cometd.client.BayeuxClient

org.cometd.oort.OortComet

All Implemented Interfaces:

Bayeux, ClientSession, Session, org.eclipse.jetty.util.component.Dumpable

public class OortComet
extends BayeuxClient

The Oort comet client connects a local Oort comet server to a remote Oort comet server.

Nested Class Summary

Nested classes/interfaces inherited from class BayeuxClient

BayeuxClient.BackOffStrategy, BayeuxClient.BayeuxClientChannel, BayeuxClient.Scheduler, BayeuxClient.State

Nested classes/interfaces inherited from class AbstractClientSession

AbstractClientSession.AbstractSessionChannel

Nested classes/interfaces inherited from interface Bayeux

Bayeux.BayeuxListener, Bayeux.Validator

Nested classes/interfaces inherited from interface ClientSession

ClientSession.Extension, ClientSession.MessageListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

org.eclipse.jetty.util.component.Dumpable.DumpableContainer, org.eclipse.jetty.util.component.Dumpable.DumpAppendable

Field Summary

Fields inherited from class BayeuxClient

BACKOFF_INCREMENT_OPTION, BAYEUX_VERSION, MAX_BACKOFF_OPTION

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

LEGEND

Constructor Summary

Constructors

Constructor	Description
OortComet(Oort oort, String cometURL, ScheduledExecutorService scheduler, ClientTransport transport, ClientTransport... transports)

Method Summary

Modifier and Type	Method	Description
protected void	clearSubscriptions()
protected void	subscribe(Set<String> observedChannels)
String	toString()
protected void	unsubscribe(String channel)

Methods inherited from class BayeuxClient

abort, addTransportListener, disconnect, disconnect, enqueueSend, getAllowedTransports, getBackOffStrategy, getCookie, getHttpCookieStore, getId, getKnownTransportNames, getOption, getOptionNames, getOptions, getState, getTransport, getTransport, getURL, handshake, handshake, handshake, handshake, initialize, isConnected, isDisconnected, isHandshook, messagesFailure, newChannel, newChannelId, onTransportFailure, onTransportFailure, processConnect, processDisconnect, processHandshake, processMessage, putCookie, removeTransportListener, scheduleConnect, scheduleHandshake, send, sendBatch, sendConnect, sendHandshake, sendMessages, setBackOffStrategy, setOption, terminate, waitFor

Methods inherited from class AbstractClientSession

addExtension, batch, dump, endBatch, extendIncoming, extendOutgoing, getAttribute, getAttributeNames, getChannel, getChannel, getChannels, getExtensions, isBatching, newMessage, newMessageId, notifyCallback, notifyListeners, receive, registerCallback, registerSubscriber, remoteCall, removeAttribute, removeExtension, resetSubscriptions, setAttribute, startBatch, unregisterCallback, unregisterSubscriber

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface ClientSession

disconnect, handshake, handshake

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dumpSelf

Constructor Details

OortComet

public OortComet(Oort oort,
 String cometURL,
 ScheduledExecutorService scheduler,
 ClientTransport transport,
 ClientTransport... transports)

Method Details

subscribe

protected void subscribe(Set<String> observedChannels)

unsubscribe

protected void unsubscribe(String channel)

clearSubscriptions

protected void clearSubscriptions()

toString

public String toString()

Overrides:

toString in class BayeuxClient